Skip to content

Commit

Permalink
fix: typo
Browse files Browse the repository at this point in the history
  • Loading branch information
Matrix-Zhang committed Apr 7, 2024
1 parent 2a4306e commit a3254dd
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
4 changes: 2 additions & 2 deletions src/listener.rs
Original file line number Diff line number Diff line change
Expand Up @@ -51,7 +51,7 @@ impl KcpListener {
loop {
tokio::select! {
peer_addr = close_rx.recv() => {
let peer_addr = peer_addr.expect("close_tx closed unexpectly");
let peer_addr = peer_addr.expect("close_tx closed unexpectedly");
sessions.close_peer(peer_addr);
trace!("session peer_addr: {} removed", peer_addr);
}
Expand Down Expand Up @@ -143,7 +143,7 @@ impl KcpListener {
Some(s) => Ok(s),
None => Err(KcpError::IoError(io::Error::new(
ErrorKind::Other,
"accept channel closed unexpectly",
"accept channel closed unexpectedly",
))),
}
}
Expand Down
2 changes: 1 addition & 1 deletion src/skcp.rs
Original file line number Diff line number Diff line change
Expand Up @@ -53,7 +53,7 @@ impl Write for UdpOutput {
// ignored as packet was lost in transmission
trace!("[SEND] UDP send EAGAIN, packet.size: {} bytes, delayed send", buf.len());

self.delay_tx.send(buf.to_owned()).expect("channel closed unexpectly");
self.delay_tx.send(buf.to_owned()).expect("channel closed unexpectedly");

Ok(buf.len())
}
Expand Down

0 comments on commit a3254dd

Please sign in to comment.