import { Observable } from '../Observable';
import { SchedulerLike } from '../types';
import { Subscription } from '../Subscription';
export function scheduleArray<T>(input: ArrayLike<T>, scheduler: SchedulerLike) {
return new Observable<T>(subscriber => {
const sub = new Subscription();
let i = 0;
sub.add(scheduler.schedule(function () {
if (i === input.length) {
subscriber.complete();
return;
}
subscriber.next(input[i++]);
if (!subscriber.closed) {
sub.add(this.schedule());
}
}));
return sub;
});
}
| Name | Type | Size | Permission | Actions |
|---|---|---|---|---|
| scheduleArray.ts | File | 585 B | 0644 |
|
| scheduleIterable.ts | File | 1.22 KB | 0644 |
|
| scheduleObservable.ts | File | 852 B | 0644 |
|
| schedulePromise.ts | File | 655 B | 0644 |
|
| scheduled.ts | File | 1.45 KB | 0644 |
|