Click or drag to resize
Akka.NETAkka.Streams.TestKit Namespace
The Akka.Streams namespace contains classes that provide base testing functionality used to test event and message streaming.
Classes
  ClassDescription
Public classGraphStageMessages
Public classGraphStageMessages.DownstreamFinish
Public classGraphStageMessages.Failure
Public classGraphStageMessages.Pull
Public classGraphStageMessages.Push
Public classGraphStageMessages.UpstreamFinish
Public classStreamTestKit
Public classStreamTestKit.CompletedSubscription<T>
Public classStreamTestKit.FailedSubscription<T>
Public classStreamTestKit.PublisherProbeSubscription<T>
Public classTestPublisher
Provides factory methods for various Publishers.
Public classTestPublisher.ManualProbe<T>
Implementation of IPublisher that allows various assertions. This probe does not track demand.Therefore you need to expect demand before sending elements downstream.
Public classTestPublisher.Probe<T>
Public classTestSink
Public classTestSinkStage<T, TMat>
Public classTestSource
Public classTestSourceStage<T, TMat>
Public classTestSubscriber
Public classTestSubscriber.ManualProbe<T>
Implementation of ISubscriber that allows various assertions. All timeouts are dilated automatically, for more details about time dilation refer to Akka.Streams.TestKit.
Public classTestSubscriber.OnComplete
Public classTestSubscriber.Probe<T>
Public classTestUtils
Structures
Interfaces