ofScheduled

ofScheduled

Signature - source.ts#L787

Copyfunction ofScheduled<T>(schedule: ScheduleFunction, ...items: T[]): Source<T>
1
function ofScheduled<T>(schedule: ScheduleFunction, ...items: T[]): Source<T>

Creates a source which will emit the given items 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

CopyScheduleFunction
1
ScheduleFunction

CopyT[]
1
T[]

Returns

CopySource<T>
1
Source<T>

Example Usage

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

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

See Also

• of

• fromArrayScheduled