Struct AppSink 

pub struct AppSink { /* private fields */ }

An in-process face connecting application code to the forwarding engine.

express() sends an Interest and waits for the matching Data. produce() registers a handler for a name prefix.

Internally uses tokio::sync::mpsc channels — zero-copy Arc<> passing for same-process use.

Implementations

impl AppSink

pub fn new( face_id: FaceId, capacity: usize, ) -> (AppSink, Receiver<OutboundRequest>)

Create a new AppSink and the matching request receiver.

The caller (typically the engine) holds the Receiver and dispatches OutboundRequest messages as they arrive.

pub fn face_id(&self) -> FaceId

pub async fn express(&self, interest: Interest) -> Result<Data, AppError>

Express an Interest and wait for the matching Data.

pub async fn register_prefix<F>( &self, prefix: Name, handler: F, ) -> Result<(), AppError>

where F: Fn(Interest) + Send + Sync + 'static,

Register a handler for Interests matching prefix.