Method WaitForAsync

Namespace

Ratatoskr.Testing

Assembly

Ratatoskr.Testing.dll

WaitForAsync(Func<MessageActivity, bool>, TimeSpan, CancellationToken)

Waits for a message activity matching the given predicate. Atomically checks existing activities and subscribes for new ones to avoid TOCTOU races.

public Task<MessageActivity> WaitForAsync(Func<MessageActivity, bool> predicate, TimeSpan timeout, CancellationToken cancellationToken = default)

Parameters

predicate Func<MessageActivity, bool>

timeout TimeSpan

cancellationToken CancellationToken

Returns

Task<MessageActivity>