initial commit: scaffolding

1 files changed, 8 insertions, 0 deletions

diff --git a/node_modules/rxjs/src/internal/scheduled/scheduleObservable.ts b/node_modules/rxjs/src/internal/scheduled/scheduleObservable.ts
new file mode 100644
index 0000000..29ba3b5
--- /dev/null
+++ b/node_modules/rxjs/src/internal/scheduled/scheduleObservable.ts
@@ -0,0 +1,8 @@
+import { innerFrom } from '../observable/innerFrom';
+import { observeOn } from '../operators/observeOn';
+import { subscribeOn } from '../operators/subscribeOn';
+import { InteropObservable, SchedulerLike } from '../types';
+
+export function scheduleObservable<T>(input: InteropObservable<T>, scheduler: SchedulerLike) {
+  return innerFrom(input).pipe(subscribeOn(scheduler), observeOn(scheduler));
+}