Handle Response::Error and send Message::Reject generated from a PeerError::Rejected
This commit is contained in:
parent
f5f1fe9bbc
commit
b9c27e5683
|
@ -374,6 +374,11 @@ where
|
||||||
|
|
||||||
match rsp {
|
match rsp {
|
||||||
Response::Ok => { /* generic success, do nothing */ }
|
Response::Ok => { /* generic success, do nothing */ }
|
||||||
|
Response::Error => {
|
||||||
|
if let Err(e) = self.peer_tx.send(Message::from(PeerError::Rejected)).await {
|
||||||
|
self.fail_with(e.into());
|
||||||
|
}
|
||||||
|
}
|
||||||
Response::Peers(addrs) => {
|
Response::Peers(addrs) => {
|
||||||
if let Err(e) = self.peer_tx.send(Message::Addr(addrs)).await {
|
if let Err(e) = self.peer_tx.send(Message::Addr(addrs)).await {
|
||||||
self.fail_with(e.into());
|
self.fail_with(e.into());
|
||||||
|
|
Loading…
Reference in New Issue