Struct ntex_amqp::ReceiverLink

pub struct ReceiverLink { /* private fields */ }

Implementations

impl ReceiverLink

pub fn name(&self) -> &ByteString

pub fn handle(&self) -> Handle

pub fn remote_handle(&self) -> Handle

pub fn credit(&self) -> u32

pub fn session(&self) -> &Session

pub fn is_closed(&self) -> bool

pub fn error(&self) -> Option<&Error>

pub fn set_link_credit(&self, credit: u32)

pub fn set_max_message_size(&self, size: u64)

Set max message size.

pub fn has_deliveries(&self) -> bool

Check deliveries

pub fn get_delivery(&self) -> Option<(Delivery, Transfer)>

Get delivery

pub fn send_disposition(&self, disp: Disposition)

Send disposition frame

pub fn close(&self) -> impl Future<Output = Result<(), AmqpProtocolError>>

pub fn close_with_error<E>( &self, error: E ) -> impl Future<Output = Result<(), AmqpProtocolError>>

where Error: From<E>,

pub async fn recv( &self ) -> Option<Result<(Delivery, Transfer), AmqpProtocolError>>

Attempt to pull out the next value of this receiver, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

pub fn poll_recv( &self, cx: &mut Context<'_> ) -> Poll<Option<Result<(Delivery, Transfer), AmqpProtocolError>>>

Attempt to pull out the next value of this receiver, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

Trait Implementations

impl Clone for ReceiverLink

fn clone(&self) -> ReceiverLink

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for ReceiverLink

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

Formats the value using the given formatter.

impl Hash for ReceiverLink

fn hash<H: Hasher>(&self, state: &mut H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for ReceiverLink

fn eq(&self, other: &ReceiverLink) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Stream for ReceiverLink

type Item = Result<(Delivery, Transfer), AmqpProtocolError>

Values yielded by the stream.

fn poll_next( self: Pin<&mut Self>, cx: &mut Context<'_> ) -> Poll<Option<Self::Item>>

Attempt to pull out the next value of this stream, registering the current task for wakeup if the value is not yet available, and returning None if the stream is exhausted.

fn size_hint(&self) -> (usize, Option<usize>)

Returns the bounds on the remaining length of the stream.

impl Eq for ReceiverLink