rename
This commit is contained in:
parent
b79c2b3ae6
commit
1b9594dbec
@ -156,14 +156,14 @@ where
|
||||
match output_loop_receiver.recv().await {
|
||||
Ok(msg) => {
|
||||
let payload = serde_json::to_string(&msg);
|
||||
if let Ok(payload2) = payload {
|
||||
let len_bytes = u32::to_le_bytes(payload2.len() as u32);
|
||||
if let Ok(payload) = payload {
|
||||
let len_bytes = u32::to_le_bytes(payload.len() as u32);
|
||||
|
||||
if let Err(err) = socket.write_all(&len_bytes).await {
|
||||
warn!("interserver send failed: {:?}", err);
|
||||
break;
|
||||
}
|
||||
if let Err(err) = socket.write_all(&payload2.as_bytes()).await {
|
||||
if let Err(err) = socket.write_all(&payload.as_bytes()).await {
|
||||
warn!("intserserver send failed: {:?}", err);
|
||||
break;
|
||||
}
|
||||
|
Loading…
x
Reference in New Issue
Block a user