vrr/TrustTunnel
2
0
Fork 0
mirror of https://github.com/TrustTunnel/TrustTunnel.git synced 2026-04-28 03:39:53 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 2

Flush at the start of data exchange

Browse source
This commit is contained in:
boommy 2026-03-03 17:10:54 +04:00
parent 13a420a4a7
commit 03075b729d
1 changed files with 1 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

1
lib/src/pipe.rs
View file

@ -149,6 +149,7 @@ impl<F: Fn(SimplexDirection, usize) + Send> SimplexPipe<F> {
self.last_activity = Instant::now();
let future = async {
self.sink.flush().await?;
if self.pending_chunk.is_none() {
let x = self.source.read().await?;
log_dir!(trace, self.source.id(), self.direction, "TCP data: {}", x);