Typo

commercetools · Jul 4, 2024 · 28d8366 · 28d8366
1 parent 9289223
commit 28d8366
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/core/src/main/scala/com/commercetools/queue/QueuePublisher.scala b/core/src/main/scala/com/commercetools/queue/QueuePublisher.scala
@@ -55,8 +55,8 @@ object QueuePublisher {
   /**
    * A publisher that does nothing.
    */
-  def noOp[F[_], T](implicit F: MonadCancel[F, Throwable]) = new QueuePublisher[F, T] {
+  def noop[F[_], T](implicit F: MonadCancel[F, Throwable]) = new QueuePublisher[F, T] {
     override def queueName: String = ""
-    override def pusher: Resource[F, QueuePusher[F, T]] = Resource.pure(QueuePusher.noOp)
+    override def pusher: Resource[F, QueuePusher[F, T]] = Resource.pure(QueuePusher.noop)
   }
 }
diff --git a/core/src/main/scala/com/commercetools/queue/QueuePusher.scala b/core/src/main/scala/com/commercetools/queue/QueuePusher.scala
@@ -46,7 +46,7 @@ object QueuePusher {
   /**
    * A pusher that does nothing.
    */
-  def noOp[F[_], T](implicit F: Applicative[F]) = new QueuePusher[F, T] {
+  def noop[F[_], T](implicit F: Applicative[F]) = new QueuePusher[F, T] {
     override def queueName: String = ""
     override def push(message: T, metadata: Map[String, String], delay: Option[FiniteDuration]): F[Unit] = F.unit
     override def push(messages: List[(T, Map[String, String])], delay: Option[FiniteDuration]): F[Unit] = F.unit

diff --git a/core/src/main/scala/com/commercetools/queue/QueueSubscriber.scala b/core/src/main/scala/com/commercetools/queue/QueueSubscriber.scala
@@ -172,6 +172,6 @@ abstract class QueueSubscriber[F[_], T](implicit F: Concurrent[F]) {
     waitingTime: FiniteDuration
   )(handler: MessageHandler[F, T, Res, ImmediateDecision]
   ): Stream[F, Either[Throwable, Res]] =
-    process[Res](batchSize, waitingTime, QueuePublisher.noOp)((msg: Message[F, T]) =>
+    process[Res](batchSize, waitingTime, QueuePublisher.noop)((msg: Message[F, T]) =>
       handler.handle(msg).widen[Decision[Res]])
 }