Skip to content

Commit

Permalink
add enum prefix
Browse files Browse the repository at this point in the history
  • Loading branch information
wathenjiang committed Sep 2, 2023
1 parent f9a93cc commit 168e684
Showing 1 changed file with 10 additions and 10 deletions.
20 changes: 10 additions & 10 deletions tokio-util/tests/length_delimited.rs
Original file line number Diff line number Diff line change
Expand Up @@ -185,11 +185,11 @@ fn read_single_frame_multi_packet_wait() {
let io = FramedRead::new(
mock! {
data(b"\x00\x00"),
Pending,
Poll::Pending,
data(b"\x00\x09abc"),
Pending,
Poll::Pending,
data(b"defghi"),
Pending,
Poll::Pending,
},
LengthDelimitedCodec::new(),
);
Expand All @@ -207,15 +207,15 @@ fn read_multi_frame_multi_packet_wait() {
let io = FramedRead::new(
mock! {
data(b"\x00\x00"),
Pending,
Poll::Pending,
data(b"\x00\x09abc"),
Pending,
Poll::Pending,
data(b"defghi"),
Pending,
Poll::Pending,
data(b"\x00\x00\x00\x0312"),
Pending,
Poll::Pending,
data(b"3\x00\x00\x00\x0bhello world"),
Pending,
Poll::Pending,
},
LengthDelimitedCodec::new(),
);
Expand Down Expand Up @@ -639,7 +639,7 @@ fn write_update_max_frame_len_in_flight() {
let io = length_delimited::Builder::new().new_write(mock! {
data(b"\x00\x00\x00\x06"),
data(b"ab"),
Pending,
Poll::Pending,
data(b"cdef"),
flush(),
});
Expand Down Expand Up @@ -714,7 +714,7 @@ impl AsyncRead for Mock {
}
Some(Poll::Ready(Ok(_))) => panic!(),
Some(Poll::Ready(Err(e))) => Poll::Ready(Err(e)),
Some(Pending) => Pending,
Some(Poll::Pending) => Poll::Pending,
None => Poll::Ready(Ok(())),
}
}
Expand Down

0 comments on commit 168e684

Please sign in to comment.