passthrough-wrapper.js

/*******************************************************************************
 * Copyright (c) 2018 Nicola Del Gobbo
 * Licensed under the Apache License, Version 2.0 (the "License"); you may not
 * use this file except in compliance with the License. You may obtain a copy of
 * the license at http://www.apache.org/licenses/LICENSE-2.0
 *
 * THIS CODE IS PROVIDED ON AN *AS IS* BASIS, WITHOUT WARRANTIES OR CONDITIONS
 * OF ANY KIND, EITHER EXPRESS OR IMPLIED, INCLUDING WITHOUT LIMITATION ANY
 * IMPLIED WARRANTIES OR CONDITIONS OF TITLE, FITNESS FOR A PARTICULAR PURPOSE,
 * MERCHANTABLITY OR NON-INFRINGEMENT.
 *
 * See the Apache Version 2.0 License for specific language governing
 * permissions and limitations under the License.
 *
 * Contributors - initial API implementation:
 * Nicola Del Gobbo <nicoladelgobbo@gmail.com>
 ******************************************************************************/

'use strict'

const { PassThrough } = require('bindings')('passthrough')
const { Transform } = require('readable-stream')

class PassthroughWrapper extends Transform {

    constructor(opts = {}) {
        super(opts)
        this._passthrough = new PassThrough()
    }

    _transform(chunk, encoding, cb) {
        // console.log(chunk.toString())       
        // console.log(Buffer.from(this._passthrough.write(chunk)).toString())
        this.push(this._passthrough.write(chunk))
        cb()
    }

}

module.exports = PassthroughWrapper