operator_delay

The delay operator shifts upstream values forward in time by a specified duration.

Upstream completion and cancellation can happen instantly if there are no pending delayed values, otherwise it will complete or cancel once all delayed values have been emitted.

Upstream errors are immediately propagated downstream, cancelling any pending delayed values.

See Also

• SubscribeOnOperator - Schedule upstream subscription on the provided scheduler.
• AdsrOperator - Convert trigger signals into an ADSR envelope driven by the scheduler.
• FallbackWhenSilentOperator - Emit a fallback value on ticks where the source stayed silent.

Example

cargo run -p rx_core --example operator_delay_example

let mut executor = MockExecutor::new_with_logging();
let scheduler = executor.get_scheduler_handle();
let _subscription = (1..=3)
    .into_observable()
    .delay(Duration::from_millis(1000), scheduler)
    .subscribe(PrintObserver::new("delay_operator"));
executor.tick(Duration::from_millis(1000));

Output:

Ticking... (1s)
delay_operator - next: 1
delay_operator - next: 2
delay_operator - next: 3
delay_operator - completed
delay_operator - unsubscribed