Struct ntex_amqp::SenderLink [−][src]
pub struct SenderLink { /* fields omitted */ }
Implementations
pub fn send<T>(
&self,
body: T
) -> impl Future<Output = Result<Disposition, AmqpProtocolError>> where
T: Into<TransferBody>,
pub fn send_with_tag<T>(
&self,
body: T,
tag: Bytes
) -> impl Future<Output = Result<Disposition, AmqpProtocolError>> where
T: Into<TransferBody>,
pub fn send_no_block<T>(&self, body: T) -> Result<Bytes, AmqpProtocolError> where
T: Into<TransferBody>,
pub fn send_no_block_with_tag<T>(
&self,
body: T,
tag: Bytes
) -> Result<Bytes, AmqpProtocolError> where
T: Into<TransferBody>,
pub fn close_with_error<E>(
&self,
error: E
) -> impl Future<Output = Result<(), AmqpProtocolError>> where
Error: From<E>,
pub fn on_disposition<F>(&self, f: F) where
F: Fn(Bytes, Result<Disposition, AmqpProtocolError>) + 'static,
Trait Implementations
Auto Trait Implementations
impl !RefUnwindSafe for SenderLink
impl !Send for SenderLink
impl !Sync for SenderLink
impl Unpin for SenderLink
impl !UnwindSafe for SenderLink
Blanket Implementations
Mutably borrows from an owned value. Read more
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more