Struct Queryable 

pub struct Queryable { /* private fields */ }

A queryable endpoint — receives Interests and lets the application reply.

Implementations

impl Queryable

pub async fn connect( socket: impl AsRef<Path>, prefix: impl Into<Name>, ) -> Result<Self, AppError>

Connect to an external router and register a prefix.

pub fn from_handle(handle: InProcHandle, prefix: Name) -> Self

Create from an in-process InProcHandle (embedded engine).

pub fn prefix(&self) -> &Name

The registered prefix.

pub async fn recv(&self) -> Option<Query>

Receive the next query. Returns None when the connection closes.

Each returned Query carries a sender so the application can reply asynchronously — even from a different task.

pub async fn serve<F, Fut>(&self, handler: F) -> Result<(), AppError>

where F: Fn(Interest) -> Fut + Send + Sync, Fut: Future<Output = Option<Bytes>> + Send,

Run a query handler loop.

The handler receives each Interest and returns Some(wire_data) to respond or None to silently drop.