airopt-manager/adi-ui/.pnpm-store/v10/files/3b/2c998fd85355bc54a5d63bce3aa725e646ce5d3f9506bf9603f24bad8c8338033f88effd61ed99e48ec2187d9804b0235bca2dd37a1a909d9400b6244f4af2

import { executeSchedule } from '../util/executeSchedule';
import { operate } from '../util/lift';
import { createOperatorSubscriber } from './OperatorSubscriber';
export function observeOn(scheduler, delay = 0) {
    return operate((source, subscriber) => {
        source.subscribe(createOperatorSubscriber(subscriber, (value) => executeSchedule(subscriber, scheduler, () => subscriber.next(value), delay), () => executeSchedule(subscriber, scheduler, () => subscriber.complete(), delay), (err) => executeSchedule(subscriber, scheduler, () => subscriber.error(err), delay)));
    });
}
//# sourceMappingURL=observeOn.js.map