diff options
| -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)] |