I've created a test that exercises a composite source that has an internal cycle. It processes integers, starting at 1 and doubling it until it is cancelled. The code can be viewed as a gist <https://gist.github.com/dpinn/cdac6709e00b7de64163>.
Two things to note: a) the stream completes successfully. To that extent, I've failed to reproduce the strangeness that I mentioned earlier; and b) the stream processes one more element than I expect it to. Doubling 1 Cancelling tick source => 2 Doubling 2 => 4 [error] Test cancellation.CancellationTest.testCancellation failed: assertion failed: expected OnComplete, found OnNext(4), took 4.11 sec [error] Failed: Total 1, Failed 1, Errors 0, Passed 0 [error] Failed tests: [error] cancellation.CancellationTest [error] (onedrive/test:test) sbt.TestsFailedException: Tests unsuccessful [error] Total time: 6 s, completed 26/07/2015 11:30:15 PM The source under test spits out the integer 4, even though the ticks were cancelled while the integer 1 was being doubled. -- >>>>>>>>>> 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 http://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
