asteroid_mq_model::connection

Trait EdgeNodeConnection

Source 
pub trait EdgeNodeConnection:
    Send
    + 'static
    + Stream<Item = Result<EdgePayload, EdgeConnectionError>>
    + Sink<EdgePayload, Error = EdgeConnectionError> { }

Implementorsยง