async-stream-emitter - npm Package Compare versions

Comparing version 2.0.0 to 2.1.0

index.js

@@ -23,2 +23,46 @@ const StreamDemux = require('stream-demux');
 
+AsyncStreamEmitter.prototype.getConsumerStats = function (consumerId) {
+  return this._listenerDemux.getConsumerStats(consumerId);
+};
+
+AsyncStreamEmitter.prototype.getConsumerStatsList = function (eventName) {
+  return this._listenerDemux.getConsumerStatsList(eventName);
+};
+
+AsyncStreamEmitter.prototype.getConsumerStatsListAll = function () {
+  return this._listenerDemux.getConsumerStatsListAll();
+};
+
+AsyncStreamEmitter.prototype.killListener = function (eventName) {
+  this._listenerDemux.kill(eventName);
+};
+
+AsyncStreamEmitter.prototype.killAllListeners = function () {
+  this._listenerDemux.killAll();
+};
+
+AsyncStreamEmitter.prototype.killConsumer = function (consumerId) {
+  this._listenerDemux.killConsumer(consumerId);
+};
+
+AsyncStreamEmitter.prototype.getBackpressure = function (eventName) {
+  return this._listenerDemux.getBackpressure(eventName);
+};
+
+AsyncStreamEmitter.prototype.getBackpressureAll = function () {
+  return this._listenerDemux.getBackpressureAll();
+};
+
+AsyncStreamEmitter.prototype.getConsumerBackpressure = function (consumerId) {
+  return this._listenerDemux.getConsumerBackpressure(consumerId);
+};
+
+AsyncStreamEmitter.prototype.hasConsumer = function (eventName, consumerId) {
+  return this._listenerDemux.hasConsumer(eventName, consumerId);
+};
+
+AsyncStreamEmitter.prototype.hasConsumerAll = function (consumerId) {
+  return this._listenerDemux.hasConsumerAll(consumerId);
+};
+
 module.exports = AsyncStreamEmitter;

package.json

 {
   "name": "async-stream-emitter",
-  "version": "2.0.0",
-  "description": "An alternantive to EventEmitter using async iterable streams.",
+  "version": "2.1.0",
+  "description": "An alternantive to EventEmitter using consumable streams.",
   "main": "index.js",
@@ -31,4 +31,4 @@ "scripts": {
   "dependencies": {
-    "stream-demux": "^5.1.0"
+    "stream-demux": "^6.1.0"
   }
 }

README.md

 # async-stream-emitter
-EventEmitter using AsyncIterableStream.
+EventEmitter using ConsumableStream.
 
@@ -4,0 +4,0 @@ ## Methods:

test/test.js

@@ -48,2 +48,46 @@ const assert = require('assert');
   });
+
+  it('should expose a getConsumerStats method', async () => {
+    assert.equal(!!streamEmitter.getConsumerStats, true);
+  });
+
+  it('should expose a getConsumerStatsList method', async () => {
+    assert.equal(!!streamEmitter.getConsumerStatsList, true);
+  });
+
+  it('should expose a getConsumerStatsListAll method', async () => {
+    assert.equal(!!streamEmitter.getConsumerStatsListAll, true);
+  });
+
+  it('should expose a killListener method', async () => {
+    assert.equal(!!streamEmitter.killListener, true);
+  });
+
+  it('should expose a killAllListeners method', async () => {
+    assert.equal(!!streamEmitter.killAllListeners, true);
+  });
+
+  it('should expose a killConsumer method', async () => {
+    assert.equal(!!streamEmitter.killConsumer, true);
+  });
+
+  it('should expose a getBackpressure method', async () => {
+    assert.equal(!!streamEmitter.getBackpressure, true);
+  });
+
+  it('should expose a getBackpressureAll method', async () => {
+    assert.equal(!!streamEmitter.getBackpressureAll, true);
+  });
+
+  it('should expose a getConsumerBackpressure method', async () => {
+    assert.equal(!!streamEmitter.getConsumerBackpressure, true);
+  });
+
+  it('should expose a hasConsumer method', async () => {
+    assert.equal(!!streamEmitter.hasConsumer, true);
+  });
+
+  it('should expose a hasConsumerAll method', async () => {
+    assert.equal(!!streamEmitter.hasConsumerAll, true);
+  });
 });

No alert changes

Improved metrics

Total package byte prevSize

7708

increased by57.34%

Lines of code

121

increased by120%

Dependency changes

• + Addedconsumable-stream@1.0.0(transitive)

• + Addedstream-demux@6.1.0(transitive)

• + Addedwritable-consumable-stream@1.1.1(transitive)

• - Removedasync-iterable-stream@4.0.0(transitive)

• - Removedstream-demux@5.1.0(transitive)

• Updatedstream-demux@^6.1.0