Struct Subscriber 

pub struct Subscriber { /* private fields */ }

A subscription to a sync group.

Receives Samples as peers publish new data.

Implementations

impl Subscriber

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

Connect to a router and subscribe to a sync group prefix.

Uses SVS as the sync protocol. The subscriber registers the group prefix and begins receiving updates from peers.

pub async fn connect_with_config( socket: impl AsRef<Path>, group_prefix: impl Into<Name>, config: SubscriberConfig, ) -> Result<Self, AppError>

Connect with explicit configuration.

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

Connect to a router and subscribe to a sync group using PSync.

Identical to connect but uses PSync instead of SVS. Use this when peers in the group also use PSync.

pub async fn connect_psync_with_config( socket: impl AsRef<Path>, group_prefix: impl Into<Name>, psync_config: PSyncConfig, ) -> Result<Self, AppError>

Connect with PSync and explicit configuration.

pub fn from_connection( conn: NdnConnection, group: Name, local_name: Name, config: SubscriberConfig, ) -> Result<Self, AppError>

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

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

Receive the next sample. Returns None when the subscription ends.