pawkit-net 0.1.2

PawKit's networking module
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

#![feature(let_chains)]

mod client;
mod host;

use std::future::Future;

pub use client::*;
pub use host::*;
use just_webrtc::{
    platform::{Channel, PeerConnection},
    DataChannelExt, PeerConnectionExt,
};

#[cfg(not(target_arch = "wasm32"))]
type PacketFuture = dyn Future<Output = (Option<Vec<u8>>, usize)> + Send + Sync;
#[cfg(target_arch = "wasm32")]
type PacketFuture = dyn Future<Output = (Option<Vec<u8>>, usize)>;

struct Connection {
    pub raw_connection: PeerConnection,
    pub channel: Channel,
}

impl Connection {
    pub async fn from(
        raw_connection: PeerConnection,
    ) -> Result<Self, just_webrtc::platform::Error> {
        return Ok(Self {
            channel: raw_connection.receive_channel().await?,
            raw_connection,
        });
    }
}

async fn recieve_packet(channel: &Channel) -> Option<Vec<u8>> {
    return channel.receive().await.map(|it| it.to_vec()).ok();
}