Struct sep2_client::pubsub::ClientNotifServer

pub struct ClientNotifServer { /* private fields */ }

Available on crate feature pubsub only.

A lightweight IEEE 2030.5 Server for receiving Notification<T> resources from a server for the subscription / notification mechanism.

Implementations

impl ClientNotifServer

pub fn new(addr: impl ToSocketAddrs) -> Result<Self>

Create a new Notification server that listens on the given address

pub fn with_https( self, cert_path: impl AsRef<Path>, pk_path: impl AsRef<Path>, rootca_path: impl AsRef<Path> ) -> Result<Self>

pub fn add<T>( self, path: impl Into<String>, callback: impl RouteCallback<T> ) -> Selfwhere T: SEResource,

Add a route to the server. Given:

• A relative URI of the form “/foo”
• A Fn callback accepting a Notification<T>, where T is the expected [SEResource`] on the route

The RouteCallback trait can be implemented on any threadsafe type, however it is automatically implemented for any applicable ‘Fn’

pub async fn run(self, shutdown: impl Future) -> Result<()>

Start the Notification Server.

When the provided shutdown future completes, the server will shutdown gracefully.

This function will return an error IFF the server could not be started. It will recover from all other errors.