diff options
author | Henauxg <19689618+Henauxg@users.noreply.github.com> | 2023-01-21 11:48:26 +0100 |
---|---|---|
committer | Henauxg <19689618+Henauxg@users.noreply.github.com> | 2023-01-21 11:48:26 +0100 |
commit | 919e5427766fad3be301dccb13cfee46c14bd8d5 (patch) | |
tree | 34753db470dddf039b1b8844da91acb349c29820 | |
parent | 027ea5e7e92fa62456a9570d9f00d4b851a06a96 (diff) |
[client] Add missing try_send_message_on and try_send_payload_on in connection
-rw-r--r-- | src/client/connection.rs | 16 |
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), |