Page MenuHomePhabricator
Files F2905641

D10903.id36493.diff
No OneTemporary
Actions

D10903.id36493.diff
View Options

diff --git a/services/identity/src/websockets/send.rs b/services/identity/src/websockets/send.rs
--- a/services/identity/src/websockets/send.rs
+++ b/services/identity/src/websockets/send.rs
@@ -15,7 +15,7 @@
pub async fn send_error_response(
error: errors::WebsocketError,
- outgoing: Arc<Mutex<SplitSink<WebSocketStream<Upgraded>, Message>>>,
+ outgoing: WebsocketSink,
) {
let response_msg = serde_json::json!({
"action": "errorMessage",
@@ -35,10 +35,7 @@
}
}
-pub async fn send_message(
- message: Message,
- outgoing: Arc<Mutex<SplitSink<WebSocketStream<Upgraded>, Message>>>,
-) {
+pub async fn send_message(message: Message, outgoing: WebsocketSink) {
if let Err(e) = outgoing.lock().await.send(message).await {
error!("Failed to send message to device: {}", e);
}

File Metadata

Mime Type
text/plain
Expires
Mon, Oct 7, 7:19 AM (22 h, 6 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
2252575
Default Alt Text
D10903.id36493.diff (810 B)

Event Timeline