fromArrayScheduled

fromArrayScheduled

Signature - source.ts#L693

Copyfunction fromArrayScheduled<T>(
    array: ArrayLike<T>,
    schedule: ScheduleFunction,
): Source<T>
1
function fromArrayScheduled<T>(
2
    array: ArrayLike<T>,
3
    schedule: ScheduleFunction,
4
): Source<T>

Creates a source which will emit the items in the given array according to the given schedule function. For example, if the schedule function acts as a 1s interval then the items will be emitted on a 1s interval.

Parameters

CopyArrayLike<T>
1
ArrayLike<T>

CopyScheduleFunction
1
ScheduleFunction

Returns

CopySource<T>
1
Source<T>

Example Usage

Copyimport {
    fromArrayScheduled,
    ScheduleInterval,
    pipe,
    subscribe
} from '@microstream/core';

const scheduleFunction = ScheduleInterval(1000);
pipe(
    fromArrayScheduled([2, 4, 6], scheduleFunction),
    subscribe(console.log)
)
// 1s -> Push(2)
// 2s -> Push(4)
// 3s -> Push(6), End
1
import {
2
    fromArrayScheduled,
3
    ScheduleInterval,
4
    pipe,
5
    subscribe
6
} from '@microstream/core';
7
8
const scheduleFunction = ScheduleInterval(1000);
9
pipe(
10
    fromArrayScheduled([2, 4, 6], scheduleFunction),
11
    subscribe(console.log)
12
)
13
// 1s -> Push(2)
14
// 2s -> Push(4)
15
// 3s -> Push(6), End

See Also

• fromArray

• ofScheduled