|
| Name | Description |
|---|
  | Aggregate<T, TResult1, TResult2, TResult3, TResult4, TResult5, TResult6, TResult7, TResult8, TResult>(IEnumerable<T>, Func<IObservable<T>, IObservable<TResult1>>, Func<IObservable<T>, IObservable<TResult2>>, Func<IObservable<T>, IObservable<TResult3>>, Func<IObservable<T>, IObservable<TResult4>>, Func<IObservable<T>, IObservable<TResult5>>, Func<IObservable<T>, IObservable<TResult6>>, Func<IObservable<T>, IObservable<TResult7>>, Func<IObservable<T>, IObservable<TResult8>>, Func<TResult1, TResult2, TResult3, TResult4, TResult5, TResult6, TResult7, TResult8, TResult>) |
Applies eight accumulator queries sequentially in a single
pass over a sequence.
|
| Aggregate<T, TResult1, TResult2, TResult>(IEnumerable<T>, Func<IObservable<T>, IObservable<TResult1>>, Func<IObservable<T>, IObservable<TResult2>>, Func<TResult1, TResult2, TResult>) |
Applies two accumulator queries sequentially in a single
pass over a sequence.
|
| Aggregate<T, TResult1, TResult2, TResult3, TResult>(IEnumerable<T>, Func<IObservable<T>, IObservable<TResult1>>, Func<IObservable<T>, IObservable<TResult2>>, Func<IObservable<T>, IObservable<TResult3>>, Func<TResult1, TResult2, TResult3, TResult>) |
Applies three accumulator queries sequentially in a single
pass over a sequence.
|
| Aggregate<T, TResult1, TResult2, TResult3, TResult4, TResult>(IEnumerable<T>, Func<IObservable<T>, IObservable<TResult1>>, Func<IObservable<T>, IObservable<TResult2>>, Func<IObservable<T>, IObservable<TResult3>>, Func<IObservable<T>, IObservable<TResult4>>, Func<TResult1, TResult2, TResult3, TResult4, TResult>) |
Applies four accumulator queries sequentially in a single
pass over a sequence.
|
| Aggregate<T, TResult1, TResult2, TResult3, TResult4, TResult5, TResult>(IEnumerable<T>, Func<IObservable<T>, IObservable<TResult1>>, Func<IObservable<T>, IObservable<TResult2>>, Func<IObservable<T>, IObservable<TResult3>>, Func<IObservable<T>, IObservable<TResult4>>, Func<IObservable<T>, IObservable<TResult5>>, Func<TResult1, TResult2, TResult3, TResult4, TResult5, TResult>) |
Applies five accumulator queries sequentially in a single
pass over a sequence.
|
| Aggregate<T, TResult1, TResult2, TResult3, TResult4, TResult5, TResult6, TResult>(IEnumerable<T>, Func<IObservable<T>, IObservable<TResult1>>, Func<IObservable<T>, IObservable<TResult2>>, Func<IObservable<T>, IObservable<TResult3>>, Func<IObservable<T>, IObservable<TResult4>>, Func<IObservable<T>, IObservable<TResult5>>, Func<IObservable<T>, IObservable<TResult6>>, Func<TResult1, TResult2, TResult3, TResult4, TResult5, TResult6, TResult>) |
Applies six accumulator queries sequentially in a single
pass over a sequence.
|
| Aggregate<T, TResult1, TResult2, TResult3, TResult4, TResult5, TResult6, TResult7, TResult>(IEnumerable<T>, Func<IObservable<T>, IObservable<TResult1>>, Func<IObservable<T>, IObservable<TResult2>>, Func<IObservable<T>, IObservable<TResult3>>, Func<IObservable<T>, IObservable<TResult4>>, Func<IObservable<T>, IObservable<TResult5>>, Func<IObservable<T>, IObservable<TResult6>>, Func<IObservable<T>, IObservable<TResult7>>, Func<TResult1, TResult2, TResult3, TResult4, TResult5, TResult6, TResult7, TResult>) |
Applies seven accumulator queries sequentially in a single
pass over a sequence.
|
| AsOrdered<T> |
Returns a query whose results evaluate asynchronously but which
are returned in the order of the source.
|
| AsSequential<T> |
Converts a query whose results evaluate asynchronously to use
sequential instead of concurrent evaluation.
|
| AsUnordered<T> |
Returns a query whose results evaluate asynchronously but which
are returned without guarantee of the source order.
|
| Await<T>(IEnumerable<Task<T>>) |
Creates a sequence query that streams the result of each task in
the source sequence as it completes asynchronously.
|
| Await<T, TResult>(IEnumerable<T>, Func<T, CancellationToken, Task<TResult>>) |
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.
|
| AwaitCompletion<T, 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.
|
| MaxConcurrency<T> |
Returns a query whose results evaluate asynchronously to use a
concurrency limit.
|
| Memoize<T> |
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.
|
| PreserveOrder<T> |
Returns a query whose results evaluate asynchronously and a Boolean
argument indicating whether the source order of the results is
preserved.
|
| Scheduler<T> |
Returns a query whose results evaluate asynchronously and uses the
given scheduler for the workhorse task.
|
| UnboundedConcurrency<T> |
Returns a query whose results evaluate asynchronously and
concurrently with no defined limitation on concurrency.
|
Inheritance Hierarchy