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

mod test_device;
#[cfg(feature = "server")]
mod test_device_comm_manager;

use crate::{
  device::DeviceImplCommand,
  util::stream::{iffy_is_empty_check, recv_now},
};
use std::sync::{Arc, Mutex};
pub use test_device::{
  TestDevice,
  TestDeviceEndpointChannel,
  TestDeviceImplCreator,
  TestDeviceInternal,
};
#[cfg(feature = "server")]
pub use test_device_comm_manager::{
  new_bluetoothle_test_device,
  TestDeviceCommunicationManager,
  TestDeviceCommunicationManagerHelper,
};
use tokio::sync::mpsc::Receiver;

#[allow(dead_code)]
pub fn check_test_recv_value(
  receiver: &Arc<Mutex<Receiver<DeviceImplCommand>>>,
  command: DeviceImplCommand,
) {
  assert_eq!(
    recv_now(&mut receiver.lock().unwrap()).unwrap().unwrap(),
    command
  );
}

#[allow(dead_code)]
pub fn check_test_recv_empty(receiver: &Arc<Mutex<Receiver<DeviceImplCommand>>>) -> bool {
  iffy_is_empty_check(&mut receiver.lock().unwrap())
}