Class ObservableExtensions

Namespace

CarinaStudio

Assembly

CarinaStudio.AppBase.Core.dll

Extensions for IObservable<T>.

public static class ObservableExtensions

Inheritance

object

ObservableExtensions

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Methods

Cast<TIn, TOut>(IObservable<TIn>)

Cast given IObservable<T> to another type of IObservable<T>.

public static IObservable<TOut> Cast<TIn, TOut>(this IObservable<TIn> observable)

Parameters

observable IObservable<TIn>

IObservable<T>.

Returns

IObservable<TOut>

IObservable<T>.

Type Parameters

TIn

Type of value of source IObservable<T>.

TOut

Type of value of target IObservable<T>.

Invert(IObservable<bool>)

Create IObservable<T> which inverts the source IObservable<T>.

public static IObservable<bool> Invert(this IObservable<bool> observable)

Parameters

observable IObservable<bool>

Source IObservable<T>.

Returns

IObservable<bool>

IObservable<T> with inverted value.

Subscribe<T>(IObservable<T>, Action, bool)

Subscribe given action to observe value change.

public static IDisposable Subscribe<T>(this IObservable<T> observable, Action onNext, bool skipOnNextDuringSubscription = false)

Parameters

observable IObservable<T>

IObservable<T>.

onNext Action

Action to observe value change.

skipOnNextDuringSubscription bool

True to skip call of onNext during subscription.

Returns

IDisposable

Token of subscribed observer.

Type Parameters

T

Type of value of IObservable<T>.

Subscribe<T>(IObservable<T>, Action<T>, bool)

Subscribe given action to observe value change.

public static IDisposable Subscribe<T>(this IObservable<T> observable, Action<T> onNext, bool skipOnNextDuringSubscription = false)

Parameters

observable IObservable<T>

IObservable<T>.

onNext Action<T>

Action to observe value change.

skipOnNextDuringSubscription bool

True to skip call of onNext during subscription.

Returns

IDisposable

Token of subscribed observer.

Type Parameters

T

Type of value of IObservable<T>.

Subscribe<T, R>(IObservable<T>, Func<T, R>, bool)

Subscribe given function to observe value change.

public static IDisposable Subscribe<T, R>(this IObservable<T> observable, Func<T, R> onNext, bool skipOnNextDuringSubscription = false)

Parameters

observable IObservable<T>

IObservable<T>.

onNext Func<T, R>

Function to observe value change.

skipOnNextDuringSubscription bool

True to skip call of onNext during subscription.

Returns

IDisposable

Token of subscribed observer.

Type Parameters

T

Type of value of IObservable<T>.

R

Type returned value of onNext.

Subscribe<T, R>(IObservable<T>, Func<R>, bool)

Subscribe given function to observe value change.

public static IDisposable Subscribe<T, R>(this IObservable<T> observable, Func<R> onNext, bool skipOnNextDuringSubscription = false)

Parameters

observable IObservable<T>

IObservable<T>.

onNext Func<R>

Function to observe value change.

skipOnNextDuringSubscription bool

True to skip call of onNext during subscription.

Returns

IDisposable

Token of subscribed observer.

Type Parameters

T

Type of value of IObservable<T>.

R

Type returned value of onNext.

WeakSubscribe<T>(IObservable<T>, IObserver<T>)

Subscribe a weak reference to given observer to observe value change.

public static IDisposable WeakSubscribe<T>(this IObservable<T> observable, IObserver<T> observer)

Parameters

observable IObservable<T>

IObservable<T>.

observer IObserver<T>

Observer.

Returns

IDisposable

Token of subscribed observer.

Type Parameters

T

Type of value of IObservable<T>.