import { Observable , Observer } from 'rxjs' ; /**
 * Create an observable from a disposable.
 */ export function fromDisposable < T > ( source ) { return Observable . create ( ( observer ) => { const disposable = source ( e => { observer . next ( e ) ; } ) ; return ( ) => disposable . dispose ( ) ; } ) ; }