Struct ServeDaemonInterface 

pub struct ServeDaemonInterface<S> { /* private fields */ }

Implementations

impl<S> ServeDaemonInterface<S>

pub fn new(z: Arc<Session>, server: S, id: ZenohId) -> Self

Trait Implementations

impl<S: Clone> Clone for ServeDaemonInterface<S>

fn clone(&self) -> ServeDaemonInterface<S>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<S> ZServe<DaemonInterfaceRequest> for ServeDaemonInterface<S>

where S: DaemonInterface + Send + 'static,

type Resp = DaemonInterfaceResponse

Type of the response

fn instance_uuid(&self) -> ZenohId

fn connect( &self, ) -> Pin<Box<dyn Future<Output = ZRPCResult<(AbortHandle, JoinHandle<Result<ZRPCResult<()>, Aborted>>)>> + '_>>

Connects to Zenoh, do nothing in this case, state is HALTED

fn initialize(&self) -> Pin<Box<dyn Future<Output = ZRPCResult<()>> + '_>>

Authenticates to Zenoh, state changes to INITIALIZING

fn register(&self) -> Pin<Box<dyn Future<Output = ZRPCResult<()>> + '_>>

fn start( &self, ) -> Pin<Box<dyn Future<Output = ZRPCResult<(AbortHandle, JoinHandle<Result<ZRPCResult<()>, Aborted>>)>> + '_>>

State changes to SERVING, calls serve on a task::spawn, returns a stop sender and the serve task handle

fn run(&self) -> Pin<Box<dyn Future<Output = ZRPCResult<()>> + '_>>

The actual run loop serving the queriable

fn serve( &self, barrier: Arc<Barrier>, ) -> Pin<Box<dyn Future<Output = ZRPCResult<()>> + '_>>

Starts serving all requests

fn stop( &self, stop: AbortHandle, ) -> Pin<Box<dyn Future<Output = ZRPCResult<()>> + '_>>

State changes to REGISTERED, will stop serve/work

fn unregister(&self) -> Pin<Box<dyn Future<Output = ZRPCResult<()>> + '_>>

fn disconnect( &self, stop: AbortHandle, ) -> Pin<Box<dyn Future<Output = ZRPCResult<()>> + '_>>

removes state from Zenoh