matchbox_socket 0.4.0

Painless WebRTC peer-to-peer full-mesh networking socket
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

use futures_channel::mpsc::UnboundedSender;

use super::{PeerId, PeerRequest, PeerSignal};

#[derive(Debug, Clone)]
pub struct SignalPeer {
    pub id: PeerId,
    pub sender: UnboundedSender<PeerRequest>,
}

impl SignalPeer {
    pub fn send(&self, signal: PeerSignal) {
        let req = PeerRequest::Signal {
            receiver: self.id.clone(),
            data: signal,
        };
        self.sender.unbounded_send(req).expect("Send error");
    }

    pub fn new(id: PeerId, sender: UnboundedSender<PeerRequest>) -> Self {
        Self { id, sender }
    }
}

// let to_peer_signal_sender = requests_sender.clone().with(move |signal| {
//     future::ok::<PeerRequest, SendError>(
//         PeerRequest::Signal {
//             receiver: peer_uuid.clone(),
//             data: signal
//         }
//     )
// });