import { Observable } from '../Observable'; | |
export function throwError(error, scheduler) { | |
if (!scheduler) { | |
return new Observable(subscriber => subscriber.error(error)); | |
} | |
else { | |
return new Observable(subscriber => scheduler.schedule(dispatch, 0, { error, subscriber })); | |
} | |
} | |
function dispatch({ error, subscriber }) { | |
subscriber.error(error); | |
} | |
//# sourceMappingURL=throwError.js.map |