wtx 0.50.0

A collection of different transport implementations and related tools focused primarily on web technologies.
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

use crate::{executor::Runtime, sync::Backoff};
use core::{
  fmt::{Debug, Formatter},
  pin::pin,
  task::{Context, Poll, Waker},
};

/// A very limited `no_std` runtime that only spins until the future resolves.
#[derive(Clone, Copy, Default)]
pub struct NoStdRuntime {}

impl NoStdRuntime {
  /// New instance
  #[inline]
  pub const fn new() -> Self {
    Self {}
  }
}

impl Runtime for NoStdRuntime {
  #[inline]
  fn new() -> crate::Result<Self> {
    Ok(Self::new())
  }

  #[inline]
  fn block_on<F>(&self, future: F) -> F::Output
  where
    F: Future,
  {
    let mut pinned = pin!(future);
    let mut cx = Context::from_waker(Waker::noop());
    let backoff = Backoff::new();
    loop {
      match pinned.as_mut().poll(&mut cx) {
        Poll::Ready(el) => return el,
        Poll::Pending => backoff.snooze(),
      }
    }
  }
}

impl Debug for NoStdRuntime {
  #[inline]
  fn fmt(&self, f: &mut Formatter<'_>) -> core::fmt::Result {
    f.debug_struct("StdRuntime").finish()
  }
}