Hi, I have created a Gist: https://gist.github.com/dnvriend/2f0d104b63b5348ddbc6
I use the `expectNextUnordered` method and that method has the problem. The `expectNext` method runs fine. Maybe you could have a look. Regards, Dennis Op woensdag 23 december 2015 23:08:42 UTC+1 schreef Konrad Malawski: > > This sounds a bit weird... I don't think those changed that much in the > move to 2.0. > Could you make the problem example a gist (gist.github.com or complete > snippet in email, ready to copy/paste) I could downlaod and quickly have a > look? Thanks in advance! > > -- > Cheers, > Konrad 'ktoso’ Malawski > Akka <http://akka.io> @ Typesafe <http://typesafe.com> > > On 23 December 2015 at 22:44:47, Dennis Vriend ([email protected] > <javascript:>) wrote: > > Hi, I have a question about akka stream. I want to migrate a project from > akka 2.3 to 2.4.1 and akka stream 1.0 to 2.0.1 and I must now refactor > tests. In the test an akka stream is used with the fluent like DSL in which > one can expect messages. , an assertion error will be thrown "`remaining` > may not be called outside of `within`" > > The only way I can fix this is to refactor the test so that the > TestSubscriber will be closed over by the .within(FiniteDuration) method, > in which the curried function can do the assertion. This is different from > the 1.0 version of akka-stream. > > > Is this the correct way to use the TestSubscriber from now on or am I > missing something? > > Note: this would break the fluent chain like DSL from akka stream 1.0 in a > big way, which would be a shame. > > > Example from the 1.0 syntax: > > > currentPersistenceIds(readJournal) > > .request(2) > > .expectNextUnOrdered("a", "b") > > .expectComplete() > > > Using the code above will give the assertion error on akka stream 2.0. > > > To make it work the code must be: > > > val xx = currentPersistenceIds(readJournal) > > .request(2) > > > xx.within(10.seconds) { > > xx.expectNextUnOrdered("a", "b") > > .expectComplete() > > } > > > I am sure I am doing something wrong, can someone help me out? > > > Thanks! > > > Dennis > > > > -- > >>>>>>>>>> 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 [email protected] <javascript:>. > To post to this group, send email to [email protected] > <javascript:>. > Visit this group at https://groups.google.com/group/akka-user. > For more options, visit https://groups.google.com/d/optout. > > -- >>>>>>>>>> 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 [email protected]. To post to this group, send email to [email protected]. Visit this group at https://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
