zeloxy 0.3.0

A library for creating lightweight, async, and lag-free proxy connections.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

use tokio::io::AsyncReadExt;
use tokio::net::tcp::OwnedReadHalf;

/// Отдельная рука для чтения данных из потока
pub struct ProxyReader {
  pub read_stream: OwnedReadHalf,
}

impl ProxyReader {
  /// Метод чтения буффера из потока
  pub async fn read(&mut self, buffer: &mut [u8]) -> std::io::Result<usize> {
    self.read_stream.read_exact(buffer).await
  }

  /// Метод чтения буффера из потока до конца
  pub async fn read_to_end(&mut self, buffer: &mut Vec<u8>) -> std::io::Result<usize> {
    self.read_stream.read_to_end(buffer).await
  }
}