Skip to content

Instantly share code, notes, and snippets.

Embed
What would you like to do?
stream._write = function (buf, enc, next) {
// dont send terminate signal
console.log('WRITE', [buf, buf.toString()])
if (buf.length === 4 && buf[buf.length-1] === 48
&& buf[buf.length-2] === 48 && buf[buf.length-3] === 48
&& buf[buf.length-4] === 48) stream.needsPktFlush = true
else backend.push(buf)
if (backend._ready) next()
else stream._next = next;
};
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
You can’t perform that action at this time.