import { Subscription } from './Subscription'; export interface Observable { subscribe: (next: (value: T) => void, fail?: (err: Error) => void, comp?: () => void) => Subscription; }