Returns an async sequence of all pairs of elements from the two input sequences. The second sequence is fully buffered before iteration begins, mirroring Seq.allPairs.

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

Yields all elements of the source asynchronous sequence and then all elements of the synchronous sequence appended at the end.

Asynchronously compute the average of the elements of the input asynchronous sequence. Raises InvalidArgumentException if the sequence is empty.

Asynchronously compute the average of the mapped elements of an asynchronous sequence using a synchronous projection. Raises InvalidArgumentException if the sequence is empty.

Asynchronously compute the average of the mapped elements of an asynchronous sequence using an asynchronous projection. Raises InvalidArgumentException if the sequence is empty.

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).

Groups consecutive elements of the async sequence that share the same key (as computed by a projection) and yields each group as a pair of the key and a list of elements.

Groups consecutive elements of the async sequence that share the same key (as computed by an async projection) and yields each group as a pair of the key and a list of elements.

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

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).

Like AsyncSeq.collect but the mapping function is asynchronous. For every input element it calls the specified async function and iterates over all elements of the returned sequence.

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.

Compares two async sequences lexicographically using the given synchronous comparison function. Returns a negative integer if source1 < source2, 0 if equal, and a positive integer if source1 > source2.

Compares two async sequences lexicographically using the given asynchronous comparison function. Returns a negative integer if source1 < source2, 0 if equal, and a positive integer if source1 > source2.

Flattens an AsyncSeq of asynchronous sequences.

Flattens an AsyncSeq of synchronous sequences.

Asynchronously determine if the sequence contains the given value

Asynchronously count the elements of the input asynchronous sequence grouped by the result of the given key projection. Returns an array of (key, count) pairs.

Asynchronously count the elements of the input asynchronous sequence grouped by the result of the given asynchronous key projection. Returns an array of (key, count) pairs.

Returns a new async sequence whose enumeration calls the factory function each time it is enumerated. Useful for deferring the creation of a sequence until enumeration begins.

Returns an async sequence containing only distinct elements. Elements are compared using structural equality.

Returns an async sequence containing only distinct elements, determined by the given key projection. Elements are compared using structural equality on the projected key.

Returns an async sequence containing only distinct elements, determined by the given asynchronous key projection. Elements are compared using structural equality on the projected key.

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 returns the only element of the asynchronous sequence. Raises InvalidOperationException if the sequence is empty or contains more than one element.

Returns a new asynchronous sequence containing only elements that are not present in the given excluded collection. Uses a HashSet for O(1) lookup. Mirrors Seq.except.

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

Asynchronously determine if there is a value in the sequence for which the async 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 find the first value in a sequence for which the predicate returns true. Raises KeyNotFoundException if no matching element is found.

Asynchronously find the first value in a sequence for which the async predicate returns true. Raises KeyNotFoundException if no matching element is found.

Asynchronously find the index of the first value in a sequence for which the predicate returns true. Raises KeyNotFoundException if no matching element is found.

Asynchronously find the index of the first value in a sequence for which the async predicate returns true. Raises KeyNotFoundException if no matching element is found.

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

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

Creates an async seq from a channel reader. The async seq will read values from the channel reader until it is closed. If the reader raises an error than the sequence will raise it.

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.

Asynchronously returns the first element of the asynchronous sequence. Raises InvalidOperationException if the sequence is empty.

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.

Returns a new asynchronous sequence with the given value inserted before the element at the specified index. An index equal to the length of the sequence appends the value at the end. Raises ArgumentException if index is negative or greater than the sequence length. Mirrors Seq.insertAt.

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.

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

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

Asynchronously returns true if the asynchronous sequence contains no elements, false otherwise. Short-circuits after the first element. Mirrors Seq.isEmpty.

Asynchronously returns the element at the specified index in the asynchronous sequence. Raises ArgumentException if the index is out of bounds, mirroring Seq.item.

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 function for every value, passing along the index of that element.

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 of the asynchronous sequence. Raises InvalidOperationException if the sequence is empty, mirroring Seq.last.

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

Asynchronously returns the number of elements in the sequence for which the predicate returns true.

Asynchronously returns the number of elements in the sequence for which the async predicate returns true.

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 function is applied to elements in parallel, and results are emitted in the order they complete (unordered), without preserving the original order. This can provide better performance than mapAsyncParallel when order doesn't matter. 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, with at most parallelism mapping operations running concurrently. The function is applied to elements in parallel (throttled), and results are emitted in the order they complete (unordered), without preserving the original order.

Maps each element of the async sequence with a folder function that also threads an accumulator state through the computation. Returns the array of results and the final state, mirroring Seq.mapFold.

Asynchronously maps each element of the async sequence with an asynchronous folder function that also threads an accumulator state through the computation. Returns the array of results and the final state, mirroring Seq.mapFold.

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).

Asynchronously find the maximum element. Raises InvalidOperationException if the sequence is empty.

Asynchronously find the element with the maximum projected value. Raises InvalidOperationException if the sequence is empty.

Asynchronously find the element with the maximum projected value. Raises InvalidOperationException if the sequence is empty.

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.

Asynchronously find the minimum element. Raises InvalidOperationException if the sequence is empty.

Asynchronously find the element with the minimum projected value. Raises InvalidOperationException if the sequence is empty.

Asynchronously find the element with the minimum projected value. Raises InvalidOperationException if the sequence is empty.

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.

Splits the sequence into two arrays: the first contains elements for which the predicate returns true, the second contains elements for which it returns false. Mirrors Seq.partition.

Splits the sequence into two arrays using an async predicate: the first contains elements for which the predicate returns true, the second contains elements for which it returns false.

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.

Transforms an async seq to a new one that fetches values ahead of time to improve throughput.

Yields all elements of the synchronous sequence first and then all elements of the source asynchronous sequence.

Asynchronously reduce the elements of the input asynchronous sequence using the specified 'reduction' function. Raises InvalidOperationException if the sequence is empty.

Asynchronously reduce the elements of the input asynchronous sequence using the specified asynchronous 'reduction' function. Raises InvalidOperationException if the sequence is empty.

Returns a new asynchronous sequence with the element at the specified index removed. Raises ArgumentException if index is negative. Mirrors Seq.removeAt.

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.

Returns a new async sequence with the elements in reverse order. The entire source sequence is buffered before yielding any elements, mirroring Seq.rev. This function should not be used with large or infinite sequences.

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.