Show / Hide Table of Contents

Class MultiSubjectProxy<TInput, TOutput>

A proxy for subjects.

Inheritance
System.Object
MultiSubjectProxy<TInput, TOutput>
GroupedMultiSubjectProxy<TKey, TSource>
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

IMultiSubject<TInput, TOutput>
ISubscribable<T>
System.IObservable<>
System.IDisposable
In This Article
Back to top Generated by DocFX