Function buffer

buffer(bufferSize?: number, eager?: boolean): (<A, E>(self: Source<A, E>) => Source<A, E>)
Converts any type of stream into a pull based one.

bufferSize configures the amount of items to keep in the queue
Parameters
- Optional bufferSize: number
- Optional eager: boolean
Returns (<A, E>(self: Source<A, E>) => Source<A, E>)
- - <A, E>(self: Source<A, E>): Source<A, E>
  - Type Parameters
    - A
    - E
    Parameters
    - self: Source<A, E>
    Returns Source<A, E>
- Defined in api/buffer.ts:84

Generated using TypeDoc