Struct lapin_async::channels::Channels

pub struct Channels { /* fields omitted */ }

Methods

impl Channels

pub fn create(&self, connection: Connection) -> Result<Channel, Error>

pub fn get(&self, id: u16) -> Option<Channel>

pub fn remove(&self, id: u16) -> Result<(), Error>

pub fn receive_method(&self, id: u16, method: AMQPClass) -> Result<(), Error>

pub fn handle_content_header_frame(
    &self,
    id: u16,
    size: u64,
    properties: BasicProperties
) -> Result<(), Error>

pub fn handle_body_frame(&self, id: u16, payload: Vec<u8>) -> Result<(), Error>

pub fn set_closing(&self)

pub fn set_closed(&self) -> Result<(), Error>

pub fn set_error(&self) -> Result<(), Error>

Trait Implementations

impl Default for Channels

fn default() -> Channels

Returns the "default value" for a type.

impl Clone for Channels

fn clone(&self) -> Channels

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Channels

fn fmt(&self, f: &mut Formatter) -> Result

Formats the value using the given formatter.