(filter)
| 151 | // v | |
| 152 | |
| 153 | function createTransformStream(filter) { |
| 154 | var transform = new Transform({ objectMode: true }); |
| 155 | var push = transform.push.bind(transform); |
| 156 | transform._transform = function(frame, encoding, done) { |
| 157 | filter(frame, push, done); |
| 158 | }; |
| 159 | return transform; |
| 160 | } |
| 161 | |
| 162 | function pipeAndFilter(stream1, stream2, filter) { |
| 163 | if (filter) { |