Struct AckSender

Source

pub struct AckSender<A = LocalAdapter>where
    A: Adapter,
{ /* private fields */ }

Expand description

Re-exported public API. An Extractor to send an ack response corresponding to the current event. If the client sent a normal message without expecting an ack, the ack callback will do nothing.

It is generic over the Adapter type. If you plan to use it with another adapter than the default, make sure to have a handler that is generic over the adapter type.

AckSender

Struct AckSender Copy item path

Implementations§

impl<A> AckSender<A>where A: Adapter,

pub fn send<T>(self, data: &T) -> Result<(), SendError>where T: Serialize + ?Sized,

Trait Implementations§

impl<A> FromMessageParts<A> for AckSender<A>where A: Adapter,

type Error = Infallible

fn from_message_parts( s: &Arc<Socket<A>>, _: &mut Value, ack_id: &Option<i64>, ) -> Result<AckSender<A>, Infallible>

Auto Trait Implementations§

impl<A = LocalAdapter> !RefUnwindSafe for AckSender<A>

impl<A = LocalAdapter> !UnwindSafe for AckSender<A>

impl<A> Freeze for AckSender<A>

impl<A> Send for AckSender<A>

impl<A> Sync for AckSender<A>

impl<A> Unpin for AckSender<A>

impl<A> UnsafeUnpin for AckSender<A>

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DTwhere ST: ?Sized, DT: ?Sized,

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DTwhere ST: ?Sized, DT: ?Sized,

impl<T> From<T> for T

fn from(t: T) -> T

impl<A, T> FromMessage<A, ViaParts> for Twhere T: FromMessageParts<A>, A: Adapter,

type Error = <T as FromMessageParts<A>>::Error

fn from_message( s: Arc<Socket<A>>, v: Value, ack_id: Option<i64>, ) -> Result<T, <T as FromMessage<A, ViaParts>>::Error>

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> Read<Exclusive, BecauseExclusive> for Twhere T: ?Sized,

impl<T> Same for T

type Output = T

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<V, T> VZip<V> for Twhere V: MultiLane<T>,

fn vzip(self) -> V

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self>

Struct AckSender

impl<A> AckSender<A>
where A: Adapter,

pub fn send<T>(self, data: &T) -> Result<(), SendError>
where T: Serialize + ?Sized,

impl<A> FromMessageParts<A> for AckSender<A>
where A: Adapter,

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
where ST: ?Sized, DT: ?Sized,

impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
where ST: ?Sized, DT: ?Sized,

impl<A, T> FromMessage<A, ViaParts> for T
where T: FromMessageParts<A>, A: Adapter,

impl<T, U> Into<U> for T
where U: From<T>,

impl<T> Read<Exclusive, BecauseExclusive> for T
where T: ?Sized,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,