Class ReactiveObservableBase<T>
Base class for observables.
Implements
Namespace: Reaqtor
Assembly: Reaqtor.Local.Core.dll
Syntax
public abstract class ReactiveObservableBase<T> : Object, IReactiveObservable<T>Type Parameters
| Name | Description |
|---|---|
| T | Type of the data produced by the observable. |
Constructors
ReactiveObservableBase()
Declaration
protected ReactiveObservableBase()Methods
Subscribe(IReactiveObserver<T>, Uri, Object)
Subscribes to the observable using the given observer.
Declaration
public IReactiveSubscription Subscribe(IReactiveObserver<T> observer, Uri subscriptionUri, object state = null)Parameters
| Type | Name | Description |
|---|---|---|
| IReactiveObserver<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. |
Returns
| Type | Description |
|---|---|
| IReactiveSubscription | Subscription object that can be used to cancel the subscription, or an exception if the submission was unsuccessful. |
SubscribeCore(IReactiveObserver<T>, Uri, Object)
Subscribes to the observable using the given observer.
Declaration
protected abstract IReactiveSubscription SubscribeCore(IReactiveObserver<T> observer, Uri subscriptionUri, object state)Parameters
| Type | Name | Description |
|---|---|---|
| IReactiveObserver<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. |
Returns
| Type | Description |
|---|---|
| IReactiveSubscription | Subscription object that can be used to cancel the subscription, or an exception if the submission was unsuccessful. |