Struct Endpoint

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

Role: the up-L2 publish and subscribe surface over a selected-wire zero-copy transport — typed payloads use transport loans and receive leases directly, with role ergonomics. See the guide.

Front door for zero-copy communication-layer clients.

Implementations

impl<T, P> Endpoint<T, P>

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

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

Creates a zero-copy communication endpoint.

pub fn subscriber(&self, usubscription: Arc<dyn USubscription>) -> Subscriber<T>

Creates the subscribe role over this endpoint’s transport, using the given uSubscription service client.

pub fn publisher(&self) -> Publisher<T, P>

Creates the publish role over this endpoint’s transport and identity.

Trait Implementations

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

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

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

Formats the value using the given formatter.