관리-도구
편집 파일: scheduleReadableStreamLike.ts
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); }