airopt-manager/adi-ui/.pnpm-store/v10/files/6e/89df357313f72f20a311c79606e8eaaeca8d84265efc44248d2125b731c43886f19892e685a8c3766f241c8aebb1e2b800ab26b6d79fa7bb798ddaf8f982c2

import { SchedulerLike, ReadableStreamLike } from '../types';
import { Observable } from '../Observable';
import { scheduleAsyncIterable } from './scheduleAsyncIterable';
import { readableStreamLikeToAsyncGenerator } from '../util/isReadableStreamLike';

export function scheduleReadableStreamLike<T>(input: ReadableStreamLike<T>, scheduler: SchedulerLike): Observable<T> {
  return scheduleAsyncIterable(readableStreamLikeToAsyncGenerator(input), scheduler);
}