Comparing version
@@ -1,4 +0,4 @@ | ||
const AsyncIterableStream = require('async-iterable-stream'); | ||
const ConsumableStream = require('consumable-stream'); | ||
class AGChannel extends AsyncIterableStream { | ||
class AGChannel extends ConsumableStream { | ||
constructor(name, client, eventDemux, dataStream) { | ||
@@ -17,4 +17,4 @@ super(); | ||
createAsyncIterator(timeout) { | ||
return this._dataStream.createAsyncIterator(timeout); | ||
createConsumer(timeout) { | ||
return this._dataStream.createConsumer(timeout); | ||
} | ||
@@ -21,0 +21,0 @@ |
{ | ||
"name": "ag-channel", | ||
"version": "3.0.0", | ||
"version": "3.1.0", | ||
"description": "Channel object for Asyngular", | ||
@@ -11,3 +11,3 @@ "main": "index.js", | ||
"dependencies": { | ||
"async-iterable-stream": "^4.0.0" | ||
"consumable-stream": "^1.0.0" | ||
}, | ||
@@ -14,0 +14,0 @@ "keywords": [ |
2319
-1.02%+ Added
+ Added
- Removed
- Removed