TestSubscriber.ManualProbe(T) Class

TestSubscriberManualProbeT 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

Copy

public class ManualProbe<T> : ISubscriber<T>

type ManualProbe<'T> =  
    class
        interface ISubscriber<'T>
    end

Type Parameters

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

The TestSubscriberManualProbeT type exposes the following members.

Methods

	Name	Description
	Equals	Determines whether the specified object is equal to the current object. (Inherited from Object.)
	ExpectComplete	Fluent DSL. Expect completion.
	ExpectError	Expect and return the signalled Exception.
	ExpectEvent	Expect and return TestSubscriberISubscriberEvent (any of: OnSubscribe(ISubscription), OnNext(T), OnError(Exception) or OnComplete).
	ExpectEvent(TimeSpan)	Expect and return TestSubscriberISubscriberEvent (any of: OnSubscribe(ISubscription), OnNext(T), OnError(Exception) or OnComplete).
	ExpectEvent(TestSubscriberISubscriberEvent)	Fluent DSL. Expect and return TestSubscriberISubscriberEvent (any of: OnSubscribe(ISubscription), OnNext(T), OnError(Exception) or OnComplete).
	ExpectEventTOther(FuncTestSubscriberISubscriberEvent, TOther)
	ExpectNext	Expect and return a stream element.
	ExpectNext(T)	Fluent DSL. Expect a stream element.
	ExpectNext(T, TimeSpan)	Fluent DSL. Expect a stream element during specified timeout.
	ExpectNext(T, T, T)	Fluent DSL. Expect multiple stream elements.
	ExpectNextTOther(PredicateTOther)
	ExpectNextN(IEnumerableT)	Fluent DSL. Expect the given elements to be signalled in order.
	ExpectNextN(Int64)	Expect and return the next n stream elements.
	ExpectNextOrComplete	Expect given next element or stream completion, returning whichever was signaled.
	ExpectNextOrComplete(T)	Fluent DSL. Expect given next element or stream completion.
	ExpectNextOrError	Expect given next element or error signal, returning whichever was signaled.
	ExpectNextOrError(T, Exception)	Fluent DSL. Expect given next element or error signal.
	ExpectNextUnordered	FluentDSL. Expect multiple stream elements in arbitrary order.
	ExpectNextUnorderedN	Fluent DSL. Expect the given elements to be signalled in any order.
	ExpectNoMsg	Fluent DSL. Same as ExpectNoMsg(TimeSpan), but correctly treating the timeFactor.
	ExpectNoMsg(TimeSpan)	Fluent DSL. Assert that no message is received for the specified time.
	ExpectSubscription	Expects and returns ISubscription.
	ExpectSubscriptionAndComplete	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
	ExpectSubscriptionAndComplete(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`.
	ExpectSubscriptionAndError	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.
	ExpectSubscriptionAndError(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`.
	Finalize	Allows an object to try to free resources and perform other cleanup operations before it is reclaimed by garbage collection. (Inherited from Object.)
	GetHashCode	Serves as the default hash function. (Inherited from Object.)
	GetType	Gets the Type of the current instance. (Inherited from Object.)
	MemberwiseClone	Creates a shallow copy of the current Object. (Inherited from Object.)
	OnComplete
	OnError
	OnNext
	OnSubscribe
	ReceiveWhileTOther	Receive messages for a given duration or until one does not match a given partial function.
	ReceiveWithinTOther	Drains a given number of messages
	ToStrict	Attempt to drain the stream into a strict collection (by requesting MaxValue elements).
	ToString	Returns a string that represents the current object. (Inherited from Object.)
	WithinTOther

Top

Extension Methods

	Name	Description
	AsInstanceOfT	TBD (Defined by Extensions.)
	Match	Overloaded. Matches the specified target. (Defined by PatternMatch.)
	MatchT	Overloaded. Matches the specified target and return a result of target processing. (Defined by PatternMatch.)

Top

Reference

Akka.Streams.TestKit Namespace