Class SubscribableBase<TResult>
Base class for subscribable sources.
Inheritance
System.Object
SubscribableBase<TResult>
Namespace: Reaqtive
Assembly: Reaqtive.Core.dll
Syntax
public abstract class SubscribableBase<TResult> : Object, ISubscribable<TResult>, IObservable<TResult>
Type Parameters
| Name | Description |
|---|---|
| TResult | Type of the elements produced by the subscribable source. |
Constructors
SubscribableBase()
Declaration
protected SubscribableBase()
Methods
Subscribe(IObserver<TResult>)
Subscribes the specified observer to the subscribable source.
Declaration
public ISubscription Subscribe(IObserver<TResult> observer)
Parameters
| Type | Name | Description |
|---|---|---|
| System.IObserver<TResult> | observer | Observer that will receive the elements of the source. |
Returns
| Type | Description |
|---|---|
| ISubscription | Handle to the newly created subscription. |
SubscribeCore(IObserver<TResult>)
Subscribes the specified observer to the subscribable source.
Declaration
protected abstract ISubscription SubscribeCore(IObserver<TResult> observer)
Parameters
| Type | Name | Description |
|---|---|---|
| System.IObserver<TResult> | observer | Observer that will receive the elements of the source. |
Returns
| Type | Description |
|---|---|
| ISubscription | Handle to the newly created subscription. |
Implements
System.IObservable<>