Attach(Func<T, CancellationToken, Task>, Func<Exception, CancellationToken, Task>)
virtual
public virtual Task Attach<T>(Func<T, CancellationToken, Task> onPublished, Func<Exception, CancellationToken, Task>? onError = null) Attaches cancellation-aware callbacks to the channel subscription.
Parameters
onPublishedFunc<T, CancellationToken, Task>- The callback invoked when an element is published.
onErrorFunc<Exception, CancellationToken, Task>- The callback invoked when delivery fails.
Returns
A
System.Threading.Tasks.Task representing the operation.