function makeObservable(input, cancel) {
  let observable = from(input);
  return Observable.create(observer => {
    let subscription = observable.subscribe(observer);
    return function unsubscribe() {
      if (typeof cancel === 'function') cancel();
      subscription.unsubscribe();
    }
  });
}
// create observable from a `observable input` and a `cancel function`
create observable from a `observable input` and a `cancel function`
create observable from a ` observable input ` and a ` cancel function `
function makeObservable(input, cancel) {
  let observable = from(input);
  return Observable.create(observer => {
    let subscription = observable.subscribe(observer);
    return function unsubscribe() {
      if (typeof cancel === 'function') cancel();
      subscription.unsubscribe();
    }
  });
}
function makeObservable ( input , cancel ) { let observable = from ( input ) ; return Observable . create ( observer => { let subscription = observable . subscribe ( observer ) ; return function unsubscribe ( ) { if ( typeof cancel === 'function' ) cancel ( ) ; subscription . unsubscribe ( ) ; } } ) ; }
create observable from a `observable input` and a `cancel function`
create observable from a ` observable input ` and a ` cancel function `