Class InternalEventFilterApplier

Namespace

Akka.TestKit.Internal

Assembly

Akka.TestKit.dll

Note! Part of internal API. Breaking changes may occur without notice. Use at own risk.

public class InternalEventFilterApplier : IEventFilterApplier

Inheritance

object

InternalEventFilterApplier

Implements

IEventFilterApplier

Inherited Members

object.GetType()

object.MemberwiseClone()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

InternalEventFilterApplier(TestKitBase, ActorSystem, IReadOnlyList<EventFilterBase>)

TBD

public InternalEventFilterApplier(TestKitBase testkit, ActorSystem system, IReadOnlyList<EventFilterBase> filters)

Parameters

testkit TestKitBase

TBD

system ActorSystem

TBD

filters IReadOnlyList<EventFilterBase>

TBD

Properties

And

TBD

public EventFilterFactory And { get; }

Property Value

EventFilterFactory

Methods

AwaitDone(TimeSpan, int?, MatchedEventHandler, CancellationToken)

TBD

protected bool AwaitDone(TimeSpan timeout, int? expectedOccurrences, InternalEventFilterApplier.MatchedEventHandler matchedEventHandler, CancellationToken cancellationToken = default)

Parameters

timeout TimeSpan

TBD

expectedOccurrences int?

TBD

matchedEventHandler InternalEventFilterApplier.MatchedEventHandler

TBD

cancellationToken CancellationToken

Returns

bool

TBD

AwaitDoneAsync(TimeSpan, int?, MatchedEventHandler, CancellationToken)

Async version of AwaitDone(TimeSpan, int?, MatchedEventHandler, CancellationToken)

protected Task<bool> AwaitDoneAsync(TimeSpan timeout, int? expectedOccurrences, InternalEventFilterApplier.MatchedEventHandler matchedEventHandler, CancellationToken cancellationToken = default)

Parameters

timeout TimeSpan

expectedOccurrences int?

matchedEventHandler InternalEventFilterApplier.MatchedEventHandler

cancellationToken CancellationToken

Returns

Task<bool>

Expect(int, Action, CancellationToken)

TBD

public void Expect(int expectedCount, Action action, CancellationToken cancellationToken = default)

Parameters

expectedCount int

TBD

action Action

TBD

cancellationToken CancellationToken

Expect(int, TimeSpan, Action, CancellationToken)

TBD

public void Expect(int expectedCount, TimeSpan timeout, Action action, CancellationToken cancellationToken = default)

Parameters

expectedCount int

TBD

timeout TimeSpan

TBD

action Action

TBD

cancellationToken CancellationToken

ExpectAsync(int, Func<Task>, TimeSpan?, CancellationToken)

Async version of Expect

public Task ExpectAsync(int expectedCount, Func<Task> actionAsync, TimeSpan? timeout, CancellationToken cancellationToken = default)

Parameters

expectedCount int

actionAsync Func<Task>

timeout TimeSpan?

cancellationToken CancellationToken

Returns

Task

ExpectAsync(int, Func<Task>, CancellationToken)

Async version of Expect

public Task ExpectAsync(int expectedCount, Func<Task> actionAsync, CancellationToken cancellationToken = default)

Parameters

expectedCount int

actionAsync Func<Task>

cancellationToken CancellationToken

Returns

Task

ExpectAsync(int, TimeSpan, Action, CancellationToken)

public Task ExpectAsync(int expectedCount, TimeSpan timeout, Action action, CancellationToken cancellationToken = default)

Parameters

expectedCount int

timeout TimeSpan

action Action

cancellationToken CancellationToken

Returns

Task

ExpectAsync(int, TimeSpan, Func<Task>, CancellationToken)

Async version of Expect(int, TimeSpan, Action, CancellationToken)

public Task ExpectAsync(int expectedCount, TimeSpan timeout, Func<Task> action, CancellationToken cancellationToken = default)

Parameters

expectedCount int

timeout TimeSpan

action Func<Task>

cancellationToken CancellationToken

Returns

Task

ExpectAsync<T>(int, Func<Task<T>>, CancellationToken)

Async version of Expect

public Task<T> ExpectAsync<T>(int expectedCount, Func<Task<T>> func, CancellationToken cancellationToken = default)

Parameters

expectedCount int

func Func<Task<T>>

cancellationToken CancellationToken

Returns

Task<T>

Type Parameters

T

ExpectAsync<T>(int, TimeSpan, Func<Task<T>>, CancellationToken)

Async version of Expect Note: func might not get awaited.

public Task<T> ExpectAsync<T>(int expectedCount, TimeSpan timeout, Func<Task<T>> func, CancellationToken cancellationToken = default)

Parameters

expectedCount int

timeout TimeSpan

func Func<Task<T>>

cancellationToken CancellationToken

Returns

Task<T>

Type Parameters

T

ExpectOne(Action, CancellationToken)

TBD

public void ExpectOne(Action action, CancellationToken cancellationToken = default)

Parameters

action Action

TBD

cancellationToken CancellationToken

ExpectOne(TimeSpan, Action, CancellationToken)

TBD

public void ExpectOne(TimeSpan timeout, Action action, CancellationToken cancellationToken = default)

Parameters

timeout TimeSpan

TBD

action Action

TBD

cancellationToken CancellationToken

ExpectOneAsync(Action, CancellationToken)

Async version of ExpectOne(Action, CancellationToken)

[Obsolete("Only for backwards compat. Use ExpectOneAsync(Func<Task>, CancellationToken) instead beginning in Akka.NET v1.5")]
public Task ExpectOneAsync(Action action, CancellationToken cancellationToken = default)

Parameters

action Action

cancellationToken CancellationToken

Returns

Task

Remarks

This is for backwards compat.

