Class AsyncReactiveObservableBase<T>

Base class for observables.

Inheritance

System.Object

AsyncReactiveObservableBase<T>

AsyncReactiveQbservableBase<T>

Implements

IAsyncReactiveObservable<T>

Namespace: Reaqtor

Assembly: Reaqtor.Local.Core.dll

Syntax

public abstract class AsyncReactiveObservableBase<T> : Object, IAsyncReactiveObservable<T>

Type Parameters

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

Constructors

AsyncReactiveObservableBase()

Declaration

protected AsyncReactiveObservableBase()

Methods

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

Subscribes to the observable using the given observer.

Declaration

public 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 submission was unsuccessful.

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

Subscribes to the observable using the given observer.

Declaration

protected abstract Task<IAsyncReactiveSubscription> SubscribeAsyncCore(IAsyncReactiveObserver<T> observer, Uri subscriptionUri, object state, CancellationToken token)

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 submission was unsuccessful.

Implements

IAsyncReactiveObservable<T>