Trait Source 

pub trait Source: Send {
    // Required method
    fn next(&mut self) -> BoxFut<'_, Option<(String, Payload)>>;
}

External → AimDB data-plane: a stream of inbound frames, drained by pump_source.

Required Methods

fn next(&mut self) -> BoxFut<'_, Option<(String, Payload)>>

Yield the next (topic, payload), or None when the source is done.

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors