zen-observable-ts
Advanced tools
Comparing version 0.2.0 to 0.3.0
import { ZenObservable } from './types'; | ||
export { ZenObservable }; | ||
declare global { | ||
interface SymbolConstructor { | ||
observable: symbol; | ||
} | ||
export declare type Observer<T> = ZenObservable.Observer<T>; | ||
export declare type Subscriber<T> = ZenObservable.Subscriber<T>; | ||
export declare type ObservableLike<T> = ZenObservable.ObservableLike<T>; | ||
export declare class Subscription implements ZenObservable.Subscription { | ||
_observer?: ZenObservable.Observer<any>; | ||
_cleanup: () => void; | ||
constructor(observer: ZenObservable.Observer<any>, subscriber: ZenObservable.Subscriber<any>); | ||
readonly closed: boolean; | ||
unsubscribe(): void; | ||
} | ||
export declare class SubscriptionObserver<T> implements ZenObservable.SubscriptionObserver<T> { | ||
private _subscription; | ||
constructor(subscription: Subscription); | ||
readonly closed: boolean; | ||
next(value: T): void; | ||
error(value: T): void; | ||
complete(): void; | ||
} | ||
export default class Observable<T> { | ||
@@ -9,0 +22,0 @@ private _subscriber; |
@@ -75,2 +75,3 @@ "use strict"; | ||
}()); | ||
exports.Subscription = Subscription; | ||
var SubscriptionObserver = (function () { | ||
@@ -146,2 +147,3 @@ function SubscriptionObserver(subscription) { | ||
}()); | ||
exports.SubscriptionObserver = SubscriptionObserver; | ||
var Observable = (function () { | ||
@@ -148,0 +150,0 @@ function Observable(subscriber) { |
import { ZenObservable } from './types'; | ||
export { ZenObservable }; | ||
declare global { | ||
interface SymbolConstructor { | ||
observable: symbol; | ||
} | ||
export declare type Observer<T> = ZenObservable.Observer<T>; | ||
export declare type Subscriber<T> = ZenObservable.Subscriber<T>; | ||
export declare type ObservableLike<T> = ZenObservable.ObservableLike<T>; | ||
export declare class Subscription implements ZenObservable.Subscription { | ||
_observer?: ZenObservable.Observer<any>; | ||
_cleanup: () => void; | ||
constructor(observer: ZenObservable.Observer<any>, subscriber: ZenObservable.Subscriber<any>); | ||
readonly closed: boolean; | ||
unsubscribe(): void; | ||
} | ||
export declare class SubscriptionObserver<T> implements ZenObservable.SubscriptionObserver<T> { | ||
private _subscription; | ||
constructor(subscription: Subscription); | ||
readonly closed: boolean; | ||
next(value: T): void; | ||
error(value: T): void; | ||
complete(): void; | ||
} | ||
export default class Observable<T> { | ||
@@ -9,0 +22,0 @@ private _subscriber; |
@@ -75,2 +75,3 @@ "use strict"; | ||
}()); | ||
exports.Subscription = Subscription; | ||
var SubscriptionObserver = (function () { | ||
@@ -146,2 +147,3 @@ function SubscriptionObserver(subscription) { | ||
}()); | ||
exports.SubscriptionObserver = SubscriptionObserver; | ||
var Observable = (function () { | ||
@@ -148,0 +150,0 @@ function Observable(subscriber) { |
{ | ||
"name": "zen-observable-ts", | ||
"version": "0.2.0", | ||
"version": "0.3.0", | ||
"description": "An Implementation of ES Observables in Typescript", | ||
@@ -5,0 +5,0 @@ "author": "Evans Hauser <evanshauser@gmail.com>", |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
233343
2821