code: function createTransformStream(filter) {
    var transform = new Transform({ objectMode: true });
    var push = transform.push.bind(transform);
    transform._transform = function(frame, encoding, done) {
      filter(frame, push, done);
    };
    return transform;
  }
docs: +---------------------------------------------+ |                                             | |   +-------------------------------------+   | |   | +---------+ +---------+ +---------+ |   | |   | | stream1 | | stream2 | |   ...   | |   | |   | +---------+ +---------+ +---------+ |   | |   |             connection              |   | |   +-------------------------------------+   | |             |                 ^             | |        pipe |                 | pipe        | |             v                 |             | |   +------------------+------------------+   | |   |    compressor    |   decompressor   |   | |   +------------------+------------------+   | |             |                 ^             | |        pipe |                 | pipe        | |             v                 |             | |   +------------------+------------------+   | |   |    serializer    |   deserializer   |   | |   +------------------+------------------+   | |             |                 ^             | |     _read() |                 | _write()    | |             v                 |             | |      +------------+     +-----------+       | |      |output queue|     |input queue|       | +------+------------+-----+-----------+-------+ |                 ^ read() |                 | write() v                 |