Class ReliableObservableExtensions

Utility and extension methods for reliable observables.

Inheritance

System.Object

ReliableObservableExtensions

Namespace: Reaqtor.QueryEngine

Assembly: Reaqtor.QueryEngine.dll

Syntax

public static class ReliableObservableExtensions : Object

Methods

ToSubscribable<T>(IReliableObservable<T>)

Converts a reliable observable sequence to a subscribable sequence which checkpoints the received elements using their sequence numbers.

Declaration

public static ISubscribable<T> ToSubscribable<T>(this IReliableObservable<T> source)

Parameters

Type	Name	Description
IReliableObservable<T>	source	Reliable observable sequence to convert to a subscribable sequence.

Returns

Type	Description
ISubscribable<T>	Subscribable sequence wrapping the specified reliable observable.

Type Parameters

Name	Description
T	Type of the elements received by the source sequence.

ToSubscribable<T>(IReliableObservable<T>, Boolean)

Converts a reliable observable sequence to a subscribable sequence which checkpoints the received elements using their sequence numbers, optionally specifying context switching behavior.

Declaration

public static ISubscribable<T> ToSubscribable<T>(this IReliableObservable<T> source, bool switchContext)

Parameters

Type	Name	Description
IReliableObservable<T>	source	Reliable observable sequence to convert to a subscribable sequence.
System.Boolean	switchContext	If set to true, received elements will be produced on the logical scheduler provided to subscription on the resulting subscribable sequence via the SetContext call. Otherwise, elements are produced in a free-threaded manner.

Returns

Type	Description
ISubscribable<T>	Subscribable sequence wrapping the specified reliable observable.

Type Parameters

Name	Description
T	Type of the elements received by the source sequence.