--- /dev/null
+import { SubscribeOnObservable } from '../observable/SubscribeOnObservable';
+export function subscribeOn(scheduler, delay = 0) {
+ return function subscribeOnOperatorFunction(source) {
+ return source.lift(new SubscribeOnOperator(scheduler, delay));
+ };
+}
+class SubscribeOnOperator {
+ constructor(scheduler, delay) {
+ this.scheduler = scheduler;
+ this.delay = delay;
+ }
+ call(subscriber, source) {
+ return new SubscribeOnObservable(source, this.delay, this.scheduler).subscribe(subscriber);
+ }
+}
+//# sourceMappingURL=subscribeOn.js.map
\ No newline at end of file