Class InternalEventFilterApplier
Implements
Inherited Members
Namespace: Akka.TestKit.Internal
Assembly: Akka.TestKit.dll
Syntax
public class InternalEventFilterApplier : IEventFilterApplier
Constructors
| Improve this Doc View SourceInternalEventFilterApplier(TestKitBase, ActorSystem, IReadOnlyList<EventFilterBase>)
TBD
Declaration
public InternalEventFilterApplier(TestKitBase testkit, ActorSystem system, IReadOnlyList<EventFilterBase> filters)
Parameters
Type | Name | Description |
---|---|---|
TestKitBase | testkit | TBD |
ActorSystem | system | TBD |
IReadOnlyList<EventFilterBase> | filters | TBD |
Properties
| Improve this Doc View SourceAnd
TBD
Declaration
public EventFilterFactory And { get; }
Property Value
Type | Description |
---|---|
EventFilterFactory |
Methods
| Improve this Doc View SourceAwaitDone(TimeSpan, Nullable<Int32>, InternalEventFilterApplier.MatchedEventHandler, CancellationToken)
TBD
Declaration
protected bool AwaitDone(TimeSpan timeout, int? expectedOccurrences, InternalEventFilterApplier.MatchedEventHandler matchedEventHandler, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type | Name | Description |
---|---|---|
TimeSpan | timeout | TBD |
Nullable<Int32> | expectedOccurrences | TBD |
InternalEventFilterApplier.MatchedEventHandler | matchedEventHandler | TBD |
CancellationToken | cancellationToken |
Returns
Type | Description |
---|---|
Boolean | TBD |
AwaitDoneAsync(TimeSpan, Nullable<Int32>, InternalEventFilterApplier.MatchedEventHandler, CancellationToken)
Async version of AwaitDone(TimeSpan, Nullable<Int32>, InternalEventFilterApplier.MatchedEventHandler, CancellationToken)
Declaration
protected async Task<bool> AwaitDoneAsync(TimeSpan timeout, int? expectedOccurrences, InternalEventFilterApplier.MatchedEventHandler matchedEventHandler, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type | Name | Description |
---|---|---|
TimeSpan | timeout | |
Nullable<Int32> | expectedOccurrences | |
InternalEventFilterApplier.MatchedEventHandler | matchedEventHandler | |
CancellationToken | cancellationToken |
Returns
Type | Description |
---|---|
Task<Boolean> |
Expect(Int32, Action, CancellationToken)
TBD
Declaration
public void Expect(int expectedCount, Action action, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type | Name | Description |
---|---|---|
Int32 | expectedCount | TBD |
Action | action | TBD |
CancellationToken | cancellationToken |
Expect(Int32, TimeSpan, Action, CancellationToken)
TBD
Declaration
public void Expect(int expectedCount, TimeSpan timeout, Action action, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type | Name | Description |
---|---|---|
Int32 | expectedCount | TBD |
TimeSpan | timeout | TBD |
Action | action | TBD |
CancellationToken | cancellationToken |
Expect<T>(Int32, Func<T>, CancellationToken)
TBD
Declaration
public T Expect<T>(int expectedCount, Func<T> func, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type | Name | Description |
---|---|---|
Int32 | expectedCount | TBD |
Func<T> | func | TBD |
CancellationToken | cancellationToken |
Returns
Type | Description |
---|---|
T | TBD |
Type Parameters
Name | Description |
---|---|
T | TBD |
Expect<T>(Int32, TimeSpan, Func<T>, CancellationToken)
TBD
Declaration
public T Expect<T>(int expectedCount, TimeSpan timeout, Func<T> func, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type | Name | Description |
---|---|---|
Int32 | expectedCount | TBD |
TimeSpan | timeout | TBD |
Func<T> | func | TBD |
CancellationToken | cancellationToken |
Returns
Type | Description |
---|---|
T | TBD |
Type Parameters
Name | Description |
---|---|
T | TBD |
ExpectAsync(Int32, Func<Task>, Nullable<TimeSpan>, CancellationToken)
Async version of Expect
Declaration
public async Task ExpectAsync(int expectedCount, Func<Task> actionAsync, TimeSpan? timeout, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type | Name | Description |
---|---|---|
Int32 | expectedCount | |
Func<Task> | actionAsync | |
Nullable<TimeSpan> | timeout | |
CancellationToken | cancellationToken |
Returns
Type | Description |
---|---|
Task |
ExpectAsync(Int32, Func<Task>, CancellationToken)
Async version of Expect
Declaration
public async Task ExpectAsync(int expectedCount, Func<Task> actionAsync, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type | Name | Description |
---|---|---|
Int32 | expectedCount | |
Func<Task> | actionAsync | |
CancellationToken | cancellationToken |
Returns
Type | Description |
---|---|
Task |
ExpectAsync(Int32, TimeSpan, Action, CancellationToken)
Declaration
public async Task ExpectAsync(int expectedCount, TimeSpan timeout, Action action, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type | Name | Description |
---|---|---|
Int32 | expectedCount | |
TimeSpan | timeout | |
Action | action | |
CancellationToken | cancellationToken |
Returns
Type | Description |
---|---|
Task |
ExpectAsync(Int32, TimeSpan, Func<Task>, CancellationToken)
Async version of Expect(Int32, TimeSpan, Action, CancellationToken)
Declaration
public async Task ExpectAsync(int expectedCount, TimeSpan timeout, Func<Task> action, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type | Name | Description |
---|---|---|
Int32 | expectedCount | |
TimeSpan | timeout | |
Func<Task> | action | |
CancellationToken | cancellationToken |
Returns
Type | Description |
---|---|
Task |
ExpectAsync<T>(Int32, Func<Task<T>>, CancellationToken)
Async version of Expect
Declaration
public Task<T> ExpectAsync<T>(int expectedCount, Func<Task<T>> func, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type | Name | Description |
---|---|---|
Int32 | expectedCount | |
Func<Task<T>> | func | |
CancellationToken | cancellationToken |
Returns
Type | Description |
---|---|
Task<T> |
Type Parameters
Name | Description |
---|---|
T |
ExpectAsync<T>(Int32, TimeSpan, Func<Task<T>>, CancellationToken)
Async version of Expect
Note: func
might not get awaited.
Declaration
public Task<T> ExpectAsync<T>(int expectedCount, TimeSpan timeout, Func<Task<T>> func, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type | Name | Description |
---|---|---|
Int32 | expectedCount | |
TimeSpan | timeout | |
Func<Task<T>> | func | |
CancellationToken | cancellationToken |
Returns
Type | Description |
---|---|
Task<T> |
Type Parameters
Name | Description |
---|---|
T |
ExpectOne(Action, CancellationToken)
TBD
Declaration
public void ExpectOne(Action action, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type | Name | Description |
---|---|---|
Action | action | TBD |
CancellationToken | cancellationToken |
ExpectOne(TimeSpan, Action, CancellationToken)
TBD
Declaration
public void ExpectOne(TimeSpan timeout, Action action, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type | Name | Description |
---|---|---|
TimeSpan | timeout | TBD |
Action | action | TBD |
CancellationToken | cancellationToken |
ExpectOne<T>(Func<T>, CancellationToken)
TBD
Declaration
public T ExpectOne<T>(Func<T> func, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type | Name | Description |
---|---|---|
Func<T> | func | TBD |
CancellationToken | cancellationToken |
Returns
Type | Description |
---|---|
T | TBD |
Type Parameters
Name | Description |
---|---|
T | TBD |
ExpectOne<T>(TimeSpan, Func<T>, CancellationToken)
TBD
Declaration
public T ExpectOne<T>(TimeSpan timeout, Func<T> func, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type | Name | Description |
---|---|---|
TimeSpan | timeout | TBD |
Func<T> | func | TBD |
CancellationToken | cancellationToken |
Returns
Type | Description |
---|---|
T | TBD |
Type Parameters
Name | Description |
---|---|
T | TBD |
ExpectOneAsync(Action, CancellationToken)
Async version of ExpectOne(Action, CancellationToken)
Declaration
[Obsolete("Only for backwards compat. Use ExpectOneAsync(Func<Task>, CancellationToken) instead beginning in Akka.NET v1.5")]
public async Task ExpectOneAsync(Action action, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type | Name | Description |
---|---|---|
Action | action | |
CancellationToken | cancellationToken |
Returns
Type | Description |
---|---|
Task |
Remarks
This is for backwards compat.
ExpectOneAsync(Func<Task>, CancellationToken)
Async version of ExpectOne(Action, CancellationToken)
Declaration
public async Task ExpectOneAsync(Func<Task> action, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type | Name | Description |
---|---|---|
Func<Task> | action | |
CancellationToken | cancellationToken |
Returns
Type | Description |
---|---|
Task |
ExpectOneAsync(TimeSpan, Func<Task>, CancellationToken)
Async version of ExpectOne(TimeSpan, Action, CancellationToken)
Declaration
public async Task ExpectOneAsync(TimeSpan timeout, Func<Task> action, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type | Name | Description |
---|---|---|
TimeSpan | timeout | |
Func<Task> | action | |
CancellationToken | cancellationToken |
Returns
Type | Description |
---|---|
Task |
ExpectOneAsync<T>(Func<Task<T>>, CancellationToken)
Async version of ExpectOne
Declaration
public Task<T> ExpectOneAsync<T>(Func<Task<T>> func, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type | Name | Description |
---|---|---|
Func<Task<T>> | func | |
CancellationToken | cancellationToken |
Returns
Type | Description |
---|---|
Task<T> |
Type Parameters
Name | Description |
---|---|
T |
ExpectOneAsync<T>(TimeSpan, Func<Task<T>>, CancellationToken)
Async version of ExpectOne
Declaration
public Task<T> ExpectOneAsync<T>(TimeSpan timeout, Func<Task<T>> func, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type | Name | Description |
---|---|---|
TimeSpan | timeout | |
Func<Task<T>> | func | |
CancellationToken | cancellationToken |
Returns
Type | Description |
---|---|
Task<T> |
Type Parameters
Name | Description |
---|---|
T |
GetMessageString(Int32)
TBD
Declaration
protected static string GetMessageString(int number)
Parameters
Type | Name | Description |
---|---|---|
Int32 | number | TBD |
Returns
Type | Description |
---|---|
String | TBD |
Intercept<T>(Func<T>, ActorSystem, Nullable<TimeSpan>, Nullable<Int32>, InternalEventFilterApplier.MatchedEventHandler, CancellationToken)
TBD
Declaration
protected T Intercept<T>(Func<T> func, ActorSystem system, TimeSpan? timeout, int? expectedOccurrences, InternalEventFilterApplier.MatchedEventHandler matchedEventHandler = null, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type | Name | Description |
---|---|---|
Func<T> | func | TBD |
ActorSystem | system | TBD |
Nullable<TimeSpan> | timeout | TBD |
Nullable<Int32> | expectedOccurrences | TBD |
InternalEventFilterApplier.MatchedEventHandler | matchedEventHandler | TBD |
CancellationToken | cancellationToken |
Returns
Type | Description |
---|---|
T | TBD |
Type Parameters
Name | Description |
---|---|
T | TBD |
InterceptAsync<T>(Func<Task<T>>, ActorSystem, Nullable<TimeSpan>, Nullable<Int32>, InternalEventFilterApplier.MatchedEventHandler, CancellationToken)
Async version of Intercept<T>(Func<T>, ActorSystem, Nullable<TimeSpan>, Nullable<Int32>, InternalEventFilterApplier.MatchedEventHandler, CancellationToken)
Declaration
protected async Task<T> InterceptAsync<T>(Func<Task<T>> func, ActorSystem system, TimeSpan? timeout, int? expectedOccurrences, InternalEventFilterApplier.MatchedEventHandler matchedEventHandler = null, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type | Name | Description |
---|---|---|
Func<Task<T>> | func | |
ActorSystem | system | |
Nullable<TimeSpan> | timeout | |
Nullable<Int32> | expectedOccurrences | |
InternalEventFilterApplier.MatchedEventHandler | matchedEventHandler | |
CancellationToken | cancellationToken |
Returns
Type | Description |
---|---|
Task<T> |
Type Parameters
Name | Description |
---|---|
T |
Mute()
TBD
Declaration
public IUnmutableFilter Mute()
Returns
Type | Description |
---|---|
IUnmutableFilter | TBD |
Mute(Action, CancellationToken)
TBD
Declaration
public void Mute(Action action, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type | Name | Description |
---|---|---|
Action | action | TBD |
CancellationToken | cancellationToken |
Mute<T>(Func<T>, CancellationToken)
TBD
Declaration
public T Mute<T>(Func<T> func, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type | Name | Description |
---|---|---|
Func<T> | func | TBD |
CancellationToken | cancellationToken |
Returns
Type | Description |
---|---|
T | TBD |
Type Parameters
Name | Description |
---|---|
T | TBD |
MuteAsync(Action, CancellationToken)
Declaration
public async Task MuteAsync(Action action, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type | Name | Description |
---|---|---|
Action | action | |
CancellationToken | cancellationToken |
Returns
Type | Description |
---|---|
Task |
MuteAsync(Func<Task>, CancellationToken)
Async version of Mute
Declaration
public async Task MuteAsync(Func<Task> action, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type | Name | Description |
---|---|---|
Func<Task> | action | |
CancellationToken | cancellationToken |
Returns
Type | Description |
---|---|
Task |
MuteAsync<T>(Func<Task<T>>, CancellationToken)
Async version of Mute
Declaration
public Task<T> MuteAsync<T>(Func<Task<T>> func, CancellationToken cancellationToken = default(CancellationToken))
Parameters
Type | Name | Description |
---|---|---|
Func<Task<T>> | func | |
CancellationToken | cancellationToken |
Returns
Type | Description |
---|---|
Task<T> |
Type Parameters
Name | Description |
---|---|
T |