Defer a timeout fix until later
This commit is contained in:
parent
d5cfd5ad5f
commit
df1b0c8d58
|
@ -489,6 +489,8 @@ where
|
||||||
let _ =
|
let _ =
|
||||||
tx.send(Err(PeerError::ConnectionClosed.into()));
|
tx.send(Err(PeerError::ConnectionClosed.into()));
|
||||||
} else if e.is_full() {
|
} else if e.is_full() {
|
||||||
|
// TODO: wait for the sink to be ready, or wait for a timeout,
|
||||||
|
// then close the connection with an overloaded error (#1551)
|
||||||
let ClientRequest { tx, .. } = e.into_inner();
|
let ClientRequest { tx, .. } = e.into_inner();
|
||||||
let _ = tx.send(Err(PeerError::Overloaded.into()));
|
let _ = tx.send(Err(PeerError::Overloaded.into()));
|
||||||
} else {
|
} else {
|
||||||
|
|
Loading…
Reference in New Issue