1.6.1 • Published 4 years ago
@jacobbubu/pull-plex v1.6.1
@jacobbubu/pull-plex
A multiplex solution for pull-stream.
Usage
import * as pull from 'pull-stream'
import { Plex, Channel } from '../src'
const plex1 = new Plex('p1')
const plex2 = new Plex('p2')
const a = plex1.createChannel('a')
pull(pull.values([1, 2, 3]), a.sink)
pull(
a.source,
pull.collect((_, ary) => {
console.log(`received data on channel ${a.name}/${plex1.plexName}:`, ary)
})
)
plex2.on('channel', (channel: Channel) => {
pull(
channel.source,
pull.collect((_, ary) => {
console.log(`received data on channel ${channel.name}/${plex2.plexName}:`, ary)
})
)
pull(pull.values([4, 5, 6]), channel.sink)
})
pull(plex1, plex2)
pull(plex2, plex1)
1.6.1
4 years ago
1.6.0
4 years ago
1.5.0
4 years ago
1.4.5
4 years ago
1.4.4
4 years ago
1.4.3
4 years ago
1.4.2
4 years ago
1.4.1
4 years ago
1.3.2
4 years ago
1.4.0
4 years ago
1.3.1
4 years ago
1.3.0
4 years ago
1.2.0
4 years ago
1.2.1
4 years ago
1.1.3
4 years ago
1.1.1
4 years ago
1.1.0
4 years ago
1.1.2
4 years ago
1.0.0
4 years ago