TimeoutWrapperReader: Fix latency issue

Pre-released for 2 days and no one had ever noticed this issue until today : (
pull/5080/head
RPRX 2025-09-01 09:47:17 +00:00
parent 6830089d3c
commit fd54b10d97
1 changed files with 6 additions and 2 deletions

View File

@ -54,12 +54,16 @@ func (r *TimeoutWrapperReader) ReadMultiBufferTimeout(duration time.Duration) (M
close(r.done)
}()
}
time.Sleep(duration)
timeout := make(chan struct{})
go func() {
time.Sleep(duration)
close(timeout)
}()
select {
case <-r.done:
r.done = nil
return r.mb, r.err
default:
case <-timeout:
return nil, nil
}
}