| Crates.io | rx_core_operator_end_with |
| lib.rs | rx_core_operator_end_with |
| version | 0.2.0 |
| created_at | 2026-01-19 14:02:58.814148+00 |
| updated_at | 2026-01-24 15:05:51.366102+00 |
| description | end_with operator for rx_core |
| homepage | https://github.com/AlexAegis/rx_bevy |
| repository | https://github.com/AlexAegis/rx_bevy |
| max_upload_size | |
| id | 2054659 |
| size | 12,923 |
Emit a value on completion.
cargo run -p rx_core --example operator_end_with_example
let _subscription = (1..=5)
.into_observable()
.end_with(99)
.subscribe(PrintObserver::new("end_with_operator"));
Output:
end_with_operator - next: 1
end_with_operator - next: 2
end_with_operator - next: 3
end_with_operator - next: 4
end_with_operator - next: 5
end_with_operator - next: 99
end_with_operator - completed
end_with_operator - unsubscribed