{“ast”:null,“code”:“'use strict';nnvar Readable = require('readable-stream').Readable;nnvar utils = require('../utils');nnutils.inherits(NodejsStreamOutputAdapter, Readable);n/*n A nodejs stream using a worker as source.n* @see the SourceWrapper in nodejs.org/api/stream.htmln* @constructorn* @param {StreamHelper} helper the helper wrapping the workern* @param {Object} options the nodejs stream optionsn* @param {Function} updateCb the update callback.n*/nnfunction NodejsStreamOutputAdapter(helper, options, updateCb) {n Readable.call(this, options);n this._helper = helper;n var self = this;n helper.on("data", function (data, meta) {n if (!self.push(data)) {n self._helper.pause();n }nn if (updateCb) {n updateCb(meta);n }n }).on("error", function (e) {n self.emit('error', e);n }).on("end", function () {n self.push(null);n });n}nnNodejsStreamOutputAdapter.prototype._read = function () {n this._helper.resume();n};nnmodule.exports = NodejsStreamOutputAdapter;”,“map”:null,“metadata”:{},“sourceType”:“module”}