File tree Expand file tree Collapse file tree 1 file changed +5
-3
lines changed Expand file tree Collapse file tree 1 file changed +5
-3
lines changed Original file line number Diff line number Diff line change 1
1
const StreamDemux = require ( 'stream-demux' ) ;
2
2
3
3
function AsyncStreamEmitter ( options ) {
4
- let { usabilityMode } = options || { } ;
5
- this . usabilityMode = usabilityMode || false ;
6
4
this . _listenerDemux = new StreamDemux ( ) ;
7
5
}
8
6
@@ -11,7 +9,7 @@ AsyncStreamEmitter.prototype.emit = function (eventName, data) {
11
9
} ;
12
10
13
11
AsyncStreamEmitter . prototype . listener = function ( eventName ) {
14
- return this . _listenerDemux . stream ( eventName , this . usabilityMode ) ;
12
+ return this . _listenerDemux . stream ( eventName ) ;
15
13
} ;
16
14
17
15
AsyncStreamEmitter . prototype . closeListener = function ( eventName ) {
@@ -22,6 +20,10 @@ AsyncStreamEmitter.prototype.closeAllListeners = function () {
22
20
this . _listenerDemux . closeAll ( ) ;
23
21
} ;
24
22
23
+ AsyncStreamEmitter . prototype . removeListener = function ( eventName ) {
24
+ this . _listenerDemux . unstream ( eventName ) ;
25
+ } ;
26
+
25
27
AsyncStreamEmitter . prototype . getListenerConsumerStats = function ( consumerId ) {
26
28
return this . _listenerDemux . getConsumerStats ( consumerId ) ;
27
29
} ;
You can’t perform that action at this time.
0 commit comments