| AggregateT, TResult1, TResult2, TResult(IEnumerableT, FuncIObservableT, IObservableTResult1, FuncIObservableT, IObservableTResult2, FuncTResult1, TResult2, TResult) |
Applies two accumulator queries sequentially in a single
pass over a sequence.
|
| AggregateT, TResult1, TResult2, TResult3, TResult(IEnumerableT, FuncIObservableT, IObservableTResult1, FuncIObservableT, IObservableTResult2, FuncIObservableT, IObservableTResult3, FuncTResult1, TResult2, TResult3, TResult) |
Applies three accumulator queries sequentially in a single
pass over a sequence.
|
| AggregateT, TResult1, TResult2, TResult3, TResult4, TResult(IEnumerableT, FuncIObservableT, IObservableTResult1, FuncIObservableT, IObservableTResult2, FuncIObservableT, IObservableTResult3, FuncIObservableT, IObservableTResult4, FuncTResult1, TResult2, TResult3, TResult4, TResult) |
Applies four accumulator queries sequentially in a single
pass over a sequence.
|
| AggregateT, TResult1, TResult2, TResult3, TResult4, TResult5, TResult(IEnumerableT, FuncIObservableT, IObservableTResult1, FuncIObservableT, IObservableTResult2, FuncIObservableT, IObservableTResult3, FuncIObservableT, IObservableTResult4, FuncIObservableT, IObservableTResult5, FuncTResult1, TResult2, TResult3, TResult4, TResult5, TResult) |
Applies five accumulator queries sequentially in a single
pass over a sequence.
|
| AggregateT, TResult1, TResult2, TResult3, TResult4, TResult5, TResult6, TResult(IEnumerableT, FuncIObservableT, IObservableTResult1, FuncIObservableT, IObservableTResult2, FuncIObservableT, IObservableTResult3, FuncIObservableT, IObservableTResult4, FuncIObservableT, IObservableTResult5, FuncIObservableT, IObservableTResult6, FuncTResult1, TResult2, TResult3, TResult4, TResult5, TResult6, TResult) |
Applies six accumulator queries sequentially in a single
pass over a sequence.
|
| AggregateT, TResult1, TResult2, TResult3, TResult4, TResult5, TResult6, TResult7, TResult(IEnumerableT, FuncIObservableT, IObservableTResult1, FuncIObservableT, IObservableTResult2, FuncIObservableT, IObservableTResult3, FuncIObservableT, IObservableTResult4, FuncIObservableT, IObservableTResult5, FuncIObservableT, IObservableTResult6, FuncIObservableT, IObservableTResult7, FuncTResult1, TResult2, TResult3, TResult4, TResult5, TResult6, TResult7, TResult) |
Applies seven accumulator queries sequentially in a single
pass over a sequence.
|
| AggregateT, TResult1, TResult2, TResult3, TResult4, TResult5, TResult6, TResult7, TResult8, TResult(IEnumerableT, FuncIObservableT, IObservableTResult1, FuncIObservableT, IObservableTResult2, FuncIObservableT, IObservableTResult3, FuncIObservableT, IObservableTResult4, FuncIObservableT, IObservableTResult5, FuncIObservableT, IObservableTResult6, FuncIObservableT, IObservableTResult7, FuncIObservableT, IObservableTResult8, FuncTResult1, TResult2, TResult3, TResult4, TResult5, TResult6, TResult7, TResult8, TResult) |
Applies eight accumulator queries sequentially in a single
pass over a sequence.
|
| AsOrderedT |
Returns a query whose results evaluate asynchronously but which
are returned in the order of the source.
|
| AsSequentialT |
Converts a query whose results evaluate asynchronously to use
sequential instead of concurrent evaluation.
|
| AsUnorderedT |
Returns a query whose results evaluate asynchronously but which
are returned without guarantee of the source order.
|
| AwaitT(IEnumerableTaskT) |
Creates a sequence query that streams the result of each task in
the source sequence as it completes asynchronously.
|
| AwaitT, TResult(IEnumerableT, FuncT, CancellationToken, TaskTResult) |
Creates a sequence query that streams the result of each task in
the source sequence as it completes asynchronously. A
CancellationToken is passed for each asynchronous
evaluation to abort any asynchronous operations in flight if the
sequence is not fully iterated.
|
| AwaitCompletionT, TTaskResult, TResult |
Awaits completion of all asynchronous evaluations irrespective of
whether they succeed or fail. An additional argument specifies a
function that projects the final result given the source item and
completed task.
|
| BatchTSource, TResult(IEnumerableTSource, Int32, ArrayPoolTSource, FuncICurrentBufferTSource, TResult) |
Batches the source sequence into sized buckets using an array pool
to rent arrays to back each bucket and returns a sequence of
elements projected from each bucket.
|
| BatchTSource, TBucket, TResult(IEnumerableTSource, Int32, ArrayPoolTSource, FuncICurrentBufferTSource, IEnumerableTBucket, FuncIEnumerableTBucket, TResult) |
Batches the source sequence into sized buckets using an array pool
to rent arrays to back each bucket and returns a sequence of
elements projected from each bucket.
|
| MaxConcurrencyT |
Returns a query whose results evaluate asynchronously to use a
concurrency limit.
|
| MemoizeT |
Creates a sequence that lazily caches the source as it is iterated
for the first time, reusing the cache thereafter for future
re-iterations. If the source is already cached or buffered then it
is returned verbatim.
|
| PreserveOrderT |
Returns a query whose results evaluate asynchronously and a Boolean
argument indicating whether the source order of the results is
preserved.
|
| SchedulerT |
Returns a query whose results evaluate asynchronously and uses the
given scheduler for the workhorse task.
|
| TrySingleT, TCardinality(IEnumerableT, TCardinality, TCardinality, TCardinality) |
Returns a tuple with the cardinality of the sequence and the
single element in the sequence if it contains exactly one element.
similar to SingleTSource(IEnumerableTSource).
|
| TrySingleT, TCardinality, TResult(IEnumerableT, TCardinality, TCardinality, TCardinality, FuncTCardinality, T, TResult) |
Returns a result projected from the the cardinality of the sequence
and the single element in the sequence if it contains exactly one
element.
|
| UnboundedConcurrencyT |
Returns a query whose results evaluate asynchronously and
concurrently with no defined limitation on concurrency.
|