diff options
| -rw-r--r-- | embassy-net/src/tcp_socket.rs | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/embassy-net/src/tcp_socket.rs b/embassy-net/src/tcp_socket.rs index def4c8176..25c8af459 100644 --- a/embassy-net/src/tcp_socket.rs +++ b/embassy-net/src/tcp_socket.rs | |||
| @@ -151,6 +151,11 @@ impl<'a> AsyncBufRead for TcpSocket<'a> { | |||
| 151 | } | 151 | } |
| 152 | 152 | ||
| 153 | fn consume(self: Pin<&mut Self>, amt: usize) { | 153 | fn consume(self: Pin<&mut Self>, amt: usize) { |
| 154 | if amt == 0 { | ||
| 155 | // smoltcp's recv returns Finished if we're at EOF, | ||
| 156 | // even if we're "reading" 0 bytes. | ||
| 157 | return; | ||
| 158 | } | ||
| 154 | self.with(|s| s.recv(|_| (amt, ()))).unwrap() | 159 | self.with(|s| s.recv(|_| (amt, ()))).unwrap() |
| 155 | } | 160 | } |
| 156 | } | 161 | } |
