summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorBartek IwaƄczuk <biwanczuk@gmail.com>2022-11-21 16:23:47 +0100
committerGitHub <noreply@github.com>2022-11-21 16:23:47 +0100
commitc0482e09c3362fa7ff00a5af04938595bbae4706 (patch)
tree5a4acc73f2b6ced4e3c928fe7c79afbff4c325ab
parent449b1317c87087173eda7f782770da44f99c1739 (diff)
Revert "fix(ext/websocket): make try_send ops infallible (#16454)" (#16743)
This reverts commit d76014192dbfd134794a6129e73f38645d7e6314.
-rw-r--r--ext/websocket/lib.rs18
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)]