(Action<TEventArgs> handler, CancellationToken cancellationToken = default)
| 31 | } |
| 32 | |
| 33 | public Task<ISubscription> SubscribeAsync(Action<TEventArgs> handler, CancellationToken cancellationToken = default) |
| 34 | { |
| 35 | ArgumentNullException.ThrowIfNull(handler); |
| 36 | |
| 37 | return _dispatcher.SubscribeAsync(_descriptor, e => { handler(e); return default; }, filter: null, cancellationToken: cancellationToken); |
| 38 | } |
| 39 | |
| 40 | public Task<ISubscription> SubscribeAsync(Func<TEventArgs, Task> handler, CancellationToken cancellationToken = default) |
| 41 | { |
nothing calls this directly
no test coverage detected