Class MultiSubjectProxy<TInput, TOutput>
A proxy for subjects.
Inheritance
System.Object
MultiSubjectProxy<TInput, TOutput>
Implements
IMultiSubject<TInput, TOutput>
ISubscribable<TOutput>
System.IObservable<TOutput>
System.IDisposable
Namespace: Reaqtor.Reactive
Assembly: Reaqtor.Reactive.HigherOrder.dll
Syntax
public class MultiSubjectProxy<TInput, TOutput> : Object, IMultiSubject<TInput, TOutput>, ISubscribable<TOutput>, IObservable<TOutput>, IDisposable
Type Parameters
Name | Description |
---|---|
TInput | The subject input type. |
TOutput | The subject output type. |
Constructors
MultiSubjectProxy(Uri)
Create the subject proxy.
Declaration
public MultiSubjectProxy(Uri uri)
Parameters
Type | Name | Description |
---|---|---|
System.Uri | uri | The subject URI. |
Methods
CreateObserver()
Creates a new observer that can be used to push elements into the subject.
Declaration
public IObserver<TInput> CreateObserver()
Returns
Type | Description |
---|---|
System.IObserver<TInput> | An observer that can be used to push elements into the subject. |
Dispose()
Dispose the subject proxy.
Declaration
public void Dispose()
Subscribe(IObserver<TOutput>)
Subscribes the specified observer to the subscribable source.
Declaration
public ISubscription Subscribe(IObserver<TOutput> observer)
Parameters
Type | Name | Description |
---|---|---|
System.IObserver<TOutput> | observer | Observer that will receive the elements of the source. |
Returns
Type | Description |
---|---|
ISubscription | Handle to the newly created subscription. |
Implements
System.IObservable<>
System.IDisposable