I’m wondering if I'm seeing a problem related to https://github.com/akka/akka/issues/23111 <https://github.com/akka/akka/issues/23111>.
My `Source.single` completes quite quickly. I also have a custom stage with an async callback. I have observed that the stage registers as being completed while the async callback hasn't been serviced. It could absolutely be something wrong with my test case. I'm still not clear on why my custom stage is registered as being completed, although I don’t see it being because of the materialiser shutting down. If I concat an extra ByteString onto the Source.single then I don’t see the issue. Perhaps some race condition then… Here’s my (uncomfortable) workaround: https://github.com/huntc/landlord/blob/3785b47a2f770ede44351b588e3b53a7cdf7d013/landlordd/daemon/src/test/scala/com/github/huntc/landlord/JvmExecutorSpec.scala#L53-L60 <https://github.com/huntc/landlord/blob/3785b47a2f770ede44351b588e3b53a7cdf7d013/landlordd/daemon/src/test/scala/com/github/huntc/landlord/JvmExecutorSpec.scala#L53-L60> Thanks for helping me gain further insight into what’s going on. -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: >>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at https://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
