@typeheim/fire-rx
Advanced tools
Comparing version 0.0.7 to 0.0.8
export * from './src/Contracts/Observables'; | ||
export * from './src/Contracts/Streams'; | ||
export * from './src/Decorators/OnDestroyHooks'; | ||
@@ -9,2 +10,3 @@ export * from './src/Observables/AggregateStream'; | ||
export * from './src/Observables/ReadonlyStream'; | ||
export * from './src/Observables/LazyLoadStream'; | ||
export * from './src/Observables/StatefulStream'; | ||
@@ -11,0 +13,0 @@ export * from './src/Observables/StatefulSubject'; |
@@ -14,2 +14,3 @@ "use strict"; | ||
__exportStar(require("./src/Contracts/Observables"), exports); | ||
__exportStar(require("./src/Contracts/Streams"), exports); | ||
__exportStar(require("./src/Decorators/OnDestroyHooks"), exports); | ||
@@ -22,2 +23,3 @@ __exportStar(require("./src/Observables/AggregateStream"), exports); | ||
__exportStar(require("./src/Observables/ReadonlyStream"), exports); | ||
__exportStar(require("./src/Observables/LazyLoadStream"), exports); | ||
__exportStar(require("./src/Observables/StatefulStream"), exports); | ||
@@ -24,0 +26,0 @@ __exportStar(require("./src/Observables/StatefulSubject"), exports); |
{ | ||
"name": "@typeheim/fire-rx", | ||
"version": "0.0.7", | ||
"version": "0.0.8", | ||
"description": "RxJS on steroids", | ||
@@ -32,3 +32,3 @@ "keywords": [ | ||
}, | ||
"gitHead": "538216dd304f287daa128a915c6b3676d1e52197" | ||
"gitHead": "50b6dd8a9cf718a7e5b9dd94673a91ffb71c2964" | ||
} |
@@ -1,4 +0,4 @@ | ||
import { Observer } from '../Contracts/Observables'; | ||
import { StatefulSubject } from './StatefulSubject'; | ||
import { ReactiveStream } from './ReactiveStream'; | ||
import { StreamContext } from '../Contracts/Streams'; | ||
export declare class StatefulStream<T> extends ReactiveStream<T> { | ||
@@ -13,9 +13,1 @@ protected sourceSubject: StatefulSubject<T>; | ||
} | ||
export interface StreamContext<T> { | ||
next: (value?: T) => void; | ||
stop: () => void; | ||
fail: (error: any) => void; | ||
isFinished: () => boolean; | ||
isFailed: () => boolean; | ||
subscribe: (observer: ((value: T) => void) | Observer<T>) => void; | ||
} |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
68780
54
1205