Struct io_streams::BufReaderLineWriter [−][src]
Wraps a reader and writer and buffers input and output to and from it, flushing
the writer whenever a newline (0x0a
, '\n'
) is detected on output.
The BufDuplexer
struct wraps a reader and writer and buffers their input and output.
But it only does this batched write when it goes out of scope, or when the
internal buffer is full. Sometimes, you’d prefer to write each line as it’s
completed, rather than the entire buffer at once. Enter BufReaderLineWriter
. It
does exactly that.
Like BufDuplexer
, a BufReaderLineWriter
’s buffer will also be flushed when the
BufReaderLineWriter
goes out of scope or when its internal buffer is full.
If there’s still a partial line in the buffer when the BufReaderLineWriter
is
dropped, it will flush those contents.
Examples
We can use BufReaderLineWriter
to write one line at a time, significantly
reducing the number of actual writes to the file.
use char_device::CharDevice; use io_streams::BufReaderLineWriter; use std::{fs, io::prelude::*}; fn main() -> std::io::Result<()> { let road_not_taken = b"I shall be telling this with a sigh Somewhere ages and ages hence: Two roads diverged in a wood, and I - I took the one less traveled by, And that has made all the difference."; let file = CharDevice::open("/dev/tty")?; let mut file = BufReaderLineWriter::new(file); file.write_all(b"I shall be telling this with a sigh")?; // No bytes are written until a newline is encountered (or // the internal buffer is filled). assert_eq!(fs::read_to_string("poem.txt")?, ""); file.write_all(b"\n")?; assert_eq!( fs::read_to_string("poem.txt")?, "I shall be telling this with a sigh\n", ); // Write the rest of the poem. file.write_all( b"Somewhere ages and ages hence: Two roads diverged in a wood, and I - I took the one less traveled by, And that has made all the difference.", )?; // The last line of the poem doesn't end in a newline, so // we have to flush or drop the `BufReaderLineWriter` to finish // writing. file.flush()?; // Confirm the whole poem was written. assert_eq!(fs::read("poem.txt")?, &road_not_taken[..]); Ok(()) }
Implementations
impl<Inner: HalfDuplex> BufReaderLineWriter<Inner>
[src]
pub fn new(inner: Inner) -> Self
[src]
Creates a new BufReaderLineWriter
.
Examples
use char_device::CharDevice; use io_streams::BufReaderLineWriter; fn main() -> std::io::Result<()> { let file = CharDevice::open("/dev/tty")?; let file = BufReaderLineWriter::new(file); Ok(()) }
pub fn with_capacities(
reader_capacity: usize,
writer_capacity: usize,
inner: Inner
) -> Self
[src]
reader_capacity: usize,
writer_capacity: usize,
inner: Inner
) -> Self
Creates a new BufReaderLineWriter
with a specified capacities for the internal
buffers.
Examples
use char_device::CharDevice; use io_streams::BufReaderLineWriter; fn main() -> std::io::Result<()> { let file = CharDevice::open("/dev/tty")?; let file = BufReaderLineWriter::with_capacities(10, 100, file); Ok(()) }
pub fn get_ref(&self) -> &Inner
[src]
Gets a reference to the underlying writer.
Examples
use char_device::CharDevice; use io_streams::BufReaderLineWriter; fn main() -> std::io::Result<()> { let file = CharDevice::open("/dev/tty")?; let file = BufReaderLineWriter::new(file); let reference = file.get_ref(); Ok(()) }
pub fn get_mut(&mut self) -> &mut Inner
[src]
Gets a mutable reference to the underlying writer.
Caution must be taken when calling methods on the mutable reference returned as extra writes could corrupt the output stream.
Examples
use char_device::CharDevice; use io_streams::BufReaderLineWriter; fn main() -> std::io::Result<()> { let file = CharDevice::open("/dev/tty")?; let mut file = BufReaderLineWriter::new(file); // we can use reference just like file let reference = file.get_mut(); Ok(()) }
pub fn into_inner(self) -> Result<Inner, IntoInnerError<Self>>
[src]
Unwraps this BufReaderLineWriter
, returning the underlying writer.
The internal buffer is written out before returning the writer.
Errors
An Err
will be returned if an error occurs while flushing the buffer.
Examples
use char_device::CharDevice; use io_streams::BufReaderLineWriter; fn main() -> std::io::Result<()> { let file = CharDevice::open("/dev/tty")?; let writer: BufReaderLineWriter<CharDevice> = BufReaderLineWriter::new(file); let file: CharDevice = writer.into_inner()?; Ok(()) }
Trait Implementations
impl<Inner: HalfDuplex + AsRawFd> AsRawFd for BufReaderLineWriter<Inner>
[src]
impl<Inner: HalfDuplex> BufRead for BufReaderLineWriter<Inner>
[src]
fn fill_buf(&mut self) -> Result<&[u8]>
[src]
fn consume(&mut self, amt: usize)
[src]
fn read_until(&mut self, byte: u8, buf: &mut Vec<u8>) -> Result<usize>
[src]
fn read_line(&mut self, buf: &mut String) -> Result<usize>
[src]
pub fn split(self, byte: u8) -> Split<Self>
1.0.0[src]
pub fn lines(self) -> Lines<Self>
1.0.0[src]
impl<Inner: HalfDuplex> Debug for BufReaderLineWriter<Inner> where
Inner: Debug,
[src]
Inner: Debug,
impl<Inner: HalfDuplex + OwnsRaw> OwnsRaw for BufReaderLineWriter<Inner>
[src]
impl<Inner: HalfDuplex> Read for BufReaderLineWriter<Inner>
[src]
fn read(&mut self, buf: &mut [u8]) -> Result<usize>
[src]
fn read_vectored(&mut self, bufs: &mut [IoSliceMut<'_>]) -> Result<usize>
[src]
fn is_read_vectored(&self) -> bool
[src]
pub unsafe fn initializer(&self) -> Initializer
[src]
pub fn read_to_end(&mut self, buf: &mut Vec<u8, Global>) -> Result<usize, Error>
1.0.0[src]
pub fn read_to_string(&mut self, buf: &mut String) -> Result<usize, Error>
1.0.0[src]
pub fn read_exact(&mut self, buf: &mut [u8]) -> Result<(), Error>
1.6.0[src]
pub fn by_ref(&mut self) -> &mut Self
1.0.0[src]
pub fn bytes(self) -> Bytes<Self>
1.0.0[src]
pub fn chain<R>(self, next: R) -> Chain<Self, R> where
R: Read,
1.0.0[src]
R: Read,
pub fn take(self, limit: u64) -> Take<Self>
1.0.0[src]
impl<Inner: HalfDuplex> Write for BufReaderLineWriter<Inner>
[src]
fn write(&mut self, buf: &[u8]) -> Result<usize>
[src]
fn flush(&mut self) -> Result<()>
[src]
fn write_vectored(&mut self, bufs: &[IoSlice<'_>]) -> Result<usize>
[src]
fn is_write_vectored(&self) -> bool
[src]
fn write_all(&mut self, buf: &[u8]) -> Result<()>
[src]
fn write_all_vectored(&mut self, bufs: &mut [IoSlice<'_>]) -> Result<()>
[src]
fn write_fmt(&mut self, fmt: Arguments<'_>) -> Result<()>
[src]
pub fn by_ref(&mut self) -> &mut Self
1.0.0[src]
Auto Trait Implementations
impl<Inner> RefUnwindSafe for BufReaderLineWriter<Inner> where
Inner: RefUnwindSafe,
Inner: RefUnwindSafe,
impl<Inner> Send for BufReaderLineWriter<Inner> where
Inner: Send,
Inner: Send,
impl<Inner> Sync for BufReaderLineWriter<Inner> where
Inner: Sync,
Inner: Sync,
impl<Inner> Unpin for BufReaderLineWriter<Inner> where
Inner: Unpin,
Inner: Unpin,
impl<Inner> UnwindSafe for BufReaderLineWriter<Inner> where
Inner: UnwindSafe,
Inner: UnwindSafe,
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> AsUnsafeFile for T where
T: OwnsRaw + AsRawFd,
[src]
T: OwnsRaw + AsRawFd,
pub fn as_unsafe_file(&self) -> UnsafeFile
[src]
pub fn as_file_view(&self) -> View<'_, File>
[src]
pub unsafe fn as_unscoped_file_view(&self) -> View<'static, File>
[src]
pub fn as_pipe_reader_view(&self) -> View<'_, PipeReader>
[src]
pub unsafe fn as_unscoped_pipe_reader_view(&self) -> View<'static, PipeReader>
[src]
pub fn as_pipe_writer_view(&self) -> View<'_, PipeWriter>
[src]
pub unsafe fn as_unscoped_pipe_writer_view(&self) -> View<'static, PipeWriter>
[src]
pub fn eq_file<Filelike>(&self, other: &Filelike) -> bool where
Filelike: AsUnsafeFile,
[src]
Filelike: AsUnsafeFile,
impl<T> AsUnsafeHandle for T where
T: OwnsRaw + AsRawFd,
[src]
T: OwnsRaw + AsRawFd,
pub fn as_unsafe_handle(&self) -> UnsafeHandle
[src]
pub fn eq_handle<Handlelike>(&self, other: &Handlelike) -> bool where
Handlelike: AsUnsafeHandle,
[src]
Handlelike: AsUnsafeHandle,
impl<T> AsUnsafeSocket for T where
T: OwnsRaw + AsRawFd,
[src]
T: OwnsRaw + AsRawFd,
pub fn as_unsafe_socket(&self) -> UnsafeSocket
[src]
pub fn as_tcp_stream_view(&self) -> View<'_, TcpStream>
[src]
pub unsafe fn as_unscoped_tcp_stream_view(&self) -> View<'static, TcpStream>
[src]
pub fn as_tcp_listener_view(&self) -> View<'_, TcpListener>
[src]
pub unsafe fn as_unscoped_tcp_listener_view(&self) -> View<'static, TcpListener>
[src]
pub fn as_udp_socket_view(&self) -> View<'_, UdpSocket>
[src]
pub unsafe fn as_unscoped_udp_socket_view(&self) -> View<'static, UdpSocket>
[src]
pub fn as_unix_stream_view(&self) -> View<'_, UnixStream>
[src]
pub unsafe fn as_unscoped_unix_stream_view(&self) -> View<'static, UnixStream>
[src]
pub fn eq_socket<Socketlike>(&self, other: &Socketlike) -> bool where
Socketlike: AsUnsafeSocket,
[src]
Socketlike: AsUnsafeSocket,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
pub fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> FileIoExt for T where
T: AsUnsafeFile,
[src]
T: AsUnsafeFile,
pub fn advise(&self, offset: u64, len: u64, advice: Advice) -> Result<(), Error>
[src]
pub fn allocate(&self, offset: u64, len: u64) -> Result<(), Error>
[src]
pub fn read(&self, buf: &mut [u8]) -> Result<usize, Error>
[src]
pub fn read_exact(&self, buf: &mut [u8]) -> Result<(), Error>
[src]
pub fn read_at(&self, buf: &mut [u8], offset: u64) -> Result<usize, Error>
[src]
pub fn read_exact_at(&self, buf: &mut [u8], offset: u64) -> Result<(), Error>
[src]
pub fn read_vectored(&self, bufs: &mut [IoSliceMut<'_>]) -> Result<usize, Error>
[src]
pub fn read_vectored_at(
&self,
bufs: &mut [IoSliceMut<'_>],
offset: u64
) -> Result<usize, Error>
[src]
&self,
bufs: &mut [IoSliceMut<'_>],
offset: u64
) -> Result<usize, Error>
pub fn is_read_vectored_at(&self) -> bool
[src]
pub fn read_to_end(&self, buf: &mut Vec<u8, Global>) -> Result<usize, Error>
[src]
pub fn read_to_end_at(
&self,
buf: &mut Vec<u8, Global>,
offset: u64
) -> Result<usize, Error>
[src]
&self,
buf: &mut Vec<u8, Global>,
offset: u64
) -> Result<usize, Error>
pub fn read_to_string(&self, buf: &mut String) -> Result<usize, Error>
[src]
pub fn read_to_string_at(
&self,
buf: &mut String,
offset: u64
) -> Result<usize, Error>
[src]
&self,
buf: &mut String,
offset: u64
) -> Result<usize, Error>
pub fn peek(&self, buf: &mut [u8]) -> Result<usize, Error>
[src]
pub fn write(&self, buf: &[u8]) -> Result<usize, Error>
[src]
pub fn write_all(&self, buf: &[u8]) -> Result<(), Error>
[src]
pub fn write_at(&self, buf: &[u8], offset: u64) -> Result<usize, Error>
[src]
pub fn write_all_at(&self, buf: &[u8], offset: u64) -> Result<(), Error>
[src]
pub fn write_vectored(&self, bufs: &[IoSlice<'_>]) -> Result<usize, Error>
[src]
pub fn write_vectored_at(
&self,
bufs: &[IoSlice<'_>],
offset: u64
) -> Result<usize, Error>
[src]
&self,
bufs: &[IoSlice<'_>],
offset: u64
) -> Result<usize, Error>
pub fn is_write_vectored_at(&self) -> bool
[src]
pub fn flush(&self) -> Result<(), Error>
[src]
pub fn write_fmt(&self, fmt: Arguments<'_>) -> Result<(), Error>
[src]
pub fn seek(&self, pos: SeekFrom) -> Result<u64, Error>
[src]
pub fn stream_position(&self) -> Result<u64, Error>
[src]
pub fn read_exact_vectored(
&self,
bufs: &mut [IoSliceMut<'_>]
) -> Result<(), Error>
[src]
&self,
bufs: &mut [IoSliceMut<'_>]
) -> Result<(), Error>
pub fn read_exact_vectored_at(
&self,
bufs: &mut [IoSliceMut<'_>],
offset: u64
) -> Result<(), Error>
[src]
&self,
bufs: &mut [IoSliceMut<'_>],
offset: u64
) -> Result<(), Error>
pub fn write_all_vectored(&self, bufs: &mut [IoSlice<'_>]) -> Result<(), Error>
[src]
pub fn write_all_vectored_at(
&self,
bufs: &mut [IoSlice<'_>],
offset: u64
) -> Result<(), Error>
[src]
&self,
bufs: &mut [IoSlice<'_>],
offset: u64
) -> Result<(), Error>
impl<T> From<T> for T
[src]
impl<T> GetSetFdFlags for T where
T: AsUnsafeFile,
[src]
T: AsUnsafeFile,
pub fn get_fd_flags(&self) -> Result<FdFlags, Error>
[src]
pub fn set_fd_flags(&mut self, fd_flags: FdFlags) -> Result<(), Error>
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> IsReadWrite for T where
T: AsUnsafeHandle,
[src]
T: AsUnsafeHandle,
impl<T> IsTerminal for T where
T: AsUnsafeHandle,
[src]
T: AsUnsafeHandle,
pub fn is_terminal(&self) -> bool
[src]
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,