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<>