Show / Hide Table of Contents

Class ReificationOperators

Builtin operators for the reification framework.

Inheritance
System.Object
ReificationOperators
Namespace: Reaqtor.ReificationFramework
Assembly: Reaqtor.ReificationFramework.dll
Syntax
public static class ReificationOperators : Object

Methods

GetParameterizedSourceObservable<TParam, TResult>(IReactiveProxy)

Get the parameterized source observable.

Declaration
[KnownResource("rx://reification/source/param")]
public static Func<TParam, IAsyncReactiveQbservable<TResult>> GetParameterizedSourceObservable<TParam, TResult>(this IReactiveProxy context)
Parameters
Type Name Description
IReactiveProxy context

The client context.

Returns
Type Description
System.Func<TParam, IAsyncReactiveQbservable<TResult>>

The parameterized source observable.

Type Parameters
Name Description
TParam

The parameter type.

TResult

The element type of the source observable.

Remarks

This is a "wildcard" source, meaning it is intended for use with any observable.

GetSinkObserver<T>(IReactiveProxy)

Get the sink observer.

Declaration
[KnownResource("rx://reification/sink")]
public static IAsyncReactiveQbserver<T> GetSinkObserver<T>(this IReactiveProxy context)
Parameters
Type Name Description
IReactiveProxy context

The client context.

Returns
Type Description
IAsyncReactiveQbserver<T>

The sink observer.

Type Parameters
Name Description
T

The element type of the sink observer.

Remarks

This is a "wildcard" sink, meaning it is intended for use with any observer.

GetSourceObservable<T>(IReactiveProxy)

Get the source observable.

Declaration
[KnownResource("rx://reification/source")]
public static IAsyncReactiveQbservable<T> GetSourceObservable<T>(this IReactiveProxy context)
Parameters
Type Name Description
IReactiveProxy context

The client context.

Returns
Type Description
IAsyncReactiveQbservable<T>

The source observable.

Type Parameters
Name Description
T

The element type of the source observable.

Remarks

This is a "wildcard" source, meaning it is intended for use with any observable.

In This Article
Back to top Generated by DocFX