zeloxy 0.2.2

A library for creating lightweight, asynchronous, 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::AsyncWriteExt;
use tokio::net::tcp::OwnedWriteHalf;

/// Отдельная рука для записи данных в поток
pub struct ProxyWriter {
  pub write_stream: OwnedWriteHalf,
}

impl ProxyWriter {
  /// Метод выключения потока записи
  pub async fn shutdown(&mut self) -> std::io::Result<()> {
    self.write_stream.shutdown().await
  }

  /// Метод записи буффера в поток
  pub async fn write(&mut self, buffer: impl Into<&[u8]>) -> std::io::Result<()> {
    self.write_stream.write_all(buffer.into()).await
  }
}