@typeheim/fire-rx
Advanced tools
Comparing version 0.0.3 to 0.0.4
{ | ||
"name": "@typeheim/fire-rx", | ||
"version": "0.0.3", | ||
"version": "0.0.4", | ||
"description": "RxJS on steroids", | ||
@@ -32,3 +32,3 @@ "keywords": [ | ||
}, | ||
"gitHead": "bd1ec62535962da31713039df9b9e8731fed3570" | ||
"gitHead": "8f630f1b7fe8be4f03e7cee984c52477ad71354b" | ||
} |
@@ -22,1 +22,7 @@ import { Subscribable } from 'rxjs'; | ||
} | ||
export interface Observer<T> { | ||
closed?: boolean; | ||
next?: (value: T) => void; | ||
error?: (err: any) => void; | ||
complete?: () => void; | ||
} |
@@ -1,4 +0,4 @@ | ||
import { Observable, Observer } from 'rxjs'; | ||
import { Observable } from 'rxjs'; | ||
import { ReadonlyStream } from './ReadonlyStream'; | ||
import { Producer } from '../Contracts/Observables'; | ||
import { Producer, Observer } from '../Contracts/Observables'; | ||
import { Subscribable } from '../Contracts/RxJsInternals'; | ||
@@ -8,3 +8,3 @@ import { StatefulSubject } from './StatefulSubject'; | ||
protected internalSubject: StatefulSubject<T>; | ||
constructor(executor: (state: ProducerState<T>) => void); | ||
constructor(executor: (context: ProducerState<T>) => void); | ||
get isStopped(): boolean; | ||
@@ -11,0 +11,0 @@ get closed(): boolean; |
Sorry, the diff of this file is not supported yet
58671
1020