在未来链中的tokio::net::TcpStream出现之前,我如何阅读_?

TcpStream 直到我遇到一个“\0”。 问题是 tokio::io::read_until BufRead .

fn poll(&mut self) -> Poll<(), Self::Error> {
    match self.listener.poll_accept()? {
        Async::Ready((stream, _addr)) => {
            let task = tokio::io::read_until(stream, 0, vec![0u8; buffer])
                 .map_err(|_| ...)
                 .map(|_| ...);
            tokio::spawn(task);
        }
        Async::NotReady => return Ok(Async::NotReady),
    }
}

如何从数据库中读取数据 TCP流 这边