pull-redirectable

0.1.2 • Public • Published

pull-redirectable

Redirectable pull-streams

API

  • .source(): Creates a redirectable source
  • .sink(): Creates a redirectable sink
  • .duplex(): Creates a redirectable duplex

Stream API

.changeDest(to): Changes the destination to a or b

Every stream exposes an a and b stream.

The main stream is an inverse of the type (e.g sink => source)

Example

it('moves half the data from a to o and the other half from b', cb => {
  const s = redir.sink()
  let i = 0
 
  pull(
    pull.values(v.slice(0, 2)),
    pull.map(v => {
      i++
      if (=== 2) s.changeDest('b')
      return v
    }),
    s.a.sink
  )
 
  pull(
    pull.values(v.slice(2)),
    s.b.sink
  )
 
  pull(
    s.source,
    pullCompare(v, cb)
  )
})

Package Sidebar

Install

npm i pull-redirectable

Weekly Downloads

4

Version

0.1.2

License

MIT

Last publish

Collaborators

  • mkg20001