summaryrefslogtreecommitdiff
path: root/ext/websocket/lib.rs
diff options
context:
space:
mode:
authorDivy Srivastava <dj.srivastava23@gmail.com>2022-10-30 23:52:49 -0700
committerGitHub <noreply@github.com>2022-10-31 12:22:49 +0530
commitd76014192dbfd134794a6129e73f38645d7e6314 (patch)
tree7fdf5a02e143f0abf12fda6d367dab5e18b63ae6 /ext/websocket/lib.rs
parent80ed54a4b65292f90b6f19ebd5988d9a0cc61cbb (diff)
fix(ext/websocket): make try_send ops infallible (#16454)
Fixes #16450
Diffstat (limited to 'ext/websocket/lib.rs')
-rw-r--r--ext/websocket/lib.rs18
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)]