Struct coap::Observer

pub struct Observer { /* fields omitted */ }

Implementations

impl Observer

pub fn new(tx_sender: MessageSender) -> Observer

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: &CoapRequest<SocketAddr>
) -> bool

filter the requests belong to the observer.

pub async fn timer_handler(&mut self)

trigger send the unacknowledge messages.