Struct BlockingForwarderClient 

pub struct BlockingForwarderClient { /* private fields */ }

Synchronous (blocking) client for communicating with a running ndn-fwd.

Wraps ForwarderClient with a private Tokio runtime so callers do not need to manage an async runtime. All methods block the calling thread.

Implementations

impl BlockingForwarderClient

pub fn connect(face_socket: impl AsRef<Path>) -> Result<Self, ForwarderError>

Connect to the forwarder’s face socket (blocking).

Automatically attempts SHM data plane; falls back to Unix socket.

Errors

Returns ForwarderError if the socket is unreachable or the connection handshake fails.

pub fn connect_unix_only( face_socket: impl AsRef<Path>, ) -> Result<Self, ForwarderError>

Connect using only the Unix socket for data (no SHM attempt).

pub fn send(&self, pkt: Bytes) -> Result<(), ForwarderError>

Send a raw NDN packet (blocking).

pub fn recv(&self) -> Option<Bytes>

Receive a raw NDN packet (blocking).

Returns None if the forwarder connection is closed.

pub fn register_prefix(&self, prefix: &Name) -> Result<(), ForwarderError>

Register a prefix with the forwarder (blocking).

pub fn unregister_prefix(&self, prefix: &Name) -> Result<(), ForwarderError>

Unregister a prefix from the forwarder (blocking).

pub fn is_shm(&self) -> bool

Whether this client is using SHM for data transport.

pub fn is_dead(&self) -> bool

Whether the forwarder connection has been lost.

pub fn close(self)

Gracefully tear down the client (blocking).