Class Utils

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

Properties

| Edit this page View Source

UnboundedMailboxConfig

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

Methods

| Edit this page View Source

AssertAllStagesStopped(TestKitBase, Action, IMaterializer, TimeSpan?, CancellationToken)

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

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

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

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

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

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

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

AssertDispatcher(IActorRef, string)

Declaration
public static void AssertDispatcher(IActorRef @ref, string dispatcher)
Parameters
Type Name Description
IActorRef ref
string dispatcher
| Edit this page View Source

AwaitResult<T>(Task<T>, 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
TimeSpan? timeout
Returns
Type Description
T
Type Parameters
Name Description
T