mirror of
https://github.com/tokio-rs/tokio.git
synced 2026-08-22 00:00:11 +02:00
Carl Lerche
f768163982
This patch adds a new crate: tokio-fs. This crate provides a wrapper around `std` functionality that can only be performed using blocking operations. This primarily includes filesystem operations, but it also includes standard input, output, and error access as these streams cannot be safely switched to non-blocking mode in a portable way. These wrappers call the `std` functions from within a `blocking` annotation which allows the runtime to compensate for the fact that the thread will potentially remain blocked in a system call.
39 lines
947 B
Rust
39 lines
947 B
Rust
use tokio_io::{AsyncRead};
|
|
|
|
use std::io::{self, Read, Stdin as StdStdin};
|
|
|
|
/// A handle to the standard input stream of a process.
|
|
///
|
|
/// The handle implements the [`AsyncRead`] trait, but beware that concurrent
|
|
/// reads of `Stdin` must be executed with care.
|
|
///
|
|
/// Created by the [`stdin`] function.
|
|
///
|
|
/// [`stdin`]: fn.stdin.html
|
|
/// [`AsyncRead`]: trait.AsyncRead.html
|
|
#[derive(Debug)]
|
|
pub struct Stdin {
|
|
std: StdStdin,
|
|
}
|
|
|
|
/// Constructs a new handle to the standard input of the current process.
|
|
///
|
|
/// The returned handle allows reading from standard input from the within the
|
|
/// Tokio runtime.
|
|
pub fn stdin() -> Stdin {
|
|
let std = io::stdin();
|
|
Stdin { std }
|
|
}
|
|
|
|
impl Read for Stdin {
|
|
fn read(&mut self, buf: &mut [u8]) -> io::Result<usize> {
|
|
::would_block(|| self.std.read(buf))
|
|
}
|
|
}
|
|
|
|
impl AsyncRead for Stdin {
|
|
unsafe fn prepare_uninitialized_buffer(&self, _: &mut [u8]) -> bool {
|
|
false
|
|
}
|
|
}
|