airopt-manager/adi-ui/.pnpm-store/v10/files/10/36fcad0ebfb97fc49494152101f977ed6c6d4fed788573b2622bf2370e384bede62e6525ac7526bc0d233e6205d07b38df319140819d0f33d07a63cc15abfc

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));
}