'use strict' class PassThrough { constructor () { this.sink = null this.source = null } bindSource (source) { source.bindSink(this) this.source = source return this } bindSink (sink) { this.sink = sink } next (status, error, buffer, bytes) { this.sink.next(status, error, buffer, bytes) } pull (error, buffer) { this.source.pull(error, buffer) } } module.exports = PassThrough