pub struct Session { /* private fields */ }
Implementations§
source§impl Session
impl Session
pub fn connection(&self) -> &ConnectionRef
pub fn local_channel_id(&self) -> u16
pub fn remote_channel_id(&self) -> u16
sourcepub fn remote_window_size(&self) -> u32
pub fn remote_window_size(&self) -> u32
Get remote window size
pub fn end(&self) -> impl Future<Output = Result<(), AmqpProtocolError>>
pub fn get_sender_link(&self, name: &str) -> Option<&SenderLink>
pub fn get_sender_link_by_local_handle( &self, hnd: Handle ) -> Option<&SenderLink>
pub fn get_sender_link_by_remote_handle( &self, hnd: Handle ) -> Option<&SenderLink>
pub fn get_receiver_link_by_local_handle( &self, hnd: Handle ) -> Option<&ReceiverLink>
pub fn get_receiver_link_by_remote_handle( &self, hnd: Handle ) -> Option<&ReceiverLink>
sourcepub fn build_sender_link<T: Into<ByteString>, U: Into<ByteString>>(
&self,
name: U,
address: T
) -> SenderLinkBuilder
pub fn build_sender_link<T: Into<ByteString>, U: Into<ByteString>>( &self, name: U, address: T ) -> SenderLinkBuilder
Open sender link
sourcepub fn build_receiver_link<T: Into<ByteString>, U: Into<ByteString>>(
&self,
name: U,
address: T
) -> ReceiverLinkBuilder
pub fn build_receiver_link<T: Into<ByteString>, U: Into<ByteString>>( &self, name: U, address: T ) -> ReceiverLinkBuilder
Open receiver link
sourcepub fn detach_receiver_link(
&self,
handle: Handle,
error: Option<Error>
) -> impl Future<Output = Result<(), AmqpProtocolError>>
pub fn detach_receiver_link( &self, handle: Handle, error: Option<Error> ) -> impl Future<Output = Result<(), AmqpProtocolError>>
Detach receiver link
sourcepub fn detach_sender_link(
&self,
handle: Handle,
error: Option<Error>
) -> impl Future<Output = Result<(), AmqpProtocolError>>
pub fn detach_sender_link( &self, handle: Handle, error: Option<Error> ) -> impl Future<Output = Result<(), AmqpProtocolError>>
Detach sender link
Trait Implementations§
Auto Trait Implementations§
impl Freeze for Session
impl !RefUnwindSafe for Session
impl !Send for Session
impl !Sync for Session
impl Unpin for Session
impl !UnwindSafe for Session
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more