Struct Publisher

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

Publisher implemented over a selected-wire zero-copy transport.

Implementations

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

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

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

Creates a publisher over a zero-copy transport.

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

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

pub async fn publish_stable<Payload>( &self, resource_id: u16, call_options: CallOptions, init: impl for<'payload> FnOnce(&'payload mut Payload) + Send, ) -> Result<(), PubSubError>

where T::Wire: UWirePayload<Payload>, <T::Wire as UWirePayload<Payload>>::Codec: LoanPayload<Payload> + Send + Sync,

Publishes an initialized stable payload using the transport endpoint’s selected wire.

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

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

pub async fn publish_uninit_stable<Payload>( &self, resource_id: u16, call_options: CallOptions, init: impl for<'payload> FnOnce(StablePayloadInitContext<'payload, Payload>) -> Result<InitializedStablePayload<'payload, Payload>, UWireError> + Send, ) -> Result<(), PubSubError>

where T::Wire: UWirePayload<Payload, Codec = StableContainerPayload<Payload>>, Payload: StablePayloadInit + Send,

Publishes a stable payload by initializing it directly in uninitialized transport storage.

Trait Implementations

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

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

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

Formats the value using the given formatter.