buttplug 2.1.5

Buttplug Intimate Hardware Control Library
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
51
52
53
54
55

use async_std::task;
use futures::{
  future::{Future, RemoteHandle},
  task::{FutureObj, Spawn, SpawnError, SpawnExt},
};

#[derive(Default)]
pub struct AsyncStdAsyncManager {}

#[cfg(target_arch = "wasm32")]
impl Spawn for AsyncStdAsyncManager {
  fn spawn_obj(&self, future: FutureObj<'static, ()>) -> Result<(), SpawnError> {
    task::spawn_local(future);
    Ok(())
  }
}

#[cfg(not(target_arch = "wasm32"))]
impl Spawn for AsyncStdAsyncManager {
  fn spawn_obj(&self, future: FutureObj<'static, ()>) -> Result<(), SpawnError> {
    task::spawn(future);
    Ok(())
  }
}

pub fn spawn<Fut>(future: Fut) -> Result<(), SpawnError>
where
  Fut: Future<Output = ()> + Send + 'static,
{
  AsyncStdAsyncManager::default().spawn(future)
}

pub fn spawn_with_handle<Fut>(future: Fut) -> Result<RemoteHandle<Fut::Output>, SpawnError>
where
  Fut: Future + Send + 'static,
  Fut::Output: Send,
{
  AsyncStdAsyncManager::default().spawn_with_handle(future)
}

#[cfg(not(target_arch = "wasm32"))]
pub fn block_on<F>(f: F) -> <F as Future>::Output
where
  F: Future,
{
  task::block_on(f)
}

#[cfg(target_arch = "wasm32")]
pub fn block_on<F>(f: F) -> <F as Future>::Output
where
  F: Future,
{
  unimplemented!("No block_on in wasm")
}