Skip to content

Commit

Permalink
Apply suggestions from code review
Browse files Browse the repository at this point in the history
  • Loading branch information
jxs authored Oct 23, 2024
1 parent b376de0 commit 8da581b
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions yamux/src/connection/closing.rs
Original file line number Diff line number Diff line change
Expand Up @@ -115,7 +115,7 @@ mod tests {
_: &mut Context<'_>,
_: &mut [u8],
) -> Poll<std::io::Result<usize>> {
todo!()
unimplemented!()
}
}
impl AsyncWrite for Socket {
Expand All @@ -130,7 +130,7 @@ mod tests {
}

fn poll_flush(self: Pin<&mut Self>, _: &mut Context<'_>) -> Poll<std::io::Result<()>> {
todo!()
uniplemented!()
}

fn poll_close(mut self: Pin<&mut Self>, _: &mut Context<'_>) -> Poll<std::io::Result<()>> {
Expand Down Expand Up @@ -181,7 +181,7 @@ mod tests {
&frame_close_ack,
StreamCommand::CloseStream { ack: true },
));
let pending_frames = vec![frame_pending.clone().into()];
let pending_frames = vec![frame_pending.into()];
let mut socket = Socket {
written: vec![],
closed: false,
Expand Down

0 comments on commit 8da581b

Please sign in to comment.