[−][src]Macro async_stream::try_stream
Asynchronous fallible stream
See crate documentation for more details.
Examples
#![feature(async_await)] use tokio::net::{TcpListener, TcpStream}; use tokio::prelude::*; use async_stream::try_stream; use std::io; use std::net::SocketAddr; fn bind_and_accept(addr: SocketAddr) -> impl Stream<Item = io::Result<TcpStream>> { try_stream! { let mut listener = TcpListener::bind(&addr)?; loop { let (stream, addr) = listener.accept().await?; println!("received on {:?}", addr); yield stream; } } }