diff --git a/tokio-io/tests/framed.rs b/tokio-io/tests/framed.rs index 7b2693be1..660cc5d0e 100644 --- a/tokio-io/tests/framed.rs +++ b/tokio-io/tests/framed.rs @@ -21,7 +21,7 @@ impl Decoder for U32Codec { return Ok(None); } - let n = buf.split_to(4).into_buf().get_u32::(); + let n = buf.split_to(4).into_buf().get_u32_be(); Ok(Some(n)) } } @@ -33,7 +33,7 @@ impl Encoder for U32Codec { fn encode(&mut self, item: u32, dst: &mut BytesMut) -> io::Result<()> { // Reserve space dst.reserve(4); - dst.put_u32::(item); + dst.put_u32_be(item); Ok(()) } } @@ -94,4 +94,3 @@ fn external_buf_does_not_shrink() { assert_eq!(readbuf.capacity(), INITIAL_CAPACITY * 2); } - diff --git a/tokio-io/tests/framed_write.rs b/tokio-io/tests/framed_write.rs index 801602684..2db21b48d 100644 --- a/tokio-io/tests/framed_write.rs +++ b/tokio-io/tests/framed_write.rs @@ -28,7 +28,7 @@ impl Encoder for U32Encoder { fn encode(&mut self, item: u32, dst: &mut BytesMut) -> io::Result<()> { // Reserve space dst.reserve(4); - dst.put_u32::(item); + dst.put_u32_be(item); Ok(()) } } @@ -65,7 +65,7 @@ fn write_hits_backpressure() { for i in 0..(ITER + 1) { let mut b = BytesMut::with_capacity(4); - b.put_u32::(i as u32); + b.put_u32_be(i as u32); // Append to the end match mock.calls.back_mut().unwrap() {