LumeWeb
/
ethers-rs
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix(provider::ws): ignore the websocket response when the request has been cancelled. (#641)

This commit is contained in:
guanqun 2021-12-04 02:14:13 +08:00 committed by GitHub
parent 9fc75ef245
commit 8d07610e4a
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
ethers-providers/src/transports/ws.rs
View File

@ -313,9 +313,11 @@ where
Err(_) => {} Err(_) => {}
Ok(Incoming::Response(resp)) => { Ok(Incoming::Response(resp)) => {
if let Some(request) = self.pending.remove(&resp.id) { if let Some(request) = self.pending.remove(&resp.id) {
if !request.is_canceled() {
request.send(resp.data.into_result()).map_err(to_client_error)?; request.send(resp.data.into_result()).map_err(to_client_error)?;
} }
} }
}
Ok(Incoming::Notification(notification)) => { Ok(Incoming::Notification(notification)) => {
let id = notification.params.subscription; let id = notification.params.subscription;
if let Entry::Occupied(stream) = self.subscriptions.entry(id) { if let Entry::Occupied(stream) = self.subscriptions.entry(id) {