scheduleObservable.js 541 B

1234567891011
  1. "use strict";
  2. Object.defineProperty(exports, "__esModule", { value: true });
  3. exports.scheduleObservable = void 0;
  4. var innerFrom_1 = require("../observable/innerFrom");
  5. var observeOn_1 = require("../operators/observeOn");
  6. var subscribeOn_1 = require("../operators/subscribeOn");
  7. function scheduleObservable(input, scheduler) {
  8. return innerFrom_1.innerFrom(input).pipe(subscribeOn_1.subscribeOn(scheduler), observeOn_1.observeOn(scheduler));
  9. }
  10. exports.scheduleObservable = scheduleObservable;
  11. //# sourceMappingURL=scheduleObservable.js.map