1 /** PURE_IMPORTS_START _Observable,_from,_empty PURE_IMPORTS_END */
2 import { Observable } from '../Observable';
3 import { from } from './from';
4 import { EMPTY } from './empty';
5 export function using(resourceFactory, observableFactory) {
6 return new Observable(function (subscriber) {
9 resource = resourceFactory();
12 subscriber.error(err);
17 result = observableFactory(resource);
20 subscriber.error(err);
23 var source = result ? from(result) : EMPTY;
24 var subscription = source.subscribe(subscriber);
26 subscription.unsubscribe();
28 resource.unsubscribe();
33 //# sourceMappingURL=using.js.map