aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorHenauxg <19689618+Henauxg@users.noreply.github.com>2023-01-21 11:48:26 +0100
committerHenauxg <19689618+Henauxg@users.noreply.github.com>2023-01-21 11:48:26 +0100
commit919e5427766fad3be301dccb13cfee46c14bd8d5 (patch)
tree34753db470dddf039b1b8844da91acb349c29820
parent027ea5e7e92fa62456a9570d9f00d4b851a06a96 (diff)
[client] Add missing try_send_message_on and try_send_payload_on in connection
-rw-r--r--src/client/connection.rs16
1 files changed, 16 insertions, 0 deletions
diff --git a/src/client/connection.rs b/src/client/connection.rs
index 21d452d..0205ba5 100644
--- a/src/client/connection.rs
+++ b/src/client/connection.rs
@@ -185,6 +185,14 @@ impl Connection {
}
}
+ /// Same as [Connection::send_message_on] but will log the error instead of returning it
+ pub fn try_send_message_on<T: serde::Serialize>(&self, channel_id: ChannelId, message: T) {
+ match self.send_message_on(channel_id, message) {
+ Ok(_) => {}
+ Err(err) => error!("try_send_message_on: {}", err),
+ }
+ }
+
pub fn send_payload<T: Into<Bytes>>(&self, payload: T) -> Result<(), QuinnetError> {
match self.default_channel {
Some(channel) => self.send_payload_on(channel, payload),
@@ -214,6 +222,14 @@ impl Connection {
}
}
+ /// Same as [Connection::send_payload_on] but will log the error instead of returning it
+ pub fn try_send_payload_on<T: Into<Bytes>>(&self, channel_id: ChannelId, payload: T) {
+ match self.send_payload_on(channel_id, payload) {
+ Ok(_) => {}
+ Err(err) => error!("try_send_payload_on: {}", err),
+ }
+ }
+
pub fn receive_payload(&mut self) -> Result<Option<Bytes>, QuinnetError> {
match &self.state {
ConnectionState::Disconnected => Err(QuinnetError::ConnectionClosed),