diff options
author | Bartek IwaĆczuk <biwanczuk@gmail.com> | 2022-11-21 16:23:47 +0100 |
---|---|---|
committer | GitHub <noreply@github.com> | 2022-11-21 16:23:47 +0100 |
commit | c0482e09c3362fa7ff00a5af04938595bbae4706 (patch) | |
tree | 5a4acc73f2b6ced4e3c928fe7c79afbff4c325ab | |
parent | 449b1317c87087173eda7f782770da44f99c1739 (diff) |
Revert "fix(ext/websocket): make try_send ops infallible (#16454)" (#16743)
This reverts commit d76014192dbfd134794a6129e73f38645d7e6314.
-rw-r--r-- | ext/websocket/lib.rs | 18 |
1 files changed, 6 insertions, 12 deletions
diff --git a/ext/websocket/lib.rs b/ext/websocket/lib.rs index 984d39e9d..704c699a7 100644 --- a/ext/websocket/lib.rs +++ b/ext/websocket/lib.rs @@ -504,12 +504,9 @@ pub fn op_ws_try_send_string( state: &mut OpState, rid: ResourceId, text: String, -) -> bool { - let resource = match state.resource_table.get::<WsStreamResource>(rid) { - Ok(resource) => resource, - Err(_) => return false, - }; - resource.try_send(Message::Text(text)).is_ok() +) -> Result<bool, AnyError> { + let resource = state.resource_table.get::<WsStreamResource>(rid)?; + resource.try_send(Message::Text(text)) } #[op(fast)] @@ -517,12 +514,9 @@ pub fn op_ws_try_send_binary( state: &mut OpState, rid: u32, value: &[u8], -) -> 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() +) -> Result<bool, AnyError> { + let resource = state.resource_table.get::<WsStreamResource>(rid)?; + resource.try_send(Message::Binary(value.to_vec())) } #[op(deferred)] |