We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent ca1983c commit 7767162Copy full SHA for 7767162
rust/acp.rs
@@ -220,14 +220,14 @@ where
220
let (tx, rx) = oneshot::channel();
221
let id = self.next_id.fetch_add(1, SeqCst);
222
self.response_senders.lock().insert(id, (method, tx));
223
- if !self
+ if self
224
.outgoing_tx
225
.unbounded_send(OutgoingMessage::Request {
226
id,
227
method: method.into(),
228
params,
229
})
230
- .is_ok()
+ .is_err()
231
{
232
self.response_senders.lock().remove(&id);
233
}
0 commit comments