tensamin/omega
Watch
6
0
Fork
You've already forked omega
 0
Code Issues Pull requests 1 Projects Releases Packages Wiki Activity Actions

[Clean]

Browse source
This commit is contained in:
Alex Emmet 2026-04-06 01:09:16 +02:00
commit 9fb50e4d20
1 changed files with 10 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

14
src/transport/omikron_connection.rs
View file

@ -504,7 +504,9 @@ impl OmikronConnection {
let response = self let response = self
.clone() .clone()
.build_user_data_response(cv.get_id(), user_data) .build_user_data_response(cv.get_id(), user_data)
.await; .await
.with_receiver(cv.get_sender())
.with_sender(cv.get_receiver());
return self.send(&response).await; return self.send(&response).await;
} }
} }
@ -515,14 +517,18 @@ impl OmikronConnection {
let response = self let response = self
.clone() .clone()
.build_user_data_response(cv.get_id(), user_data) .build_user_data_response(cv.get_id(), user_data)
.await; .await
.with_receiver(cv.get_sender())
.with_sender(cv.get_receiver());
return self.send(&response).await; return self.send(&response).await;
} }
} }
// Not found // Not found
let response = let response = CommunicationValue::new(CommunicationType::error_not_found)
CommunicationValue::new(CommunicationType::error_not_found).with_id(cv.get_id()); .with_id(cv.get_id())
.with_receiver(cv.get_sender())
.with_sender(cv.get_receiver());
self.send(&response).await self.send(&response).await
} }