Skip to content

IBroadcastChannelSubscription.Attach(Func<T, CancellationToken, Task>, Func<Exception, CancellationToken, Task>)

Attach(Func<T, CancellationToken, Task>, Func<Exception, CancellationToken, Task>)

virtual
View source
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.