import { Observable } from '../Observable';
import { SchedulerLike } from '../types';
import { subscribeToArray } from '../util/subscribeToArray';
import { scheduleArray } from '../scheduled/scheduleArray';
export function fromArray<T>(input: ArrayLike<T>, scheduler?: SchedulerLike) {
if (!scheduler) {
return new Observable<T>(subscribeToArray(input));
} else {
return scheduleArray(input, scheduler);
}
}
| Name | Type | Size | Permission | Actions |
|---|---|---|---|---|
| dom | Folder | 0755 |
|
|
| ConnectableObservable.ts | File | 5.42 KB | 0644 |
|
| SubscribeOnObservable.ts | File | 1.59 KB | 0644 |
|
| bindCallback.ts | File | 15.9 KB | 0644 |
|
| bindNodeCallback.ts | File | 15.41 KB | 0644 |
|
| combineLatest.ts | File | 21.95 KB | 0644 |
|
| concat.ts | File | 9.43 KB | 0644 |
|
| defer.ts | File | 2.53 KB | 0644 |
|
| empty.ts | File | 2.21 KB | 0644 |
|
| forkJoin.ts | File | 9.49 KB | 0644 |
|
| from.ts | File | 3.06 KB | 0644 |
|
| fromArray.ts | File | 423 B | 0644 |
|
| fromEvent.ts | File | 10.38 KB | 0644 |
|
| fromEventPattern.ts | File | 7.14 KB | 0644 |
|
| fromIterable.ts | File | 511 B | 0644 |
|
| fromObservable.ts | File | 485 B | 0644 |
|
| fromPromise.ts | File | 439 B | 0644 |
|
| generate.ts | File | 12.55 KB | 0644 |
|
| iif.ts | File | 3.22 KB | 0644 |
|
| interval.ts | File | 2.53 KB | 0644 |
|
| merge.ts | File | 9.94 KB | 0644 |
|
| never.ts | File | 1.16 KB | 0644 |
|
| of.ts | File | 4.77 KB | 0644 |
|
| onErrorResumeNext.ts | File | 3.83 KB | 0644 |
|
| pairs.ts | File | 3.06 KB | 0644 |
|
| partition.ts | File | 2.61 KB | 0644 |
|
| race.ts | File | 5.03 KB | 0644 |
|
| range.ts | File | 2.28 KB | 0644 |
|
| throwError.ts | File | 2.2 KB | 0644 |
|
| timer.ts | File | 3.32 KB | 0644 |
|
| using.ts | File | 3.04 KB | 0644 |
|
| zip.ts | File | 12.06 KB | 0644 |
|