Struct Rivers 

pub struct Rivers { /* private fields */ }

Implementations

impl Rivers

pub fn new(events: Vec<Event>) -> Self

Examples found in repository

examples/test.rs (line 16)

async fn main() {
    let events = vec![
        Event::new(vec![0x1], vec![0x2]),
        Event::new(vec![0x3], vec![0x4]),
        Event::new(vec![0x5], vec![0x6]),
    ];

    let rivers = Rivers::new(events)
        .stream("key and value", key_and_value_handler)
        .stream("value only", value_handler);

    rivers.run().await
}

pub fn stream<S, H, T>(self, topic: S, handler: H) -> Self

where S: AsRef<str>, H: Handler<T>, T: FromEvent + Clone + Send + 'static,

Examples found in repository

examples/test.rs (line 17)

async fn main() {
    let events = vec![
        Event::new(vec![0x1], vec![0x2]),
        Event::new(vec![0x3], vec![0x4]),
        Event::new(vec![0x5], vec![0x6]),
    ];

    let rivers = Rivers::new(events)
        .stream("key and value", key_and_value_handler)
        .stream("value only", value_handler);

    rivers.run().await
}

pub async fn run(self)

Examples found in repository

examples/test.rs (line 20)

async fn main() {
    let events = vec![
        Event::new(vec![0x1], vec![0x2]),
        Event::new(vec![0x3], vec![0x4]),
        Event::new(vec![0x5], vec![0x6]),
    ];

    let rivers = Rivers::new(events)
        .stream("key and value", key_and_value_handler)
        .stream("value only", value_handler);

    rivers.run().await
}