#752 Catch stashed lifecycle event from starting if not used (#753)

* Invoke Github Actions * #750: Fixed future handling in said test. * #752: Fixed extra dead letter on PerpetualStream startup.
paypal · Mar 10, 2022 · 7dba345 · 7dba345
1 parent 8074371
commit 7dba345
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 2 deletions.
diff --git a/.github/workflows/publish.yml b/.github/workflows/publish.yml
@@ -1,4 +1,4 @@
-name: Pull Request
+name: Build
 'on':
   push:
     branches:

diff --git a/squbs-unicomplex/src/main/scala/org/squbs/stream/PerpetualStreamBase.scala b/squbs-unicomplex/src/main/scala/org/squbs/stream/PerpetualStreamBase.scala
@@ -70,7 +70,7 @@ trait PerpetualStreamBase[T] extends Actor with ActorLogging with Stash with Gra
 
   final def starting: Receive = {
     case `streamRunLifecycleState` =>
-      context.become(running orElse flowMatValue orElse receive)
+      context.become(running orElse flowMatValue orElse receive orElse catchAnyLifecycleState)
       matValueOption = Option(runGraph())
       unstashAll()
     case _ => stash()
@@ -96,6 +96,10 @@ trait PerpetualStreamBase[T] extends Actor with ActorLogging with Stash with Gra
   final def flowMatValue: Receive = {
     case MatValueRequest => sender() ! matValue
   }
+
+  final def catchAnyLifecycleState: Receive = {
+    case _: LifecycleState => // Stashed lifecycle states without meaning or anyone caring should be ignored.
+  }
 }
 
 case object MatValueRequest {