Yields all elements of the first asynchronous sequence and then all elements of the second asynchronous sequence.

Buffer items from the async sequence into buffers of a specified size. The last buffer returned may be less than the specified buffer size.

Buffer items from the async sequence until a specified buffer size is reached or a specified amount of time is elapsed.

Buffers items from the async sequence by the specified time interval. If no items are received in an intervel and empty array is emitted.

Create a new asynchronous sequence that caches all elements of the sequence specified as the input. When accessing the resulting sequence multiple times, the input will still be evaluated only once

Asynchronously iterates over the input sequence and generates 'x' for every input element for which the specified function returned 'Some(x)'

Asynchronously iterates over the input sequence and generates 'x' for every input element for which the specified asynchronous function returned 'Some(x)' The specified function is asynchronous (and the input sequence will be asked for the next element after the processing of an element completes).

Creates an asynchronous sequence that iterates over the given input sequence. For every input element, it calls the the specified function and iterates over all elements generated by that asynchronous sequence. This is the 'bind' operation of the computation expression (exposed using the 'for' keyword in asyncSeq computation).

Merges two async sequences. The resulting async sequence produces an element when either input sequence produces an element, passing the new element from the emitting sequence and the previously emitted element from the other sequence. If either of the input sequences is empty, the resulting sequence is empty.

Merges two async sequences using the specified combine function. The resulting async sequence produces an element when either input sequence produces an element, passing the new element from the emitting sequence and the previously emitted element from the other sequence. If either of the input sequences is empty, the resulting sequence is empty.

Merges two async sequences using the specified combine function. The resulting async sequence produces an element when either input sequence produces an element, passing the new element from the emitting sequence and the previously emitted element from the other sequence. If either of the input sequences is empty, the resulting sequence is empty.

Flattens an AsyncSeq of asynchronous sequences.

Flattens an AsyncSeq of synchronous sequences.

Asynchronously determine if the sequence contains the given value

Returns an async sequence which contains no contiguous duplicate elements.

Returns an async sequence which contains no contiguous duplicate elements based on the specified comparison function.

Returns an async sequence which contains no contiguous duplicate elements based on the specified comparison function.

Creates an empty asynchronous sequence that immediately ends.

Asynchronously determine if there is a value in the sequence for which the predicate returns true

Same as AsyncSeq.filterAsync, but the specified predicate is synchronous and processes the input element immediately.

Builds a new asynchronous sequence whose elements are those from the input sequence for which the specified function returned true. The specified function is asynchronous (and the input sequence will be asked for the next element after the processing of an element completes).

Asynchronously returns the first element that was generated by the given asynchronous sequence (or the specified default value).

Asynchronously aggregate the elements of the input asynchronous sequence using the specified 'aggregation' function.

Asynchronously aggregate the elements of the input asynchronous sequence using the specified asynchronous 'aggregation' function.

Asynchronously determine if the predicate returns true for all values in the sequence

Applies a key-generating function to each element and returns an async sequence containing unique keys and async sequences containing elements corresponding to the key. Note that the resulting async sequence has to be processed in parallel (e.g AsyncSeq.mapAsyncParallel) becaused completion of sub-sequences depends on completion of other sub-sequences.

Applies a key-generating function to each element and returns an async sequence containing unique keys and async sequences containing elements corresponding to the key. Note that the resulting async sequence has to be processed in parallel (e.g AsyncSeq.mapAsyncParallel) becaused completion of sub-sequences depends on completion of other sub-sequences.

Return an asynchronous sequence which, when iterated, includes an integer indicating the index of each element in the sequence.

Generates a finite async sequence using the specified initialization function.

Generates a finite async sequence using the specified asynchronous initialization function.

Generates an infinite async sequence using the specified initialization function.

Generates an infinite async sequence using the specified asynchronous initialization function.

Interleaves two async sequences of the same type into a resulting sequence. The provided sequences are consumed in lock-step.

Interleaves two async sequences into a resulting sequence. The provided sequences are consumed in lock-step.

