Struct AppFace 

pub struct AppFace { /* private fields */ }

In-process NDN face backed by a pair of tokio::sync::mpsc channels.

AppFace is held by the forwarder pipeline; AppHandle is given to the application (library user). The forwarder sends packets to the app via AppFace::send → app_tx; the app sends packets to the forwarder via AppHandle::send → face_tx.

  pipeline            application
  ────────            ───────────
  AppFace::recv()  ←  AppHandle::send()   (face_rx ← face_tx)
  AppFace::send()  →  AppHandle::recv()   (app_tx  → app_rx)

face_rx is wrapped in a Mutex to satisfy the &self requirement of the Face trait; the pipeline’s single-consumer contract means it never actually contends.

Implementations

impl AppFace

pub fn new(id: FaceId, buffer: usize) -> (Self, AppHandle)

Create a linked (AppFace, AppHandle) pair with buffer slots each.

Trait Implementations

impl Face for AppFace

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

Receive a packet sent by the application via AppHandle::send.

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

Forward a packet to the application (readable via AppHandle::recv).

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:///tmp/ndn.sock). Returns None for face types that don’t expose local binding info.

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.