Class ObservableCombinators

Namespace: Bonsai

Assembly: Bonsai.Core.dll

Provides a set of static methods to aid in writing queries over observable sequences.

public static class ObservableCombinators

Inheritance: object

ObservableCombinators

Inherited Members: object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

Methods

Gate<TSource>(IObservable<TSource>, TimeSpan): Allows a single element from an observable sequence to pass through every time the specified time interval elapses.

Gate<TSource>(IObservable<TSource>, TimeSpan, IScheduler): Allows a single element from an observable sequence to pass through every time the specified time interval elapses, using the specified scheduler to run gate timers.

Gate<TSource, TGateOpening>(IObservable<TSource>, IObservable<TGateOpening>): Allows a single element from an observable sequence to pass through every time a second sequence emits a notification.

Gate<TSource, TGateOpening>(IObservable<TSource>, IObservable<TGateOpening>, TimeSpan): Allows an element from an observable sequence to pass through if this element is produced after a gate opening event and before the specified due time elapses.

Gate<TSource, TGateOpening>(IObservable<TSource>, IObservable<TGateOpening>, TimeSpan, IScheduler): Allows an element from an observable sequence to pass through if this element is produced after a gate opening event and before the specified due time elapses, using the specified scheduler to run gate closing timers.

Gate<TSource, TGateOpening, TGateClosing>(IObservable<TSource>, IObservable<TGateOpening>, IObservable<TGateClosing>): Allows an element from an observable sequence to pass through if this element is produced between a gate opening and gate closing event.

MulticastReconnectable<TSource, TResult>(IObservable<TSource>, Func<ISubject<TSource, TResult>>): Returns a connectable observable sequence that upon connection causes the source to push results into a new fresh subject, which is created by invoking the specified subjectFactory.

PublishReconnectable<TSource>(IObservable<TSource>): Returns a connectable observable sequence that upon connection causes the source to push results into a new fresh Subject<T>.

Zip<TSource1, TSource2, TResult>(IObservable<TSource1>, IEnumerable<TSource2>, Func<TSource1, TSource2, TResult>): Merges an observable sequence and an enumerable sequence into one observable sequence by using the selector function.

Edit this page