operator_first

Emit only the first value, then complete.

See Also

• TakeOperator - Emit only the first n values, then complete.
• FindOperator - Emit the first value that matches a predicate.
• ElementAtOperator - Emit the value at the given index then complete.
• FindIndexOperator - Emit the index of the first value that matches a predicate.

Example

cargo run -p rx_core --example operator_first_example

let _subscription = (1..=5)
    .into_observable()
    .first()
    .subscribe(PrintObserver::new("first_operator"));

Output:

first_operator - next: 1
first_operator - completed
first_operator - unsubscribed