dhaar-torrent 0.4.0

A BitTorrent client library: peer wire protocol, piece management and a resumable on-disk store
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

use tokio::sync::mpsc::{Receiver, Sender, channel};

use crate::peer_explorer::Peer;

const CHANNEL_SIZE: usize = 256;

#[derive(Debug)]
pub enum PeerExplorerChannelMessage {
    PeerFound(Peer),
}

pub type PeerExplorerChannelSender = Sender<PeerExplorerChannelMessage>;
pub type PeerExplorerChannelReceiver = Receiver<PeerExplorerChannelMessage>;
pub fn new_peer_explorer_channel() -> (
    Sender<PeerExplorerChannelMessage>,
    Receiver<PeerExplorerChannelMessage>,
) {
    channel(CHANNEL_SIZE)
}

#[derive(Debug)]
pub enum PeerSourceChannelMessage {
    PeerFound(Peer),
}

pub type PeerSourceChannelSender = Sender<PeerSourceChannelMessage>;
pub type PeerSourceChannelReceiver = Receiver<PeerSourceChannelMessage>;

pub fn new_peer_source_channel() -> (
    Sender<PeerSourceChannelMessage>,
    Receiver<PeerSourceChannelMessage>,
) {
    channel(CHANNEL_SIZE)
}