Class Utils

Inheritance
Object
Utils
Inherited Members
Namespace: Akka.Streams.TestKit
Assembly: Akka.Streams.TestKit.dll
Syntax
public static class Utils

Properties

| Improve this Doc View Source

UnboundedMailboxConfig

Declaration
public static Config UnboundedMailboxConfig { get; }
Property Value
Type Description
Config

Methods

| Improve this Doc View Source

AssertAllStagesStopped(TestKitBase, Action, IMaterializer, Nullable<TimeSpan>, CancellationToken)

Declaration
public static void AssertAllStagesStopped(this TestKitBase spec, Action block, IMaterializer materializer, TimeSpan? timeout = null, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
TestKitBase spec
Action block
IMaterializer materializer
Nullable<TimeSpan> timeout
CancellationToken cancellationToken
| Improve this Doc View Source

AssertAllStagesStopped<T>(TestKitBase, Func<T>, IMaterializer, Nullable<TimeSpan>, CancellationToken)

Declaration
public static T AssertAllStagesStopped<T>(this TestKitBase spec, Func<T> block, IMaterializer materializer, TimeSpan? timeout = null, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
TestKitBase spec
Func<T> block
IMaterializer materializer
Nullable<TimeSpan> timeout
CancellationToken cancellationToken
Returns
Type Description
T
Type Parameters
Name Description
T
| Improve this Doc View Source

AssertAllStagesStoppedAsync(TestKitBase, Func<Task>, IMaterializer, Nullable<TimeSpan>, CancellationToken)

Declaration
public static async Task AssertAllStagesStoppedAsync(this TestKitBase spec, Func<Task> block, IMaterializer materializer, TimeSpan? timeout = null, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
TestKitBase spec
Func<Task> block
IMaterializer materializer
Nullable<TimeSpan> timeout
CancellationToken cancellationToken
Returns
Type Description
Task
| Improve this Doc View Source

AssertAllStagesStoppedAsync<T>(TestKitBase, Func<Task<T>>, IMaterializer, Nullable<TimeSpan>, CancellationToken)

Declaration
public static async Task<T> AssertAllStagesStoppedAsync<T>(this TestKitBase spec, Func<Task<T>> block, IMaterializer materializer, TimeSpan? timeout = null, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type Name Description
TestKitBase spec
Func<Task<T>> block
IMaterializer materializer
Nullable<TimeSpan> timeout
CancellationToken cancellationToken
Returns
Type Description
Task<T>
Type Parameters
Name Description
T
| Improve this Doc View Source

AssertDispatcher(IActorRef, String)

Declaration
public static void AssertDispatcher(IActorRef ref, string dispatcher)
Parameters
Type Name Description
IActorRef ref
String dispatcher
| Improve this Doc View Source

AwaitResult<T>(Task<T>, Nullable<TimeSpan>)

Declaration
[Obsolete("Use ShouldCompleteWithin instead")]
public static T AwaitResult<T>(this Task<T> task, TimeSpan? timeout = null)
Parameters
Type Name Description
Task<T> task
Nullable<TimeSpan> timeout
Returns
Type Description
T
Type Parameters
Name Description
T