xstream
Advanced tools
Comparing version 11.4.0 to 11.5.0
@@ -9,3 +9,4 @@ import { Operator, Stream } from '../index'; | ||
private on; | ||
constructor(o: Stream<any>, ins: Stream<T>); | ||
constructor(o: Stream<any>, // o = other | ||
ins: Stream<T>); | ||
_start(out: Stream<T>): void; | ||
@@ -12,0 +13,0 @@ _stop(): void; |
@@ -15,3 +15,3 @@ import { Stream, InternalProducer, InternalListener } from '../index'; | ||
_start(out: InternalListener<any>): void; | ||
private schedule(notification, out); | ||
private schedule; | ||
_stop(): void; | ||
@@ -18,0 +18,0 @@ } |
@@ -9,3 +9,4 @@ import { Operator, Stream } from '../index'; | ||
private sil; | ||
constructor(s: Stream<any>, ins: Stream<T>); | ||
constructor(s: Stream<any>, // s = separator | ||
ins: Stream<T>); | ||
_start(out: Stream<Stream<T>>): void; | ||
@@ -12,0 +13,0 @@ _stop(): void; |
@@ -9,3 +9,3 @@ declare const NO: {}; | ||
export interface InternalProducer<T> { | ||
_start: (listener: InternalListener<T>) => void; | ||
_start(listener: InternalListener<T>): void; | ||
_stop: () => void; | ||
@@ -19,3 +19,3 @@ } | ||
ins: Stream<T>; | ||
_start: (out: Stream<R>) => void; | ||
_start(out: Stream<R>): void; | ||
} | ||
@@ -25,3 +25,3 @@ export interface Aggregator<T, U> extends InternalProducer<U>, OutSender<U> { | ||
insArr: Array<Stream<T>>; | ||
_start: (out: Stream<U>) => void; | ||
_start(out: Stream<U>): void; | ||
} | ||
@@ -89,3 +89,3 @@ export interface Producer<T> { | ||
_hasNoSinks(x: InternalListener<any>, trace: Array<any>): boolean; | ||
private ctor(); | ||
private ctor; | ||
/** | ||
@@ -92,0 +92,0 @@ * Adds a Listener to the Stream. |
{ | ||
"name": "xstream", | ||
"version": "11.4.0", | ||
"version": "11.5.0", | ||
"description": "An extremely intuitive, small, and fast functional reactive stream library for JavaScript", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
Sorry, the diff of this file is too big to display
Sorry, the diff of this file is too big to display
882566
57
6260