Struct wasmcloud_core::wrpc::TransmitterWithHeaders

pub struct TransmitterWithHeaders { /* private fields */ }

Wrapper around wrpc_transport_nats::Transmitter that includes a async_nats::HeaderMap for passing invocation and trace context.

Trait Implementations

impl Clone for TransmitterWithHeaders

fn clone(&self) -> TransmitterWithHeaders

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for TransmitterWithHeaders

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

Formats the value using the given formatter.

impl Transmitter for TransmitterWithHeaders

type Subject = Subject

type PublishError = PublishError

async fn transmit( &self, subject: Self::Subject, payload: Bytes ) -> Result<(), Self::PublishError>

fn transmit_static( &self, subject: Self::Subject, payload: impl Encode ) -> impl Future<Output = Result<(), Error>> + Send

fn transmit_tuple_dynamic<T>( &self, subject: Self::Subject, values: T ) -> impl Future<Output = Result<(), Error>> + Send

where T: IntoIterator<Item = Value> + Send, <T as IntoIterator>::IntoIter: ExactSizeIterator<Item = Value> + Send,

fn transmit_async<'life0, 'async_trait>( &'life0 self, subject: Self::Subject, value: AsyncValue ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,