Module it-queueless-pushable

A pushable async generator that waits until the current value is consumed before allowing a new value to be pushed.

Useful for when you don't want to keep memory usage under control and/or allow a downstream consumer to dictate how fast data flows through a pipe, but you want to be able to apply a transform to that data.

Example

import { queuelessPushable } from 'it-queueless-pushable'

const pushable = queuelessPushable<string>()

// run asynchronously
Promise.resolve().then(async () => {
  // push a value - the returned promise will not resolve until the value is
  // read from the pushable
  await pushable.push('hello')
})

// read a value
const result = await pushable.next()
console.info(result) // { done: false, value: 'hello' }

Interfaces

Pushable

Functions

queuelessPushable

Module it-queueless-pushable

Example

Interfaces

Functions

Settings

On This Page