Sha256: f8fa90a2b69a4ea7e9cda1431d9477dda7415e0befae92aeff93c9e81ea7a190
Contents?: true
Size: 828 Bytes
Versions: 49
Compression:
Stored size: 828 Bytes
Contents
export interface NextObserver<T> {
closed?: boolean;
next: (value: T) => void;
error?: (err: any) => void;
complete?: () => void;
}
export interface ErrorObserver<T> {
closed?: boolean;
next?: (value: T) => void;
error: (err: any) => void;
complete?: () => void;
}
export interface CompletionObserver<T> {
closed?: boolean;
next?: (value: T) => void;
error?: (err: any) => void;
complete: () => void;
}
export type PartialObserver<T> = NextObserver<T> | ErrorObserver<T> | CompletionObserver<T>;
export interface Observer<T> {
closed?: boolean;
next: (value: T) => void;
error: (err: any) => void;
complete: () => void;
}
export const empty: Observer<any> = {
closed: true,
next(value: any): void { /* noop */},
error(err: any): void { throw err; },
complete(): void { /*noop*/ }
};
Version data entries
49 entries across 49 versions & 4 rubygems