Package akka.stream.testkit

Interface Summary

Interface	Description
GraphStageMessages.StageMessage
TestPublisher.PublisherEvent
TestSubscriber.SubscriberEvent

Class Summary

Class	Description
GraphStageMessages	Messages emitted after the corresponding stageUnderTest methods has been invoked.
GraphStageMessages.DownstreamFinish$
GraphStageMessages.Failure
GraphStageMessages.Failure$
GraphStageMessages.Pull$
GraphStageMessages.Push$
GraphStageMessages.StageFailure	Sent to the probe when the operator callback threw an exception param: operation The operation that failed
GraphStageMessages.StageFailure$
GraphStageMessages.UpstreamFinish$
GraphStageMessages$	Messages emitted after the corresponding stageUnderTest methods has been invoked.
StreamTestKit	INTERNAL API
StreamTestKit.CompletedSubscription<T>
StreamTestKit.CompletedSubscription$
StreamTestKit.FailedSubscription<T>
StreamTestKit.FailedSubscription$
StreamTestKit.ProbeSink<T>
StreamTestKit.ProbeSource<T>
StreamTestKit.PublisherProbeSubscription<I>
StreamTestKit.PublisherProbeSubscription$
StreamTestKit$	INTERNAL API
TestPublisher	Provides factory methods for various Publishers.
TestPublisher.CancelSubscription
TestPublisher.CancelSubscription$
TestPublisher.ManualProbe<I>
TestPublisher.ManualProbe$
TestPublisher.Probe<T>	Single subscription and demand tracking for TestPublisher.ManualProbe.
TestPublisher.Probe$
TestPublisher.RequestMore
TestPublisher.RequestMore$
TestPublisher.Subscribe
TestPublisher.Subscribe$
TestPublisher.SubscriptionDone$
TestPublisher$	Provides factory methods for various Publishers.
TestSinkStage$
TestSourceStage$
TestSubscriber
TestSubscriber.ManualProbe<I>	Implementation of Subscriber that allows various assertions.
TestSubscriber.ManualProbe$
TestSubscriber.OnComplete$
TestSubscriber.OnError
TestSubscriber.OnError$
TestSubscriber.OnNext<I>
TestSubscriber.OnNext$
TestSubscriber.OnSubscribe
TestSubscriber.OnSubscribe$
TestSubscriber.Probe<T>	Single subscription tracking for TestSubscriber.ManualProbe.
TestSubscriber.Probe$
TestSubscriber$