• Creates a buffer with a shared view over the source sequence, causing each iterator to fetch the next element from the source sequence.

    Type Parameters

    • TSource

      Source sequence element type.

    Returns OperatorAsyncFunction<TSource, TSource>

    Buffer enabling each enumerator to retrieve elements from the shared source sequence.

  • Shares the source sequence within a selector function where each iterator can fetch the next element from the source sequence.

    Type Parameters

    • TSource

      Source sequence element type.

    • TResult

      Result sequence element type.

    Parameters

    • Optional selector: ((value, signal?) => AsyncIterable<TResult> | Promise<AsyncIterable<TResult>>)

      Selector function with shared access to the source sequence for each iterator.

        • (value, signal?): AsyncIterable<TResult> | Promise<AsyncIterable<TResult>>
        • Parameters

          • value: AsyncIterable<TSource>
          • Optional signal: AbortSignal

          Returns AsyncIterable<TResult> | Promise<AsyncIterable<TResult>>

    Returns OperatorAsyncFunction<TSource, TResult>

    Sequence resulting from applying the selector function to the shared view over the source sequence.

Generated using TypeDoc