mirror of
https://github.com/tokio-rs/tokio.git
synced 2026-09-08 00:00:13 +02:00
util: fix typo in udp/frame.rs (#3154)
This commit is contained in:
@@ -56,7 +56,7 @@ impl<C: Decoder + Unpin> Stream for UdpFramed<C> {
|
|||||||
pin.rd.reserve(INITIAL_RD_CAPACITY);
|
pin.rd.reserve(INITIAL_RD_CAPACITY);
|
||||||
|
|
||||||
loop {
|
loop {
|
||||||
// Are there are still bytes left in the read buffer to decode?
|
// Are there still bytes left in the read buffer to decode?
|
||||||
if pin.is_readable {
|
if pin.is_readable {
|
||||||
if let Some(frame) = pin.codec.decode_eof(&mut pin.rd)? {
|
if let Some(frame) = pin.codec.decode_eof(&mut pin.rd)? {
|
||||||
let current_addr = pin
|
let current_addr = pin
|
||||||
|
|||||||
Reference in New Issue
Block a user