@jacobbubu/pull-pushable-duplex


> A helper class for constructing full/half pushable duplex in pull-stream manner.

Intro.

Constructing a full-duplex, pushable duplex requires complex state management considerations.

Especially, you need to make sure that you follow the guidelines of the pull-stream (pull-stream-protocol-checker).

Usage

`` ts
import * as pull from 'pull-stream'
import { PushableDuplex } from '@jacobbubu/pull-pushable-duplex'

function valuesToRead(values: T[] = []) {
let i = 0
return (cb: OnReadCallback) => {
i === values.length ? cb(true) : cb(null, values[i])
i += 1
}
}

const results: any[] = []
const d = new PushableDuplex({
allowHalfOpen: true,
onRead: valuesToRead([1, 2, 3]),
onReceived: (data) => {
results.push(data)
},
onFinished: (err) => {
console.log("we've" got, results)
},
})
const peer = {
source: pull.values(['a', 'b', 'c']),
sink: pull.collect((err, results) => {
console.log("peer's got", results)
})
}
pull(d, peer, d)
``