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 classGraphStageMessagesDownstreamFinish
Public classGraphStageMessagesFailure
Public classGraphStageMessagesPull
Public classGraphStageMessagesPush
Public classGraphStageMessagesUpstreamFinish
Public classStreamTestKit
Public classStreamTestKitCompletedSubscriptionT
Public classStreamTestKitFailedSubscriptionT
Public classStreamTestKitPublisherProbeSubscriptionT
Public classTestPublisher
Provides factory methods for various Publishers.
Public classTestPublisherManualProbeT
Implementation of IPublisher that allows various assertions. This probe does not track demand.Therefore you need to expect demand before sending elements downstream.
Public classTestPublisherProbeT
Single subscription and demand tracking for TestPublisherManualProbeT.
Public classTestSink
Public classTestSinkStageT, TMat
Public classTestSource
Public classTestSourceStageT, TMat
Public classTestSubscriber
Public classTestSubscriberManualProbeT
Implementation of ISubscriber that allows various assertions. All timeouts are dilated automatically, for more details about time dilation refer to Akka.Streams.TestKit.
Public classTestSubscriberOnComplete
Public classTestSubscriberProbeT
Single subscription tracking for TestSubscriberManualProbeT.
Public classTestUtils
Structures
Interfaces