Function socket_bench_server::start_stream_server
source · pub fn start_stream_server<T, L, I, S, E>(
executor: &Handle,
transport: T,
listen_addr: NetworkAddress
) -> NetworkAddresswhere
T: Transport<Output = S, Error = E, Listener = L, Inbound = I>,
L: Stream<Item = Result<(I, NetworkAddress), E>> + Unpin + Send + 'static,
I: Future<Output = Result<S, E>> + Send + 'static,
S: AsyncRead + AsyncWrite + Unpin + Send + 'static,
E: Error + Send + Sync + 'static,