Returns an async sequence which emits an element on a specified period.

Iterates over the input sequence and calls the specified function for every value.

Iterates over the input sequence and calls the specified asynchronous function for every value. The input sequence will be asked for the next element after the processing of an element completes.

Iterates over the input sequence and calls the specified asynchronous function for every value. Each action computation is started but not awaited before consuming the next item from the sequence, thereby iterating in parallel.

Iterates over the input sequence and calls the specified asynchronous function for every value. Each action computation is started but not awaited before consuming the next item from the sequence, thereby iterating in parallel with a specified degree of parallelism.

Iterates over the input sequence and calls the specified asynchronous function for every value, passing along the index of that element. The input sequence will be asked for the next element after the processing of an element completes.

Asynchronously returns the last element that was generated by the given asynchronous sequence (or the specified default value).

Asynchronously determine the number of elements in the sequence

Same as AsyncSeq.mapAsync, but the specified function is synchronous.

Builds a new asynchronous sequence whose elements are generated by applying the specified function to all elements of the input sequence. The specified function is asynchronous (and the input sequence will be asked for the next element after the processing of an element completes).

Builds a new asynchronous sequence whose elements are generated by applying the specified function to all elements of the input sequence. The function is applied to elements in order and results are emitted in order, but in parallel, without waiting for a prior mapping operation to complete. Parallelism is bound by the ThreadPool.

Builds a new asynchronous sequence whose elements are generated by applying the specified function to all elements of the input sequence. The specified function is synchronous (and the input sequence will be asked for the next element after the processing of an element completes).

Builds a new asynchronous sequence whose elements are generated by applying the specified function to all elements of the input sequence. The specified function is asynchronous (and the input sequence will be asked for the next element after the processing of an element completes).

Merges two async sequences of the same type into an async sequence non-deterministically. The resulting async sequence produces elements when any argument sequence produces an element.

Merges all specified async sequences into an async sequence non-deterministically. The resulting async sequence produces elements when any argument sequence produces an element.

Merges two async sequences into an async sequence non-deterministically. The resulting async sequence produces elements when any argument sequence produces an element.

Creates an asynchronous computation that asynchronously yields results from the provided .NET IAsyncEnumerable.

Converts observable to an asynchronous sequence. Values that are produced by the observable while the asynchronous sequence is blocked are stored to an unbounded buffer and are returned as next elements of the async sequence.

Creates an asynchronous sequence that lazily takes element from an input synchronous sequence and returns them one-by-one.

Creates an asynchronous sequence that lazily takes element from an input synchronous sequence of asynchronous computation and returns them one-by-one.

Returns an asynchronous sequence that returns pairs containing an element from the input sequence and its predecessor. Empty sequence is returned for singleton input sequence.

Asynchronously pick a value from a sequence based on the specified chooser function. Raises KeyNotFoundException if the chooser function can't find a matching key.

Asynchronously pick a value from a sequence based on the specified chooser function. Raises KeyNotFoundException if the chooser function can't find a matching key.

Creates an async sequence which repeats the specified value the indicated number of times.

Creates an infinite async sequence which repeats the specified value.

Creates an infinite async sequence which repeatedly evaluates and emits the specified async value.

Creates an async sequence given by evaluating the specified async computation until it returns None.

Same as AsyncSeq.scanAsync, but the specified function is synchronous.

Aggregates the elements of the input asynchronous sequence using the specified 'aggregation' function. The result is an asynchronous sequence of intermediate aggregation result. The aggregation function is asynchronous (and the input sequence will be asked for the next element after the processing of an element completes).

Creates an asynchronous sequence that generates a single element and then ends.

Skips the first N elements of an asynchronous sequence and then returns the rest of the sequence unmodified.

Skips elements from an async sequence until the specified signal completes.

Skips elements from an asynchronous sequence while the specified predicate holds and then returns the rest of the sequence. The predicate is evaluated asynchronously.

