coap-client 0.3.1

A CoAP client
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35

//! Backend module provides swappable CoAP client backends
// https://github.com/ryankurte/rust-coap-client
// Copyright 2021 ryan kurte <ryan@kurte.nz>

use async_trait::async_trait;
use coap_lite::Packet;
use futures::{Future, Stream};

use crate::RequestOptions;

#[cfg(feature = "backend-tokio")]
pub mod backend_tokio;

#[cfg(feature = "backend-tokio")]
pub use backend_tokio::{Tokio, TokioObserve};

pub trait Observer<E>: Stream<Item = Result<Packet, E>> + Send {
    /// Fetch the observer token
    fn token(&self) -> u32;
    /// Fetch the observer resource
    fn resource(&self) -> &str;
}

/// Generic transport trait for implementing CoAP client backends
#[async_trait]
pub trait Backend<E>: Send {
    type Observe: Observer<E>;

    async fn request(&mut self, req: Packet, opts: RequestOptions) -> Result<Packet, E>;

    async fn observe(&mut self, resource: String, opts: RequestOptions)
        -> Result<Self::Observe, E>;

    async fn unobserve(&mut self, o: Self::Observe) -> Result<(), E>;
}