Interface IAsyncReactiveObservable<T>

Interface for observables representing event streams.

Namespace: Reaqtor

Assembly: Reaqtor.Local.Model.dll

Syntax

public interface IAsyncReactiveObservable<out T>

Type Parameters

Name	Description
T	Type of the data produced by the observable.

Methods

SubscribeAsync(IAsyncReactiveObserver<T>, Uri, Object, CancellationToken)

Subscribes to the observable using the given observer.

Declaration

Task<IAsyncReactiveSubscription> SubscribeAsync(IAsyncReactiveObserver<T> observer, Uri subscriptionUri, object state = null, CancellationToken token = null)

Parameters

Type	Name	Description
IAsyncReactiveObserver<T>	observer	Observer to send the observable's data to.
System.Uri	subscriptionUri	URI to identify the subscription.
System.Object	state	Additional metadata to associate with the artifact. Implementations can interpret this value, or ignore it.
System.Threading.CancellationToken	token	Token to observe for cancellation of the request.

Returns

Type	Description
System.Threading.Tasks.Task<IAsyncReactiveSubscription>	Task returning a subscription object that can be used to cancel the subscription, or an exception if the subscription was unsuccessful.