Reading from a TcpStream with Read::read_to_string hangs until the connection is closed by the remote end

by

Check out the docs for Read::read_to_string, emphasis mine:

Read all bytes until EOF in this source, placing them into buf.

Likewise for Read::read_to_end:

Read all bytes until EOF in this source, placing them into buf.

Notably, you aren’t reading 512 bytes in the first example, you are pre-allocating 512 bytes of space and then reading every byte until the socket closes – 4 minutes later.

It sounds like you want to use BufRead::read_line:

Read all bytes until a newline byte (the 0xA byte) is reached, and append them to the provided buffer.

This function will continue to read (and buffer) bytes from the underlying stream until the newline delimiter (the 0xA byte) or EOF is found. Once found, all bytes up to, and including, the delimiter (if found) will be appended to buf.

You can also any other technique that will read a fixed amount of data before returning. One such example would be Read::take, which will cap the total number of bytes you can read at a time.

More Related Contents:

  1. How to idiomatically / efficiently pipe data from Read+Seek to Write?
  2. How to read a struct from a file in Rust?
  3. Read a file line by line in Prolog
  4. How are the O_SYNC and O_DIRECT flags in open(2) different/alike?
  5. MPI Reading from a text file
  6. How do I read the output of a child process without blocking in Rust?
  7. Traits and Rust
  8. How do I collect into an array?
  9. Why are the elements of an array formatted as zeros when they are multiplied by 1/2 or 1/3?
  10. Cannot borrow as mutable more than once at a time in one code – but can in another very similar
  11. How do I conditionally return different types of futures?
  12. Is it considered a bad practice to implement Deref for newtypes?
  13. Implementing a trait for multiple types at once
  14. How to declare a higher-ranked lifetime for a closure argument?
  15. How do I get an owned value out of a `Box`?
  16. Converting from Option to Option
  17. How does Rust implement reflection?
  18. How can I deserialize JSON with a top-level array using Serde?
  19. Comparing HTTP and FTP for transferring files
  20. Send HTTP request manually via socket
  21. How do you use parent module imports in Rust?
  22. Why are recursive struct types illegal in Rust?
  23. is it possible to filter on a vector in-place?
  24. How to embed resources in Rust executable?
  25. Extend lifetime of variable
  26. Read, edit, and write a text file line-wise using Ruby
  27. Quick fix for NetworkOnMainThreadException
  28. Lazy sequence generation in Rust
  29. Is there a way to get the field names of a struct in a macro?
  30. How to set up CORS or OPTIONS for Rocket.rs

Leave a Comment