Skip to content
Orleans logoMicrosoft Orleans

IBroadcastChannelSubscription Methods

Represents a grain's implicit subscription to a broadcast channel.

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

abstract
View source
public abstract Task Attach<T>(Func<T, Task> onPublished, Func<Exception, Task>? onError = null)
Attaches handlers which receive items and delivery errors for this subscription.

Parameters

onPublishedFunc<T, Task>
The handler invoked for each published item.
onErrorFunc<Exception, Task>
The optional handler invoked when item delivery fails.

Returns

A task which completes when the handlers have been attached.

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.