Searched refs:remote_stream (Results 1 – 3 of 3) sorted by relevance
59 fn run_forwarder(local_stream: StreamSocket, remote_stream: StreamSocket) -> Result<()> { in run_forwarder()67 poll_ctx.add(&remote_stream, Token::RemoteStreamReadable).map_err(Error::PollContextAdd)?; in run_forwarder()69 let mut forwarder = ForwarderSession::new(local_stream, remote_stream); in run_forwarder()88 .delete(forwarder.remote_stream()) in run_forwarder()119 let remote_stream = in main() localVariable122 run_forwarder(local_stream, remote_stream) in main()
239 .add(session.remote_stream(), Token::RemoteSocket(tag)) in accept_connection()268 poll_ctx.delete(session.remote_stream()).map_err(Error::PollContextDelete)?; in forward_from_remote()
103 pub fn remote_stream(&self) -> &StreamSocket { in remote_stream() method