How to idiomatically / efficiently pipe data from Read+Seek to Write?

by

You are looking for io::copy:

use std::io::{self, prelude::*, SeekFrom};

pub fn assemble<I, O>(mut input: I, mut output: O) -> Result<(), io::Error>
where
    I: Read + Seek,
    O: Write,
{
    // first seek and output "hello"
    input.seek(SeekFrom::Start(5))?;
    io::copy(&mut input.by_ref().take(5), &mut output)?;

    // then output "world"
    input.seek(SeekFrom::Start(0))?;
    io::copy(&mut input.take(5), &mut output)?;

    Ok(())
}

If you look at the implementation of io::copy, you can see that it’s similar to your code. However, it takes care to handle more error cases:

  1. write does not always write everything you ask it to!
  2. An “interrupted” write isn’t usually fatal.

It also uses a larger buffer size but still stack-allocates it.

More Related Contents:

  1. Reading from a TcpStream with Read::read_to_string hangs until the connection is closed by the remote end
  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. Scanner is skipping nextLine() after using next() or nextFoo()?
  8. What are Rust’s exact auto-dereferencing rules?
  9. How to check for file lock? [duplicate]
  10. Is it possible to use `impl Trait` as a function’s return type in a trait definition?
  11. Cannot borrow as immutable because it is also borrowed as mutable in function arguments
  12. What is the relation between auto-dereferencing and deref coercion?
  13. What is the return type of the indexing operation?
  14. I implemented a trait for another trait but cannot call methods from both traits
  15. Moved variable still borrowing after calling `drop`?
  16. OS X / Linux: pipe into two processes?
  17. What is InputStream & Output Stream? Why and when do we use them?
  18. Listing files in a directory matching a pattern in Java [duplicate]
  19. Temporary value is freed at the end of this statement [duplicate]
  20. Simultaneous mutable access to arbitrary indices of a large vector that are guaranteed to be disjoint
  21. How can I store a pattern in a variable in Rust?
  22. pipe stdout and stderr to two different processes in shell script?
  23. In Java, what is the default location for newly created files?
  24. Why is `with open()` better for opening files in Python?
  25. Why is Rust’s assert_eq! implemented using a match?
  26. Using async / await with DataReader ? ( without middle buffers!)
  27. How can I store function pointers in an array? [duplicate]
  28. Is there a good way to convert a Vec to an array?
  29. How to use Pipe Symbol through exec in Java [duplicate]
  30. How can I conditionally provide a default reference without performing unnecessary computation when it isn’t used?

Leave a Comment