Как использовать Tokio для перенаправления стандартного ввода в поток? - PullRequest
Новая
       12

Как использовать Tokio для перенаправления стандартного ввода в поток?

1 голос
/ 17 июня 2019

Я пытаюсь создать клиент, который будет отправлять все данные со стандартного ввода на сервер. Я могу создать клиент, но я не получу результат, если введу текст, хотя я жду сообщения «отправить данные» или ошибки. 

use tokio::{
    codec, io as aio, net as anet,
    prelude::{future::Future, stream::Stream},
};

fn main() {
    let address = "127.0.0.1:4732"
        .parse()
        .expect("could not to parse address");

    let stdin_stream = {
        let stdin = aio::stdin();
        let codec = codec::LinesCodec::new();
        codec::FramedRead::new(stdin, codec)
    };

    let client = anet::TcpStream::connect(&address)
        .map_err(|err| eprintln!("connect error: {}", err))
        .map(|stream| {
            let codec = codec::LinesCodec::new();
            codec::FramedWrite::new(stream, codec)
        })
        .and_then(move |sink| {
            stdin_stream
                .forward(sink)
                .map_err(|err| eprintln!("could not forward stdin to stream: {}", err))
                .map(|_| println!("send data"))
        });

    tokio::run(client);
}
...