bip_peer 0.5.0

Communication with bittorrent peers via peer wire protocol
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
39
40
41
42

use std::io::{self, Write};

use protocol::{PeerProtocol, NestedPeerProtocol};

use bytes::Bytes;

/// Unit protocol which will always return a unit if called.
pub struct UnitProtocol;

impl UnitProtocol {
    /// Create a new `UnitProtocol`.
    pub fn new() -> UnitProtocol {
        UnitProtocol
    }
}

impl PeerProtocol for UnitProtocol {
    type ProtocolMessage = ();

    fn bytes_needed(&mut self, _bytes: &[u8]) -> io::Result<Option<usize>> {
        Ok(Some(0))
    }

    fn parse_bytes(&mut self, _bytes: Bytes) -> io::Result<Self::ProtocolMessage> {
        Ok(())
    }

    fn write_bytes<W>(&mut self, _message: &Self::ProtocolMessage, _writer: W) -> io::Result<()>
        where W: Write {
        Ok(())
    }

    fn message_size(&mut self, _message: &Self::ProtocolMessage) -> usize {
        0
    }
}

impl<M> NestedPeerProtocol<M> for UnitProtocol {
    fn received_message(&mut self, _message: &M) { }

    fn sent_message(&mut self, _message: &M) { }
}