WithLatest Operator

Rocket.with_latest — Function

with_latest(sources...)

Creates a with_latest operator, which combines the source Observable with other Observables to create an Observable whose values are calculated from the latest values of each, only when the source emits.

Examples

using Rocket

source = of(1)
subscribe!(source |> with_latest(from(1:5)), logger())
;

# output

[LogActor] Data: (1, 5)
[LogActor] Completed

See also: AbstractOperator, InferableOperator

source