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

use async_stream::stream;
use futures::{FutureExt, Stream};
use tokio::sync::{broadcast, mpsc};

pub fn convert_broadcast_receiver_to_stream<T>(
  receiver: broadcast::Receiver<T>,
) -> impl Stream<Item = T>
where
  T: Unpin + Clone,
{
  stream! {
    pin_mut!(receiver);
    while let Ok(val) = receiver.recv().await {
      yield val;
    }
  }
}

pub fn recv_now<T>(receiver: &mut mpsc::Receiver<T>) -> Option<Option<T>> {
  receiver.recv().now_or_never()
}

pub fn iffy_is_empty_check<T>(receiver: &mut mpsc::Receiver<T>) -> bool {
  recv_now(receiver).is_none()
}