signal-controller
Advanced tools
+2
-1
@@ -20,3 +20,3 @@ declare const ONCE_SYMBOL: unique symbol; | ||
| on<K extends keyof T>(signalName: K, options: SignalListenerOptions, listener: T[K]): void; | ||
| stream<K extends keyof T>(signalName: K): ReadableStream<Parameters<T[K]>>; | ||
| readableStream<K extends keyof T>(signalName: K): ReadableStream<Parameters<T[K]>>; | ||
| next<K extends keyof T>(signalName: K, { signal }?: { | ||
@@ -34,3 +34,4 @@ signal?: AbortSignal | undefined; | ||
| clear(): void; | ||
| writableStream<K extends keyof T>(signalName: K): WritableStream<Parameters<T[K]>>; | ||
| } | ||
| export {}; |
+6
-1
@@ -52,3 +52,3 @@ const ONCE_SYMBOL = Symbol('once'); | ||
| } | ||
| stream(signalName) { | ||
| readableStream(signalName) { | ||
| const aborter = new AbortController(); | ||
@@ -105,2 +105,7 @@ return new ReadableStream({ | ||
| } | ||
| writableStream(signalName) { | ||
| return new WritableStream({ | ||
| write: args => this.emit(signalName, ...args), | ||
| }); | ||
| } | ||
| } |
+1
-1
| { | ||
| "name": "signal-controller", | ||
| "version": "0.2.0", | ||
| "version": "0.3.0", | ||
| "description": "A lightweight event emitter with separation of concerns between emitter and listener inspired by the AbortController interface. It also supports using AbortController to remove listeners.", | ||
@@ -5,0 +5,0 @@ "author": "Leonardo Raele <leonardoraele@gmail.com>", |
5530
4.73%144
4.35%