hick-embassy 0.2.0

Async mDNS / DNS-SD for embassy: the `hick-smoltcp` engine driven on embassy-net + embassy-time. `no_std` + `alloc`.
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
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50

//! Bridge the `embassy-time` clock to the [`mdns_proto::Instant`] trait.

use core::time::Duration;

use embassy_time::{Duration as EmbassyDuration, Instant as RawInstant};
use mdns_proto::Instant as ProtoInstant;

/// An [`embassy_time::Instant`] that implements [`mdns_proto::Instant`].
///
/// `embassy_time::Instant` and the `mdns_proto::Instant` trait are both foreign
/// here, so the orphan rule requires a newtype. The driver wraps each
/// `Instant::now()` reading; the engine is generic over the trait, so this is
/// the `I` type for the embassy path.
#[derive(Debug, Clone, Copy, PartialEq, Eq, PartialOrd, Ord)]
pub struct EmbassyInstant(pub RawInstant);

impl From<RawInstant> for EmbassyInstant {
  #[inline(always)]
  fn from(raw: RawInstant) -> Self {
    Self(raw)
  }
}

impl From<EmbassyInstant> for RawInstant {
  #[inline(always)]
  fn from(wrapped: EmbassyInstant) -> Self {
    wrapped.0
  }
}

impl ProtoInstant for EmbassyInstant {
  #[inline]
  fn checked_add_duration(self, dur: Duration) -> Option<Self> {
    let micros = u64::try_from(dur.as_micros()).ok()?;
    self
      .0
      .checked_add(EmbassyDuration::from_micros(micros))
      .map(Self)
  }

  #[inline]
  fn checked_duration_since(self, earlier: Self) -> Option<Duration> {
    let delta = self.0.checked_duration_since(earlier.0)?;
    Some(Duration::from_micros(delta.as_micros()))
  }
}

#[cfg(test)]
#[allow(clippy::unwrap_used)]
mod tests;