x.rs

-

let (writer, mut reader) = stream.framed(LineCodec).split();
let server = reader.and_then(|x| writer.send(x));
handle.spawn(server);





handle.spawn(server);
       ^^^^^ the trait `futures::Future` is not implemented for `futures::stream::Then<futures::stream::AndThen<futures::stream::SplitStream<tokio_io::codec::Framed<tokio_core::net::TcpStream, LineCodec>>, [closure@src/main.rs:125:42: 125:60 writer:_], futures::sink::Send<futures::stream::SplitSink<tokio_io::codec::Framed<tokio_core::net::TcpStream, LineCodec>>>>, [closure@src/main.rs:125:67: 125:77], std::result::Result<(), _>>`