Namespace Akka.Streams.TestKit
Classes
ChainSetup<TIn, TOut, TMat>
Coroner
GraphStageMessages
GraphStageMessages.DownstreamFinish
GraphStageMessages.Failure
GraphStageMessages.Pull
GraphStageMessages.Push
GraphStageMessages.UpstreamFinish
PublisherFluentBuilder<T>
StreamTestKit
StreamTestKit.CompletedSubscription<T>
StreamTestKit.FailedSubscription<T>
StreamTestKit.PublisherProbeSubscription<T>
SubscriberFluentBuilder<T>
TestException
TestPublisher
Provides factory methods for various Publishers.
TestPublisher.ManualProbe<T>
Implementation of Reactive.Streams.IPublisher{T} that allows various assertions. This probe does not track demand.Therefore you need to expect demand before sending elements downstream.
TestPublisher.Probe<T>
Single subscription and demand tracking for TestPublisher.ManualProbe<T>.
TestSink
TestSinkStage<T, TMat>
TestSource
TestSourceStage<T, TMat>
TestSubscriber
TestSubscriber.ManualProbe<T>
Implementation of Reactive.Streams.ISubscriber{T} that allows various assertions. All timeouts are dilated automatically, for more details about time dilation refer to Akka.Streams.TestKit.
TestSubscriber.OnComplete
TestSubscriber.Probe<T>
Single subscription tracking for TestSubscriber.ManualProbe<T>.