diff options
author | Divy Srivastava <dj.srivastava23@gmail.com> | 2022-10-30 23:52:49 -0700 |
---|---|---|
committer | GitHub <noreply@github.com> | 2022-10-31 12:22:49 +0530 |
commit | d76014192dbfd134794a6129e73f38645d7e6314 (patch) | |
tree | 7fdf5a02e143f0abf12fda6d367dab5e18b63ae6 | |
parent | 80ed54a4b65292f90b6f19ebd5988d9a0cc61cbb (diff) |
fix(ext/websocket): make try_send ops infallible (#16454)
Fixes #16450
-rw-r--r-- | ext/websocket/lib.rs | 18 |
1 files changed, 12 insertions, 6 deletions
diff --git a/ext/websocket/lib.rs b/ext/websocket/lib.rs index 337752c21..61bc44459 100644 --- a/ext/websocket/lib.rs +++ b/ext/websocket/lib.rs @@ -505,9 +505,12 @@ pub fn op_ws_try_send_string( state: &mut OpState, rid: ResourceId, text: String, -) -> Result<bool, AnyError> { - let resource = state.resource_table.get::<WsStreamResource>(rid)?; - resource.try_send(Message::Text(text)) +) -> bool { + let resource = match state.resource_table.get::<WsStreamResource>(rid) { + Ok(resource) => resource, + Err(_) => return false, + }; + resource.try_send(Message::Text(text)).is_ok() } #[op(fast)] @@ -515,9 +518,12 @@ pub fn op_ws_try_send_binary( state: &mut OpState, rid: u32, value: &[u8], -) -> Result<bool, AnyError> { - let resource = state.resource_table.get::<WsStreamResource>(rid)?; - resource.try_send(Message::Binary(value.to_vec())) +) -> bool { + let resource = match state.resource_table.get::<WsStreamResource>(rid) { + Ok(resource) => resource, + Err(_) => return false, + }; + resource.try_send(Message::Binary(value.to_vec())).is_ok() } #[op(deferred)] |