@jacobbubu/multiplex-pull

A multiplex impementation that uses pull-stream.

Usage

npm install @jacobbubu/multiplex-pull
npm run example.ex1

import * as pull from 'pull-stream'
import { Multiplex, Channel } from '@jacobbubu/multiplex-pull'

const plex1 = new Multiplex()

const plex2 = new Multiplex(null, (channel: Channel, name: string) => {
  pull(
    channel.source,
    pull.collect((err, result) => {
      expect(err).toBeFalsy()
      expect(result.toString()).toEqual('plex1')
      done()
    })
  )
})

pull(p1.source, p2.sink)
pull(p2.source, p1.sink)

pull(pull.values(['plex1']), channelAt1.sink)