Struct Publisher

pub struct Publisher<T, P>
where
    T: UOwnedTransport + ?Sized,
    P: LocalUriProvider + ?Sized,
{ /* private fields */ }

Publisher implemented over an owned native-frame transport.

Implementations

impl<T, P> Publisher<T, P>

where T: UOwnedTransport + ?Sized, P: LocalUriProvider + ?Sized,

pub fn new(transport: Arc<T>, uri_provider: Arc<P>) -> Self

Creates a publisher over an owned native-frame transport.

pub async fn publish( &self, resource_id: u16, call_options: CallOptions, payload: Option<UPayload>, ) -> Result<(), PubSubError>

Publishes an owned native-frame message.

impl<T, P> Publisher<T, P>

where T: UOwnedTransport + UHasWire + ?Sized, P: LocalUriProvider + ?Sized,

pub async fn publish_typed<Payload>( &self, resource_id: u16, call_options: CallOptions, payload: &Payload, ) -> Result<(), PubSubError>

where T::Wire: UWireEncode<Payload>,

Publishes a typed payload using the transport endpoint’s selected wire.

Trait Implementations

impl<T, P> Debug for Publisher<T, P>

where T: UOwnedTransport + ?Sized, P: LocalUriProvider + ?Sized,

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

Formats the value using the given formatter.

impl<T, P> Publisher for Publisher<T, P>

where T: UOwnedTransport + ?Sized, P: LocalUriProvider + ?Sized,

fn publish<'life0, 'async_trait>( &'life0 self, resource_id: u16, call_options: CallOptions, payload: Option<UPayload>, ) -> Pin<Box<dyn Future<Output = Result<(), PubSubError>> + Send + 'async_trait>>

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

Publishes a message to a topic.