ExpectOneAsync(Func<Task>, CancellationToken)

Async version of ExpectOne(Action, CancellationToken)

public Task ExpectOneAsync(Func<Task> action, CancellationToken cancellationToken = default)

Parameters

action Func<Task>

cancellationToken CancellationToken

Returns

Task

ExpectOneAsync(TimeSpan, Func<Task>, CancellationToken)

Async version of ExpectOne(TimeSpan, Action, CancellationToken)

public Task ExpectOneAsync(TimeSpan timeout, Func<Task> action, CancellationToken cancellationToken = default)

Parameters

timeout TimeSpan

action Func<Task>

cancellationToken CancellationToken

Returns

Task

ExpectOneAsync<T>(Func<Task<T>>, CancellationToken)

Async version of ExpectOne

public Task<T> ExpectOneAsync<T>(Func<Task<T>> func, CancellationToken cancellationToken = default)

Parameters

func Func<Task<T>>

cancellationToken CancellationToken

Returns

Task<T>

Type Parameters

T

ExpectOneAsync<T>(TimeSpan, Func<Task<T>>, CancellationToken)

Async version of ExpectOne

public Task<T> ExpectOneAsync<T>(TimeSpan timeout, Func<Task<T>> func, CancellationToken cancellationToken = default)

Parameters

timeout TimeSpan

func Func<Task<T>>

cancellationToken CancellationToken

Returns

Task<T>

Type Parameters

T

ExpectOne<T>(Func<T>, CancellationToken)

TBD

public T ExpectOne<T>(Func<T> func, CancellationToken cancellationToken = default)

Parameters

func Func<T>

TBD

cancellationToken CancellationToken

Returns

T

TBD

Type Parameters

T

TBD

ExpectOne<T>(TimeSpan, Func<T>, CancellationToken)

TBD

public T ExpectOne<T>(TimeSpan timeout, Func<T> func, CancellationToken cancellationToken = default)

Parameters

timeout TimeSpan

TBD

func Func<T>

TBD

cancellationToken CancellationToken

Returns

T

TBD

Type Parameters

T

TBD

Expect<T>(int, Func<T>, CancellationToken)

TBD

public T Expect<T>(int expectedCount, Func<T> func, CancellationToken cancellationToken = default)

Parameters

expectedCount int

TBD

func Func<T>

TBD

cancellationToken CancellationToken

Returns

T

TBD

Type Parameters

T

TBD

Expect<T>(int, TimeSpan, Func<T>, CancellationToken)

TBD

public T Expect<T>(int expectedCount, TimeSpan timeout, Func<T> func, CancellationToken cancellationToken = default)

Parameters

expectedCount int

TBD

timeout TimeSpan

TBD

func Func<T>

TBD

cancellationToken CancellationToken

Returns

T

TBD

Type Parameters

T

TBD

GetMessageString(int)

TBD

protected static string GetMessageString(int number)

Parameters

number int

TBD

Returns

string

TBD

InterceptAsync<T>(Func<Task<T>>, ActorSystem, TimeSpan?, int?, MatchedEventHandler, CancellationToken)

Async version of Intercept<T>(Func<T>, ActorSystem, TimeSpan?, int?, MatchedEventHandler, CancellationToken)

protected Task<T> InterceptAsync<T>(Func<Task<T>> func, ActorSystem system, TimeSpan? timeout, int? expectedOccurrences, InternalEventFilterApplier.MatchedEventHandler matchedEventHandler = null, CancellationToken cancellationToken = default)

Parameters

func Func<Task<T>>

system ActorSystem

timeout TimeSpan?

expectedOccurrences int?

matchedEventHandler InternalEventFilterApplier.MatchedEventHandler

cancellationToken CancellationToken

Returns

Task<T>

Type Parameters

T

Intercept<T>(Func<T>, ActorSystem, TimeSpan?, int?, MatchedEventHandler, CancellationToken)

TBD

protected T Intercept<T>(Func<T> func, ActorSystem system, TimeSpan? timeout, int? expectedOccurrences, InternalEventFilterApplier.MatchedEventHandler matchedEventHandler = null, CancellationToken cancellationToken = default)

Parameters

func Func<T>

TBD

system ActorSystem

TBD

timeout TimeSpan?

TBD

expectedOccurrences int?

TBD

matchedEventHandler InternalEventFilterApplier.MatchedEventHandler

TBD

cancellationToken CancellationToken

Returns

T

TBD

Type Parameters

T

TBD

Mute()

TBD

public IUnmutableFilter Mute()

Returns

IUnmutableFilter

TBD

Mute(Action, CancellationToken)

TBD

public void Mute(Action action, CancellationToken cancellationToken = default)

Parameters

action Action

TBD

cancellationToken CancellationToken

MuteAsync(Action, CancellationToken)

public Task MuteAsync(Action action, CancellationToken cancellationToken = default)

Parameters

action Action

cancellationToken CancellationToken

Returns

Task

MuteAsync(Func<Task>, CancellationToken)

Async version of Mute

public Task MuteAsync(Func<Task> action, CancellationToken cancellationToken = default)

Parameters

action Func<Task>

cancellationToken CancellationToken

Returns

Task

MuteAsync<T>(Func<Task<T>>, CancellationToken)

Async version of Mute

public Task<T> MuteAsync<T>(Func<Task<T>> func, CancellationToken cancellationToken = default)

Parameters

func Func<Task<T>>

cancellationToken CancellationToken

Returns

Task<T>

Type Parameters

T

Mute<T>(Func<T>, CancellationToken)

TBD

public T Mute<T>(Func<T> func, CancellationToken cancellationToken = default)

Parameters

func Func<T>

TBD

cancellationToken CancellationToken

Returns

T

TBD

Type Parameters

T

TBD