subject/
subject.rs

1//! `Subject` example
2//!
3//! This example demonstrates the usage of the `Subject` in the `rxr` library.
4//!
5//! The `Subject` acts as both an observer and observable in reactive programming,
6//! broadcasting values to multiple observers.
7//!
8//! To run this example, execute `cargo run --example subject`.
9
10use std::fmt::Display;
11
12use rxr::{subjects::Subject, subscribe::Subscriber};
13use rxr::{ObservableExt, Observer, Subscribeable};
14
15pub fn create_subscriber<T: Display>(subscriber_id: i32) -> Subscriber<T> {
16    Subscriber::new(
17        move |v| println!("Subscriber #{} emitted: {}", subscriber_id, v),
18        |_| eprintln!("Error"),
19        move || println!("Completed {}", subscriber_id),
20    )
21}
22
23pub fn main() {
24    // Initialize a `Subject` and obtain its emitter and receiver.
25    let (mut emitter, mut receiver) = Subject::emitter_receiver();
26
27    // Registers `Subscriber` 1.
28    receiver.subscribe(create_subscriber(1));
29
30    emitter.next(101); // Emits 101 to registered `Subscriber` 1.
31    emitter.next(102); // Emits 102 to registered `Subscriber` 1.
32
33    // All Observable operators can be applied to the receiver.
34    // Registers mapped `Subscriber` 2.
35    receiver
36        .clone() // Shallow clone: clones only the pointer to the `Subject` object.
37        .map(|v| format!("mapped {}", v))
38        .subscribe(create_subscriber(2));
39
40    // Registers `Subscriber` 3.
41    receiver.subscribe(create_subscriber(3));
42
43    // Emits 103 to registered `Subscriber`'s 1, 2 and 3.
44    emitter.next(103);
45
46    // Calls `complete` on registered `Subscriber`'s 1, 2 and 3.
47    emitter.complete();
48
49    // Subscriber 4: post-completion subscribe, completes immediately.
50    receiver.subscribe(create_subscriber(4));
51
52    // Called post-completion, does not emit.
53    emitter.next(104);
54}
subject/subject.rs

subject/
subject.rs
