shadowsocks-rust 1.3.2

shadowsocks is a fast tunnel proxy that helps you bypass firewalls.
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

use std::io;

use futures::{Future, Async, Poll};
use tokio_io::io::{WriteAll, write_all};
use tokio_io::AsyncWrite;

/// Write all bytes without returning the internal bytes buffer
pub struct WriteBytes<W, B>
    where W: AsyncWrite,
          B: AsRef<[u8]>
{
    inner: WriteAll<W, B>,
}

impl<W, B> WriteBytes<W, B>
    where W: AsyncWrite,
          B: AsRef<[u8]>
{
    fn new(writer: W, bytes: B) -> WriteBytes<W, B> {
        WriteBytes { inner: write_all(writer, bytes) }
    }
}

impl<W, B> Future for WriteBytes<W, B>
    where W: AsyncWrite,
          B: AsRef<[u8]>
{
    type Item = W;
    type Error = io::Error;

    fn poll(&mut self) -> Poll<Self::Item, Self::Error> {
        let (w, _) = try_ready!(self.inner.poll());
        Ok(Async::Ready(w))
    }
}

/// Write all bytes without returning the internal bytes buffer
pub fn write_bytes<W: AsyncWrite, B: AsRef<[u8]>>(w: W, b: B) -> WriteBytes<W, B> {
    WriteBytes::new(w, b)
}