use std::io;
use std::net::SocketAddr;
use futures::{Future, Sink, Stream};
use tokio_core::net::TcpStream;
use tokio_core::reactor::Handle;
use tokio_io::AsyncRead;
use error;
use resp;
const DEFAULT_BUFFER_SIZE: usize = 100;
pub fn connect(addr: &SocketAddr,
handle: &Handle)
-> Box<Future<Item = ClientConnection, Error = io::Error>> {
let con = TcpStream::connect(addr, handle).map(move |socket| {
let framed = socket.framed(resp::RespCodec);
let (write_f, read_f) = framed.split();
let write_b = write_f.buffer(DEFAULT_BUFFER_SIZE);
ClientConnection {
sender: Box::new(write_b),
receiver: Box::new(read_f),
}
});
Box::new(con)
}
pub struct ClientConnection {
pub sender: Box<Sink<SinkItem = resp::RespValue, SinkError = io::Error>>,
pub receiver: Box<Stream<Item = resp::RespValue, Error = error::Error>>,
}