Interface IAsyncReactiveQbservable<T>

Interface for an observable represented by an expression tree.

Inherited Members

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

IAsyncReactiveQbservable.ElementType

IAsyncReactiveExpressible.Provider

IExpressible.Expression

Namespace: Reaqtor

Assembly: Reaqtor.Expressions.Model.dll

Syntax

public interface IAsyncReactiveQbservable<out T> : IAsyncReactiveObservable<T>, IAsyncReactiveQbservable, IAsyncReactiveExpressible, IExpressible

Type Parameters

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

Methods

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

Subscribes to the observable using the given observer.

Declaration

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

Parameters

Type	Name	Description
IAsyncReactiveQbserver<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<IAsyncReactiveQubscription>	Task returning a subscription object that can be used to cancel the subscription, or an exception if the subscription was unsuccessful.