packageDocumentation module import { from as rxjsFrom } from "rxjs/internal/observable/from" ; import { Observable as RxjsObservable } from "rxjs/internal/Observable" ; public export function from < T > ( iterable ) { return rxjsFrom ( iterable ) ; } internal export function toRxjsObservable < T > ( observable ) { return new RxjsObservable ( ( subscriber ) => { observable . subscribe ( subscriber ) ; } ) ; } public export interface Observable < T > extends Subscribable < T > { } public export interface Subscribable < T > { subscribe ( observer ? ) : Subscription ; subscribe ( next , error , complete ) : Subscription ; subscribe ( next , error , complete ? ) : Subscription ; subscribe ( next , error , complete ) : Subscription ; subscribe ( next ? , error ? , complete ? ) : Subscription ; } public export declare type Observer < T > = NextObserver < T > | ErrorObserver < T > | CompletionObserver < T > ; public export interface Unsubscribable { unsubscribe ( ) : void ; } public export interface Subscription extends Unsubscribable { readonly closed : boolean ; unsubscribe ( ) : void ; add ( tearDown ) : void ; } public export interface NextObserver < T > { closed ? : boolean ; next : ( value : T ) => void ; error ? : ( err : any ) => void ; complete ? : ( ) => void ; } public export interface ErrorObserver < T > { closed ? : boolean ; next ? : ( value : T ) => void ; error : ( err : any ) => void ; complete ? : ( ) => void ; } public export interface CompletionObserver < T > { closed ? : boolean ; next ? : ( value : T ) => void ; error ? : ( err : any ) => void ; complete : ( ) => void ; }