upgrade tokio
This commit is contained in:
parent
9498b77c0a
commit
d3fc6ccd9c
5 changed files with 154 additions and 151 deletions
|
|
@ -492,7 +492,7 @@ impl Connection {
|
|||
res = self.stream.next() => {
|
||||
if let Some(res) = res {
|
||||
last_recv_time = Instant::now();
|
||||
timeout(SEND_TIMEOUT_OTHER, forward.send(res?.into())).await??;
|
||||
timeout(SEND_TIMEOUT_OTHER, forward.send(res?)).await??;
|
||||
} else {
|
||||
bail!("Stream reset by the peer");
|
||||
}
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue