Generate Observable

Rocket.generate — Function

generate(initial::D, condition::C, iterator::I; scheduler::H = AsapScheduler()) where { D, C, I, H <: AbstractScheduler }

Generates an observable sequence by running a state-driven loop producing the sequence's elements, using the specified scheduler to send out observer messages.

Arguments

initial: initial state
condition: condition to terminate generation (upon returning false)
iterator: iteration step function
scheduler: optional, scheduler-like object

Note

iterator object should return objects of the same type as initial.

Examples

using Rocket

source = generate(1, x -> x < 3, x -> x + 1)
subscribe!(source, logger())
;

# output
[LogActor] Data: 1
[LogActor] Data: 2
[LogActor] Completed

source