* A worker that use a nodejs stream as source. * @constructor * @param {String} filename the name of the file entry for this stream. * @param {Readable} stream the nodejs stream.
(filename, stream)
| 10 | * @param {Readable} stream the nodejs stream. |
| 11 | */ |
| 12 | function NodejsStreamInputAdapter(filename, stream) { |
| 13 | GenericWorker.call(this, "Nodejs stream input adapter for " + filename); |
| 14 | this._upstreamEnded = false; |
| 15 | this._bindStream(stream); |
| 16 | } |
| 17 | |
| 18 | utils.inherits(NodejsStreamInputAdapter, GenericWorker); |
| 19 |
nothing calls this directly
no outgoing calls
no test coverage detected