Hi Jason, I'm a newbie pursuing Streams testing as well.
I was wondering if you had run into; or found a way through a couple of the build.sbt dependency issues I was running into with the v2.9 Docs on Akka WebSocket support with Streams? (Pls see my recent posts!) If so; would you mind please sharing your insights by replying to my Posts with links to any information that would help with answering my questions on that? I'd already found a build.sbt here; but it looks like the wrong one as it's too general and complex for the specific dependency set I need: https://github.com/akka/akka/tree/v2.4.9/akka-http-tests Thanks in advance for any help! Dagny T On Tuesday, August 30, 2016 at 4:04:30 PM UTC-7, Jason Steenstra-Pickens wrote: > > Hi, > > I'm trying to use the Probes in *StreamTestKit* but I have hit a few > issues, specifically relating to the various probes. > > The main one is that for all types of probes (*Publisher*/*Subscriber* > *ManualProbe*/*Probe*) the actual *TestProbe* is encapsulated as a > private member and most of the functions just delegate to this inner probe. > The problem is that there is no way to set the *end* time which would > normally be done via the *within* construct. > > The second issue is the combination of the fact that > *TestPublisher.Probe#ensureSubscription* does not return the underlying > *Subscription* and this class does not override the *expectSubscription* to > initialise the lazy val. The consequence of this is that you cannot get the > *Subscription* and then use any of the other functions that internally > use the lazy val otherwise it will expect two subscriptions. > > Lastly, a relatively minor but frustrating issue is that > *ManualProbe#expectSubscription* returns a *PublisherProbeSubscription* which > has some useful functions for doing things on a per-subscription basis > rather than for the whole Publisher. However *StreamTestKit* is private > so even though *PublisherProbeSubscription* escapes out, you can't refer > to its type so writing helper functions etc is not possible. > > I was just hoping to raise these and get some feedback around whether > anyone else had noticed these or perhaps I'm just using it wrong. > > I really like Akka Streams and I'm hoping to get into a better position to > start contributing back. Keep up the good work! > > > Cheers, > Jason > -- >>>>>>>>>> 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.
