,System.Func{--1},System.Func{--1,--0,--1})} ,System.Func{--1},System.Func{--1,--0,--1},System.Func{--1,--1})}

Observable.Collect(IObservable, Func, Func) method¶

Defined in

Type: Observable Namespace: System.Reactive.Linq Assembly: System.Reactive.dll

Applies to

netstandard2.0

Overloads¶

1. public static IEnumerable<TResult> Collect<TSource, TResult>(this IObservable<TSource> source, Func<TResult> newCollector, Func<TResult, TSource, TResult> merge)
2. public static IEnumerable<TResult> Collect<TSource, TResult>(this IObservable<TSource> source, Func<TResult> getInitialCollector, Func<TResult, TSource, TResult> merge, Func<TResult, TResult> getNewCollector)

1. Overload¶

public static IEnumerable<TResult> Collect<TSource, TResult>(this IObservable<TSource> source, Func<TResult> newCollector, Func<TResult, TSource, TResult> merge)

Summary: Produces an enumerable sequence that returns elements collected/aggregated from the source sequence between consecutive iterations.

Type parameters

Name	Description
`TSource`	The type of the elements in the source sequence.
`TResult`	The type of the elements produced by the merge operation during collection.

Parameters

Name	Type	Description
`source`	IObservable	Source observable sequence.
`newCollector`	Func	Factory to create a new collector object.
`merge`	Func	Merges a sequence element with the current collector.

Returns: IEnumerable -- The enumerable sequence that returns collected/aggregated elements from the source sequence upon each iteration.

Exceptions

Type	Condition
System.ArgumentNullException	`source` or `newCollector` or `merge` is null.

2. Overload¶

public static IEnumerable<TResult> Collect<TSource, TResult>(this IObservable<TSource> source, Func<TResult> getInitialCollector, Func<TResult, TSource, TResult> merge, Func<TResult, TResult> getNewCollector)