ts-async-iterable-queue
Advanced tools
Comparing version 1.2.0 to 2.0.0
@@ -58,3 +58,8 @@ "use strict"; | ||
unsubscriptions = []; | ||
subscriber(q.enqueue, q.complete, q.error, function (handler) { return unsubscriptions.push(handler); }); | ||
subscriber({ | ||
next: q.enqueue, | ||
complete: q.complete, | ||
error: q.error, | ||
addCompletionHandler: function (handler) { return unsubscriptions.push(handler); } | ||
}); | ||
_b.label = 1; | ||
@@ -61,0 +66,0 @@ case 1: |
@@ -235,3 +235,8 @@ /*! ***************************************************************************** | ||
unsubscriptions = []; | ||
subscriber(q.enqueue, q.complete, q.error, function (handler) { return unsubscriptions.push(handler); }); | ||
subscriber({ | ||
next: q.enqueue, | ||
complete: q.complete, | ||
error: q.error, | ||
addCompletionHandler: function (handler) { return unsubscriptions.push(handler); } | ||
}); | ||
_b.label = 1; | ||
@@ -238,0 +243,0 @@ case 1: |
@@ -241,3 +241,8 @@ (function (global, factory) { | ||
unsubscriptions = []; | ||
subscriber(q.enqueue, q.complete, q.error, function (handler) { return unsubscriptions.push(handler); }); | ||
subscriber({ | ||
next: q.enqueue, | ||
complete: q.complete, | ||
error: q.error, | ||
addCompletionHandler: function (handler) { return unsubscriptions.push(handler); } | ||
}); | ||
_b.label = 1; | ||
@@ -244,0 +249,0 @@ case 1: |
@@ -1,1 +0,8 @@ | ||
export declare function createPushAsyncIterable<T>(subscriber: (next: (item: T) => void, complete: () => void, error: (reason: any) => void, addCompletionHandler: (handler: () => void) => void) => void): AsyncIterableIterator<T>; | ||
interface Subscription<T> { | ||
next: (item: T) => void; | ||
complete: () => void; | ||
error: (reason: any) => void; | ||
addCompletionHandler: (handler: () => void) => void; | ||
} | ||
export declare function createPushAsyncIterable<T>(subscriber: (s: Subscription<T>) => void): AsyncIterableIterator<T>; | ||
export {}; |
{ | ||
"name": "ts-async-iterable-queue", | ||
"version": "1.2.0", | ||
"version": "2.0.0", | ||
"description": "", | ||
@@ -5,0 +5,0 @@ "keywords": [], |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
68093
905