stream-demux
Advanced tools
Comparing version
14
index.js
@@ -1,3 +0,3 @@ | ||
const AsyncIterableStream = require('async-iterable-stream'); | ||
const WritableAsyncIterableStream = require('writable-async-iterable-stream'); | ||
const DemuxedAsyncIterableStream = require('./demuxed-async-iterable-stream'); | ||
@@ -50,14 +50,2 @@ class StreamDemux { | ||
class DemuxedAsyncIterableStream extends AsyncIterableStream { | ||
constructor(streamDemux, name) { | ||
super(); | ||
this.name = name; | ||
this._streamDemux = streamDemux; | ||
} | ||
createAsyncIterator(timeout) { | ||
return this._streamDemux.createAsyncIterator(this.name, timeout); | ||
} | ||
} | ||
module.exports = StreamDemux; |
{ | ||
"name": "stream-demux", | ||
"version": "4.0.3", | ||
"version": "4.0.4", | ||
"description": "An iterable asynchronous stream demultiplexer.", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
15657
0.8%6
20%334
0.6%