From d374bb4ab326873d9bfaa58dd3035598187d3d83 Mon Sep 17 00:00:00 2001
From: Jason Longshore <longshorej@gmail.com>
Date: Wed, 17 Jul 2019 17:26:41 -0500
Subject: [PATCH] Partially revert #1818

---
 .../stream/alpakka/mqtt/streaming/impl/QueueOfferState.scala    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/mqtt-streaming/src/main/scala/akka/stream/alpakka/mqtt/streaming/impl/QueueOfferState.scala b/mqtt-streaming/src/main/scala/akka/stream/alpakka/mqtt/streaming/impl/QueueOfferState.scala
index 83316751da..c5bebf1b04 100644
--- a/mqtt-streaming/src/main/scala/akka/stream/alpakka/mqtt/streaming/impl/QueueOfferState.scala
+++ b/mqtt-streaming/src/main/scala/akka/stream/alpakka/mqtt/streaming/impl/QueueOfferState.scala
@@ -43,5 +43,5 @@ private[mqtt] object QueueOfferState {
         case (_, other) =>
           waitForQueueOfferCompleted(behavior, stash = stash :+ other)
       }
-      .receiveSignal { case (ctx, signal) => Behavior.interpretSignal(behavior, ctx, signal) } // handle signals immediately
+      .orElse(behavior) // handle signals immediately
 }