Click or drag to resize
Akka.NETTestSubscriberManualProbeT Class
Implementation of ISubscriber that allows various assertions. All timeouts are dilated automatically, for more details about time dilation refer to Akka.Streams.TestKit.
Inheritance Hierarchy
SystemObject
  Akka.Streams.TestKitTestSubscriberManualProbeT
    Akka.Streams.TestKitTestSubscriberProbeT

Namespace:  Akka.Streams.TestKit
Assembly:  Akka.Streams.TestKit (in Akka.Streams.TestKit.dll) Version: 1.0.0.0 (1.0.0.0)
Syntax
public class ManualProbe<T> : ISubscriber<T>

Type Parameters

T

[Missing <typeparam name="T"/> documentation for "T:Akka.Streams.TestKit.TestSubscriber.ManualProbe`1"]

The TestSubscriberManualProbeT type exposes the following members.

Methods
  NameDescription
Public methodEquals
Determines whether the specified object is equal to the current object.
(Inherited from Object.)
Public methodExpectComplete
Fluent DSL. Expect completion.
Public methodExpectError
Expect and return the signalled Exception.
Public methodExpectEvent
Public methodExpectEvent(TimeSpan)
Public methodExpectEvent(TestSubscriberISubscriberEvent)
Public methodExpectEventTOther(FuncTestSubscriberISubscriberEvent, TOther)
Public methodExpectNext
Expect and return a stream element.
Public methodExpectNext(T)
Fluent DSL. Expect a stream element.
Public methodExpectNext(T, TimeSpan)
Fluent DSL. Expect a stream element during specified timeout.
Public methodExpectNext(T, T, T)
Fluent DSL. Expect multiple stream elements.
Public methodExpectNextTOther(PredicateTOther)
Public methodExpectNextN(IEnumerableT)
Fluent DSL. Expect the given elements to be signalled in order.
Public methodExpectNextN(Int64)
Expect and return the next n stream elements.
Public methodExpectNextOrComplete
Expect given next element or stream completion, returning whichever was signaled.
Public methodExpectNextOrComplete(T)
Fluent DSL. Expect given next element or stream completion.
Public methodExpectNextOrError
Expect given next element or error signal, returning whichever was signaled.
Public methodExpectNextOrError(T, Exception)
Fluent DSL. Expect given next element or error signal.
Public methodExpectNextUnordered
FluentDSL. Expect multiple stream elements in arbitrary order.
Public methodExpectNextUnorderedN
Fluent DSL. Expect the given elements to be signalled in any order.
Public methodExpectNoMsg
Fluent DSL. Same as ExpectNoMsg(TimeSpan), but correctly treating the timeFactor.
Public methodExpectNoMsg(TimeSpan)
Fluent DSL. Assert that no message is received for the specified time.
Public methodExpectSubscription
Expects and returns ISubscription.
Public methodExpectSubscriptionAndComplete
Fluent DSL. Expect subscription followed by immediate stream completion. By default single demand will be signaled in order to wake up a possibly lazy upstream
Public methodExpectSubscriptionAndComplete(Boolean)
Fluent DSL. Expect subscription followed by immediate stream completion. Depending on the `signalDemand` parameter demand may be signaled immediately after obtaining the subscription in order to wake up a possibly lazy upstream. You can disable this by setting the `signalDemand` parameter to `false`.
Public methodExpectSubscriptionAndError
Expect subscription to be followed immediately by an error signal. By default single demand will be signaled in order to wake up a possibly lazy upstream.
Public methodExpectSubscriptionAndError(Boolean)
Expect subscription to be followed immediately by an error signal. Depending on the `signalDemand` parameter demand may be signaled immediately after obtaining the subscription in order to wake up a possibly lazy upstream.You can disable this by setting the `signalDemand` parameter to `false`.
Protected methodFinalize
Allows an object to try to free resources and perform other cleanup operations before it is reclaimed by garbage collection.
(Inherited from Object.)
Public methodGetHashCode
Serves as the default hash function.
(Inherited from Object.)
Public methodGetType
Gets the Type of the current instance.
(Inherited from Object.)
Protected methodMemberwiseClone
Creates a shallow copy of the current Object.
(Inherited from Object.)
Public methodOnComplete
Public methodOnError
Public methodOnNext
Public methodOnSubscribe
Public methodReceiveWhileTOther
Receive messages for a given duration or until one does not match a given partial function.
Public methodReceiveWithinTOther
Drains a given number of messages
Public methodToStrict
Attempt to drain the stream into a strict collection (by requesting MaxValue elements).
Public methodToString
Returns a string that represents the current object.
(Inherited from Object.)
Public methodWithinTOther
Top
Extension Methods
See Also