pub async fn bind_tcp<T: 'static, Codec: 'static + Clone + Decoder + Encoder<T>>(
endpoint: SocketAddr,
codec: Codec
) -> Result<(TcpFramedSink<T>, TcpFramedStream<Codec>, SocketAddr), Error>Expand description
Create a listening tcp socket, and then as new connections come in, receive their data and forward it to a queue.