Struct oasis_amqp::proto::Client

pub struct Client { /* fields omitted */ }

Implementations

impl Client

pub async fn connect<A: ToSocketAddrs>(addr: A) -> Result<Self, ()>

pub async fn login(&mut self, user: &str, password: &str) -> Result<(), ()>

Login with the given username and password

Currently this only supports SASL PLAIN login.

pub async fn open(&mut self, container_id: &str) -> Result<(), ()>

pub async fn begin(&mut self) -> Result<(), ()>

pub async fn attach(&mut self, attach: Attach<'_>) -> Result<(), ()>

pub async fn flow(&mut self, flow: Flow<'_>) -> Result<(), ()>

pub async fn transfer(
    &mut self,
    transfer: Transfer,
    message: Message<'_>
) -> Result<(), ()>

pub async fn next(&mut self) -> Option<Result<BytesFrame, Error>>