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.
