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
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
882566
57
6260