gistfile1.txt

    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;
    };