Struct StreamFace 

pub struct StreamFace<R, W, C: Clone> { /* private fields */ }

Generic stream-based NDN face.

Wraps any async read/write pair with a codec into a full Face implementation. The stream is split into independent read and write halves, each behind its own Mutex:

• reader: locked only by the face’s receive task (single consumer, never actually contends).
• writer: locked by whichever pipeline task calls send(), serialising concurrent sends on the same stream.

The lp_encode flag controls whether send() wraps outgoing packets in NDNLPv2 LpPacket framing before writing. Network-facing transports (TCP, Serial) set this to true; local transports (Unix) set it to false.

Implementations

impl<R, W, C: Clone> StreamFace<R, W, C>

pub fn new( id: FaceId, kind: FaceKind, lp_encode: bool, remote_uri: Option<String>, local_uri: Option<String>, reader: R, writer: W, codec: C, ) -> Self

Create a new StreamFace from pre-split read/write halves.

Trait Implementations

impl<R, W, C> Face for StreamFace<R, W, C>

where R: AsyncRead + Unpin + Send + Sync + 'static, W: AsyncWrite + Unpin + Send + Sync + 'static, C: Decoder<Item = Bytes, Error = Error> + Encoder<Bytes, Error = Error> + Clone + Send + Sync + 'static,

fn id(&self) -> FaceId

fn kind(&self) -> FaceKind

fn remote_uri(&self) -> Option<String>

Remote URI (e.g. udp4://192.168.1.1:6363). Returns None for face types that don’t have a meaningful remote endpoint.

fn local_uri(&self) -> Option<String>

Local URI (e.g. unix:///run/nfd/nfd.sock). Returns None for face types that don’t expose local binding info.

async fn recv(&self) -> Result<Bytes, FaceError>

Receive the next packet. Blocks until a packet arrives or the face closes.

async fn send(&self, pkt: Bytes) -> Result<(), FaceError>

Send a packet. Must not block the caller; use internal buffering.

fn recv_with_addr( &self, ) -> impl Future<Output = Result<(Bytes, Option<FaceAddr>), FaceError>> + Send

Receive the next packet together with the link-layer sender address.

fn link_type(&self) -> LinkType

Link type of this face.