Interface IConcurrencyWork<T, R>

Provides a work chain, based on concurrency, for operator concurrencyFork.

Type Parameters

  • T

  • R

Hierarchy

  • IConcurrencyWork

Methods

onAsync? onSync?

Methods

Optional onAsync

  • Invoked for asynchronous iterables only, to return a chain of operators for asynchronous processing.

    When nothing or null is returned, it redirects to the source iterable.

    Parameters

    • i: AsyncIterable<T>

    Returns null | void | AsyncIterable<R>

Optional onSync

  • Invoked for synchronous iterables only, to return a chain of operators for synchronous processing.

    When nothing or null is returned, it redirects to the source iterable.

    Parameters

    • i: Iterable<T>

    Returns null | void | Iterable<R>

Settings

Member Visibility

Theme

On This Page