Struct std::old_io::ChanReaderUnstable

pub struct ChanReader {
    // some fields omitted
}

Allows reading from a rx.

Example

fn main() { use std::sync::mpsc::channel; use std::old_io::ChanReader; let (tx, rx) = channel(); drop(tx); let mut reader = ChanReader::new(rx); let mut buf = [0u8; 100]; match reader.read(&mut buf) { Ok(nread) => println!("Read {} bytes", nread), Err(e) => println!("read error: {}", e), } }

use std::sync::mpsc::channel;
use std::old_io::ChanReader;

let (tx, rx) = channel();
let mut reader = ChanReader::new(rx);

let mut buf = [0u8; 100];
match reader.read(&mut buf) {
    Ok(nread) => println!("Read {} bytes", nread),
    Err(e) => println!("read error: {}", e),
}

Methods

impl ChanReader

fn new(rx: Receiver<Vec<u8>>) -> ChanReader

Wraps a Port in a ChanReader structure

Trait Implementations

impl Buffer for ChanReader

fn fill_buf<'a>(&'a mut self) -> IoResult<&'a [u8]>

fn consume(&mut self, amt: usize)

fn read_line(&mut self) -> IoResult<String>

fn read_until(&mut self, byte: u8) -> IoResult<Vec<u8>>

fn read_char(&mut self) -> IoResult<char>

impl Reader for ChanReader

fn read(&mut self, buf: &mut [u8]) -> IoResult<usize>

fn read_at_least(&mut self, min: usize, buf: &mut [u8]) -> IoResult<usize>

fn read_byte(&mut self) -> IoResult<u8>

fn push(&mut self, len: usize, buf: &mut Vec<u8>) -> IoResult<usize>

fn push_at_least(&mut self, min: usize, len: usize, buf: &mut Vec<u8>) -> IoResult<usize>

fn read_exact(&mut self, len: usize) -> IoResult<Vec<u8>>

fn read_to_end(&mut self) -> IoResult<Vec<u8>>

fn read_to_string(&mut self) -> IoResult<String>

fn read_le_uint_n(&mut self, nbytes: usize) -> IoResult<u64>

fn read_le_int_n(&mut self, nbytes: usize) -> IoResult<i64>

fn read_be_uint_n(&mut self, nbytes: usize) -> IoResult<u64>

fn read_be_int_n(&mut self, nbytes: usize) -> IoResult<i64>

fn read_le_uint(&mut self) -> IoResult<usize>

fn read_le_int(&mut self) -> IoResult<isize>

fn read_be_uint(&mut self) -> IoResult<usize>

fn read_be_int(&mut self) -> IoResult<isize>

fn read_be_u64(&mut self) -> IoResult<u64>

fn read_be_u32(&mut self) -> IoResult<u32>

fn read_be_u16(&mut self) -> IoResult<u16>

fn read_be_i64(&mut self) -> IoResult<i64>

fn read_be_i32(&mut self) -> IoResult<i32>

fn read_be_i16(&mut self) -> IoResult<i16>

fn read_be_f64(&mut self) -> IoResult<f64>

fn read_be_f32(&mut self) -> IoResult<f32>

fn read_le_u64(&mut self) -> IoResult<u64>

fn read_le_u32(&mut self) -> IoResult<u32>

fn read_le_u16(&mut self) -> IoResult<u16>

fn read_le_i64(&mut self) -> IoResult<i64>

fn read_le_i32(&mut self) -> IoResult<i32>

fn read_le_i16(&mut self) -> IoResult<i16>

fn read_le_f64(&mut self) -> IoResult<f64>

fn read_le_f32(&mut self) -> IoResult<f32>

fn read_u8(&mut self) -> IoResult<u8>

fn read_i8(&mut self) -> IoResult<i8>