Skips elements from an asynchronous sequence while the specified predicate holds and then returns the rest of the sequence. The predicate is evaluated asynchronously.

Yields a sequence ordered by keys. This function returns a sequence that digests the whole initial sequence as soon as that sequence is iterated. As a result this function should not be used with large or infinite sequences.

Applies a key-generating function to each element of an AsyncSeq and yield an array ordered by keys. This function returns an array that digests the whole initial sequence as soon as that sequence is iterated. As a result this function should not be used with large or infinite sequences.

Applies a key-generating function to each element of an AsyncSeq and yield an array ordered descending by keys. This function returns an array that digests the whole initial sequence as soon as that sequence is iterated. As a result this function should not be used with large or infinite sequences.

Yields an array ordered descending by keys. This function returns an array that digests the whole initial sequence as soon as that sequence is iterated. As a result this function should not be used with large or infinite sequences.

Asynchronously sum the elements of the input asynchronous sequence using the specified function.

Returns the first N elements of an asynchronous sequence does not cast an exception if count is larger than the sequence length.

Returns elements from the argument async sequence until the specified signal completes or the sequences completes.

Returns elements from an asynchronous sequence while the specified predicate holds. The predicate is evaluated synchronously.

Returns elements from an asynchronous sequence while the specified predicate holds. The predicate is evaluated asynchronously.

Returns elements from an asynchronous sequence while the specified predicate holds. The predicate is evaluated synchronously. Does return the first element that predicate fails

Threads a state through the mapping over an async sequence using an async function.

Creates an async computation which iterates the AsyncSeq and collects the output into an array.

Synchronously iterates the AsyncSeq and collects the output into an array.

Creates an .NET IAsyncEnumerable from the provided AsyncSeq computation.

Converts asynchronous sequence to a synchronous blocking sequence. The elements of the asynchronous sequence are consumed lazily.

Creates an async computation which iterates the AsyncSeq and collects the output into a list.

Synchronously iterates the AsyncSeq and collects the output into a list.

Converts asynchronous sequence to an IObservable<_>. When the client subscribes to the observable, a new copy of asynchronous sequence is started and is sequentially iterated over (at the maximal possible speed). Disposing of the observer cancels the iteration over asynchronous sequence.

Traverses an async sequence an applies to specified function such that if Choice2Of2 is returned the traversal short-circuits and Choice2Of2 is returned as the result. Otherwise, the entire sequence is traversed and the result returned as Choice1Of2.

Traverses an async sequence an applies to specified function such that if None is returned the traversal short-circuits and None is returned as the result. Otherwise, the entire sequence is traversed and the result returned as Some.

Alias for take

Asynchronously find the first value in a sequence for which the predicate returns true

Asynchronously returns the first element that was generated by the given asynchronous sequence (or None if the sequence is empty).

Asynchronously returns the last element that was generated by the given asynchronous sequence (or None if the sequence is empty).

Asynchronously pick a value from a sequence based on the specified chooser function.

Asynchronously pick a value from a sequence based on the specified chooser function.

Generates an async sequence using the specified generator function.

Generates an async sequence using the specified asynchronous generator function.

Feeds an async sequence of values into an async sequence of functions.

Feeds an async sequence of values into an async sequence of async functions.

Combines two asynchronous sequences into a sequence of pairs. The resulting sequence stops when either of the argument sequences stop.

Combines two asynchronous sequences into a sequence of pairs. The values from sequences are retrieved in parallel. The resulting sequence stops when either of the argument sequences stop.

Combines two asynchronous sequences using the specified function. The resulting sequence stops when either of the argument sequences stop.

Combines two asynchronous sequences using the specified function. The resulting sequence stops when either of the argument sequences stop.

Combines two asynchronous sequences using the specified function. The values from sequences are retrieved in parallel. The resulting sequence stops when either of the argument sequences stop.

Combines two asynchronous sequences using the specified function. The values from sequences are retrieved in parallel. The resulting sequence stops when either of the argument sequences stop.