Click or drag to resize
Akka.NETTestSubscriberProbeT Class
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 Probe<T> : TestSubscriberManualProbe<T>

Type Parameters

T

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

The TestSubscriberProbeT type exposes the following members.

Methods
  NameDescription
Public methodCancel
Public methodEnsureSubscription
Asserts that a subscription has been received or will be received
Public methodEquals
Determines whether the specified object is equal to the current object.
(Inherited from Object.)
Public methodExpectComplete
Fluent DSL. Expect completion.
(Inherited from TestSubscriberManualProbeT.)
Public methodExpectError
Expect and return the signalled Exception.
(Inherited from TestSubscriberManualProbeT.)
Public methodExpectEvent (Inherited from TestSubscriberManualProbeT.)
Public methodExpectEvent(TimeSpan) (Inherited from TestSubscriberManualProbeT.)
Public methodExpectEvent(TestSubscriberISubscriberEvent) (Inherited from TestSubscriberManualProbeT.)
Public methodExpectEventTOther(FuncTestSubscriberISubscriberEvent, TOther) (Inherited from TestSubscriberManualProbeT.)
Public methodExpectNext
Expect and return a stream element.
(Inherited from TestSubscriberManualProbeT.)
Public methodExpectNext(T)
Fluent DSL. Expect a stream element.
(Inherited from TestSubscriberManualProbeT.)
Public methodExpectNext(T, TimeSpan)
Fluent DSL. Expect a stream element during specified timeout.
(Inherited from TestSubscriberManualProbeT.)
Public methodExpectNext(T, T, T)
Fluent DSL. Expect multiple stream elements.
(Inherited from TestSubscriberManualProbeT.)
Public methodExpectNextTOther(PredicateTOther) (Inherited from TestSubscriberManualProbeT.)
Public methodExpectNextN(IEnumerableT)
Fluent DSL. Expect the given elements to be signalled in order.
(Inherited from TestSubscriberManualProbeT.)
Public methodExpectNextN(Int64)
Expect and return the next n stream elements.
(Inherited from TestSubscriberManualProbeT.)
Public methodExpectNextOrComplete
Expect given next element or stream completion, returning whichever was signaled.
(Inherited from TestSubscriberManualProbeT.)
Public methodExpectNextOrComplete(T)
Fluent DSL. Expect given next element or stream completion.
(Inherited from TestSubscriberManualProbeT.)
Public methodExpectNextOrError
Expect given next element or error signal, returning whichever was signaled.
(Inherited from TestSubscriberManualProbeT.)
Public methodExpectNextOrError(T, Exception)
Fluent DSL. Expect given next element or error signal.
(Inherited from TestSubscriberManualProbeT.)
Public methodExpectNextUnordered
FluentDSL. Expect multiple stream elements in arbitrary order.
(Inherited from TestSubscriberManualProbeT.)
Public methodExpectNextUnorderedN
Fluent DSL. Expect the given elements to be signalled in any order.
(Inherited from TestSubscriberManualProbeT.)
Public methodExpectNoMsg
Fluent DSL. Same as ExpectNoMsg(TimeSpan), but correctly treating the timeFactor.
(Inherited from TestSubscriberManualProbeT.)
Public methodExpectNoMsg(TimeSpan)
Fluent DSL. Assert that no message is received for the specified time.
(Inherited from TestSubscriberManualProbeT.)
Public methodExpectSubscription
Expects and returns ISubscription.
(Inherited from TestSubscriberManualProbeT.)
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
(Inherited from TestSubscriberManualProbeT.)
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`.
(Inherited from TestSubscriberManualProbeT.)
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.
(Inherited from TestSubscriberManualProbeT.)
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`.
(Inherited from TestSubscriberManualProbeT.)
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 (Inherited from TestSubscriberManualProbeT.)
Public methodOnError (Inherited from TestSubscriberManualProbeT.)
Public methodOnNext (Inherited from TestSubscriberManualProbeT.)
Public methodOnSubscribe (Inherited from TestSubscriberManualProbeT.)
Public methodReceiveWhileTOther
Receive messages for a given duration or until one does not match a given partial function.
(Inherited from TestSubscriberManualProbeT.)
Public methodReceiveWithinTOther
Drains a given number of messages
(Inherited from TestSubscriberManualProbeT.)
Public methodRequest
Public methodRequestNext
Public methodRequestNext(T)
Public methodToStrict
Attempt to drain the stream into a strict collection (by requesting MaxValue elements).
(Inherited from TestSubscriberManualProbeT.)
Public methodToString
Returns a string that represents the current object.
(Inherited from Object.)
Public methodWithinTOther (Inherited from TestSubscriberManualProbeT.)
Top
Extension Methods
See Also