Struct coap::Observer

pub struct Observer { /* private fields */ }

Implementations

impl Observer

pub fn new() -> Self

Creates an observer with channel to send message.

pub fn select_next_some(&mut self) -> SelectNextSome<'_, Fuse<IntervalStream>>

poll the observer’s timer.

pub async fn request_handler( &mut self, request: &mut CoapRequest<SocketAddr>, responder: Arc<dyn Responder> ) -> bool

filter the requests belong to the observer. store the responder in case it is needed returns whether the request should be forwarded to the handler

pub async fn timer_handler(&mut self)

trigger send the unacknowledge messages.