diff options
| author | Lizzy Fleckenstein <eliasfleckenstein@web.de> | 2023-01-06 21:20:09 +0100 |
|---|---|---|
| committer | Lizzy Fleckenstein <eliasfleckenstein@web.de> | 2023-01-06 21:20:15 +0100 |
| commit | 9ee7b7ddc5c3611bf515dbdee4134b6df9efed92 (patch) | |
| tree | 09247c8cf80c19e1e005d3be8b03b97a30aaa6b4 /src/send.rs | |
| parent | 12bfebc06ed29fabbc4a4357e314b8fbde1b552d (diff) | |
| download | mt_rudp-9ee7b7ddc5c3611bf515dbdee4134b6df9efed92.tar.xz | |
cleanup; readme
Diffstat (limited to 'src/send.rs')
| -rw-r--r-- | src/send.rs | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/src/send.rs b/src/send.rs index 20308e6..c41ad80 100644 --- a/src/send.rs +++ b/src/send.rs @@ -1,4 +1,6 @@ -use crate::*; +use crate::{prelude::*, Ack, RudpShare}; +use byteorder::{BigEndian, WriteBytesExt}; +use std::io::{self, Write}; use tokio::sync::watch; type AckResult = io::Result<Option<watch::Receiver<bool>>>; @@ -50,6 +52,5 @@ impl<S: UdpSender> RudpShare<S> { pub async fn send_raw(&self, data: &[u8]) -> io::Result<()> { self.udp_tx.send(data).await - // TODO: reset ping timeout } } |