Struct UWireTransport

pub struct UWireTransport<TCore, W, C>
where
    W: UWire,
    C: UWireMetadataCodecFor<W>,
{ /* private fields */ }

Generic selected-wire transport adapter.

Implementations

impl<TCore, W, C> UWireTransport<TCore, W, C>

where W: UWire, C: UWireMetadataCodecFor<W>,

pub fn new(core: TCore, wire: W, metadata_codec: C) -> Self

Creates an adapter around a transport core, selected wire marker, and metadata codec.

pub fn with_wire_and_metadata_codec( core: TCore, wire: W, metadata_codec: C, ) -> Self

Creates an adapter with an explicit selected wire and metadata codec.

pub fn core(&self) -> &TCore

Returns the wrapped physical transport core.

pub fn core_mut(&mut self) -> &mut TCore

Returns the wrapped physical transport core mutably.

pub fn metadata_codec(&self) -> &C

Returns the selected metadata codec.

pub fn into_parts(self) -> (TCore, W, C)

Consumes the adapter and returns the wrapped core, selected wire, and metadata codec.

Trait Implementations

impl<TCore, W, C> Debug for UWireTransport<TCore, W, C>

where W: UWire, C: UWireMetadataCodecFor<W>,

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

Formats the value using the given formatter.

impl<TCore, W, C> UHasWire for UWireTransport<TCore, W, C>

where W: UWire, C: UWireMetadataCodecFor<W>,

type Wire = W

Concrete selected wire type.

fn wire(&self) -> &Self::Wire

Returns the selected wire marker/value.

impl<TCore, W, C> UOwnedTransportImpl for UWireTransport<TCore, W, C>

where TCore: UOwnedTransportCore, W: UWire + Send + Sync + 'static, C: UWireMetadataCodecFor<W> + Clone + Send + Sync + 'static,

fn send_validated_owned<'life0, 'async_trait>( &'life0 self, frame: UOwnedFrame, ) -> Pin<Box<dyn Future<Output = Result<(), UStatus>> + Send + 'async_trait>>

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

Sends an already validated owned frame.

fn receive_validated_owned<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, source_filter: &'life1 UUri, sink_filter: Option<&'life2 UUri>, ) -> Pin<Box<dyn Future<Output = Result<UOwnedFrame, UStatus>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Receives one matching owned frame from transports that support pull receive.

fn register_validated_owned_listener<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, source_filter: &'life1 UUri, sink_filter: Option<&'life2 UUri>, listener: Arc<dyn UOwnedListener>, ) -> Pin<Box<dyn Future<Output = Result<(), UStatus>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Registers an owned listener after public filter validation.

fn unregister_validated_owned_listener<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, source_filter: &'life1 UUri, sink_filter: Option<&'life2 UUri>, listener: Arc<dyn UOwnedListener>, ) -> Pin<Box<dyn Future<Output = Result<(), UStatus>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Unregisters an owned listener after public filter validation.

impl<TCore, W, C> USelectedWireZeroCopyTransport for UWireTransport<TCore, W, C>

where TCore: UZeroCopyTransportCore, W: UWire + Send + Sync + 'static, C: UWireMetadataCodecFor<W> + Clone + Send + Sync + 'static,

type MetadataCodec = C

Metadata codec used with the selected wire.

impl<TCore, W, C> UZeroCopyTransportImpl for UWireTransport<TCore, W, C>

where TCore: UZeroCopyTransportCore, W: UWire + Send + Sync + 'static, C: UWireMetadataCodecFor<W> + Clone + Send + Sync + 'static,

type Tx = <TCore as UZeroCopyTransportCore>::Tx

Transport-specific transmit loan type.

type Rx = UWireRx<<TCore as UZeroCopyTransportCore>::Rx, W, C>

Transport-specific receive lease type.

fn loan_validated_tx<'life0, 'async_trait>( &'life0 self, spec: UTxLoanSpec, ) -> Pin<Box<dyn Future<Output = Result<Self::Tx, UStatus>> + Send + 'async_trait>>

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

Reserves transmit storage for a validated frame loan spec.

fn send_validated_zero_copy<'life0, 'async_trait>( &'life0 self, buffer: Self::Tx, ) -> Pin<Box<dyn Future<Output = Result<(), UStatus>> + Send + 'async_trait>>

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

Commits a validated transmit loan.

fn receive_validated_zero_copy<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, source_filter: &'life1 UUri, sink_filter: Option<&'life2 UUri>, ) -> Pin<Box<dyn Future<Output = Result<Self::Rx, UStatus>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Receives one matching zero-copy frame from transports that support pull receive.

fn register_validated_zero_copy_listener<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, source_filter: &'life1 UUri, sink_filter: Option<&'life2 UUri>, listener: Arc<dyn UZeroCopyListener<Self::Rx>>, ) -> Pin<Box<dyn Future<Output = Result<(), UStatus>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Registers a zero-copy listener after public filter validation.

fn unregister_validated_zero_copy_listener<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, source_filter: &'life1 UUri, sink_filter: Option<&'life2 UUri>, listener: Arc<dyn UZeroCopyListener<Self::Rx>>, ) -> Pin<Box<dyn Future<Output = Result<(), UStatus>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Unregisters a zero-copy listener after public filter validation.

impl<TCore, W, C> UZeroCopyUninitTransportImpl for UWireTransport<TCore, W, C>

where TCore: UZeroCopyUninitTransportCore, W: UWire + Send + Sync + 'static, C: UWireMetadataCodecFor<W> + Clone + Send + Sync + 'static,

type UninitTx = <TCore as UZeroCopyUninitTransportCore>::UninitTx

Transport-specific uninitialized transmit loan type.

fn loan_validated_uninit_tx<'life0, 'async_trait>( &'life0 self, spec: UTxLoanSpec, ) -> Pin<Box<dyn Future<Output = Result<Self::UninitTx, UStatus>> + Send + 'async_trait>>

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

Reserves uninitialized transmit storage for a validated frame loan spec.