mirror of
https://github.com/tokio-rs/tokio.git
synced 2025-10-01 12:20:39 +00:00
rename ReadOnce back to Read, but keep it exposed
This commit is contained in:
parent
da37ad0948
commit
6789527952
@ -3,7 +3,7 @@
|
|||||||
//! Contains various combinators to work with I/O objects and type definitions
|
//! Contains various combinators to work with I/O objects and type definitions
|
||||||
//! as well.
|
//! as well.
|
||||||
|
|
||||||
use std::io::{self, Read, Write};
|
use std::io;
|
||||||
|
|
||||||
use futures::{BoxFuture, Async, Poll};
|
use futures::{BoxFuture, Async, Poll};
|
||||||
use futures::stream::BoxStream;
|
use futures::stream::BoxStream;
|
||||||
@ -44,7 +44,7 @@ pub use self::copy::{copy, Copy};
|
|||||||
pub use self::flush::{flush, Flush};
|
pub use self::flush::{flush, Flush};
|
||||||
pub use self::read_exact::{read_exact, ReadExact};
|
pub use self::read_exact::{read_exact, ReadExact};
|
||||||
pub use self::read_to_end::{read_to_end, ReadToEnd};
|
pub use self::read_to_end::{read_to_end, ReadToEnd};
|
||||||
pub use self::read::{read, ReadOnce};
|
pub use self::read::{read, Read};
|
||||||
pub use self::read_until::{read_until, ReadUntil};
|
pub use self::read_until::{read_until, ReadUntil};
|
||||||
pub use self::split::{ReadHalf, WriteHalf};
|
pub use self::split::{ReadHalf, WriteHalf};
|
||||||
pub use self::window::Window;
|
pub use self::window::Window;
|
||||||
@ -61,7 +61,7 @@ pub use self::write_all::{write_all, WriteAll};
|
|||||||
/// value that indicates "would block" the current future's task is arranged to
|
/// value that indicates "would block" the current future's task is arranged to
|
||||||
/// receive a notification when the method would otherwise not indicate that it
|
/// receive a notification when the method would otherwise not indicate that it
|
||||||
/// would block.
|
/// would block.
|
||||||
pub trait Io: Read + Write {
|
pub trait Io: io::Read + io::Write {
|
||||||
/// Tests to see if this I/O object may be readable.
|
/// Tests to see if this I/O object may be readable.
|
||||||
///
|
///
|
||||||
/// This method returns an `Async<()>` indicating whether the object
|
/// This method returns an `Async<()>` indicating whether the object
|
||||||
|
@ -1,4 +1,3 @@
|
|||||||
use std::io::{Error, Read};
|
|
||||||
use std::mem;
|
use std::mem;
|
||||||
|
|
||||||
use futures::{Future, Poll};
|
use futures::{Future, Poll};
|
||||||
@ -16,32 +15,32 @@ enum State<R, T> {
|
|||||||
///
|
///
|
||||||
/// The returned future will resolve to both the I/O stream and the buffer
|
/// The returned future will resolve to both the I/O stream and the buffer
|
||||||
/// as well as the number of bytes read once the read operation is completed.
|
/// as well as the number of bytes read once the read operation is completed.
|
||||||
pub fn read<R, T>(rd: R, buf: T) -> ReadOnce<R, T>
|
pub fn read<R, T>(rd: R, buf: T) -> Read<R, T>
|
||||||
where R: Read,
|
where R: ::std::io::Read,
|
||||||
T: AsMut<[u8]>
|
T: AsMut<[u8]>
|
||||||
{
|
{
|
||||||
ReadOnce { state: State::Pending { rd: rd, buf: buf } }
|
Read { state: State::Pending { rd: rd, buf: buf } }
|
||||||
}
|
}
|
||||||
|
|
||||||
/// A future which can be used to easily read available number of bytes to fill
|
/// A future which can be used to easily read available number of bytes to fill
|
||||||
/// a buffer.
|
/// a buffer.
|
||||||
///
|
///
|
||||||
/// Created by the [`read`] function.
|
/// Created by the [`read`] function.
|
||||||
pub struct ReadOnce<R, T> {
|
pub struct Read<R, T> {
|
||||||
state: State<R, T>,
|
state: State<R, T>,
|
||||||
}
|
}
|
||||||
|
|
||||||
impl<R, T> Future for ReadOnce<R, T>
|
impl<R, T> Future for Read<R, T>
|
||||||
where R: Read,
|
where R: ::std::io::Read,
|
||||||
T: AsMut<[u8]>
|
T: AsMut<[u8]>
|
||||||
{
|
{
|
||||||
type Item = (R, T, usize);
|
type Item = (R, T, usize);
|
||||||
type Error = Error;
|
type Error = ::std::io::Error;
|
||||||
|
|
||||||
fn poll(&mut self) -> Poll<(R, T, usize), Error> {
|
fn poll(&mut self) -> Poll<(R, T, usize), ::std::io::Error> {
|
||||||
let nread = match self.state {
|
let nread = match self.state {
|
||||||
State::Pending { ref mut rd, ref mut buf } => try_nb!(rd.read(&mut buf.as_mut()[..])),
|
State::Pending { ref mut rd, ref mut buf } => try_nb!(rd.read(&mut buf.as_mut()[..])),
|
||||||
State::Empty => panic!("poll a ReadOnce after it's done"),
|
State::Empty => panic!("poll a Read after it's done"),
|
||||||
};
|
};
|
||||||
|
|
||||||
match mem::replace(&mut self.state, State::Empty) {
|
match mem::replace(&mut self.state, State::Empty) {
|
||||||
|
Loading…
x
Reference in New Issue
Block a user