Class Merge

Namespace

Bonsai.Reactive

Assembly

Bonsai.Core.dll

Represents an operator that merges any number of observable sequences into a single observable sequence.

The Merge operator allows you to combine the output of multiple sequences of the same type into a single sequence. Merge subscribes to all source sequences in parallel and emits all the elements from each sequence downstream.

The resulting sequence will terminate successfully only when all source sequences have terminated successfully, or exceptionally as soon as any sequence produces an error.

Higher-order operator

Merge also works as a higher-order operator, so it can take as input a sequence of observable sequences. In this case, it will subscribe to all source sequences as soon as they are emitted by the outer sequence, and emit all elements from each sequence downstream.

The higher-order variant is useful to combine notifications from multiple event sources running in parallel, for example when waiting for the first event from multiple input conditionals, or when logging data from multiple sources to the same file.

[Combinator]
public class Merge

Inheritance

object

Merge

Inherited Members

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

Methods

Process<TSource>(IObservable<IEnumerable<TSource>>)

Merges all inner enumerable sequences into one observable sequence.

Process<TSource>(IObservable<IObservable<TSource>>)

Merges elements from all inner observable sequences into a single observable sequence.

Process<TSource>(IObservable<TSource>, IObservable<TSource>)

Merges elements from two observable sequences into a single observable sequence.

Process<TSource>(IObservable<TSource>, IObservable<TSource>, params IObservable<TSource>[])

Merges elements from the specified observable sequences into a single observable sequence.