Searched refs:StreamSocket (Results 1 – 3 of 3) sorted by relevance
48 pub struct StreamSocket { struct53 impl StreamSocket { impl55 pub fn connect(sockaddr: &str) -> result::Result<StreamSocket, StreamSocketError> { in connect() argument97 impl io::Read for StreamSocket { implementation110 impl io::Write for StreamSocket { implementation136 impl AsRawFd for StreamSocket { implementation142 impl From<TcpStream> for StreamSocket { implementation144 StreamSocket { fd: stream.into_raw_fd(), shut_down: false } in from()148 impl From<UnixStream> for StreamSocket { implementation150 StreamSocket { fd: stream.into_raw_fd(), shut_down: false } in from()[all …]
24 use crate::stream::StreamSocket;60 local: StreamSocket,61 remote: StreamSocket,64 fn forward(from_stream: &mut StreamSocket, to_stream: &mut StreamSocket) -> Result<bool> { in forward() argument79 pub fn new(local: StreamSocket, remote: StreamSocket) -> Self { in new() argument98 pub fn local_stream(&self) -> &StreamSocket { in local_stream() argument103 pub fn remote_stream(&self) -> &StreamSocket { in remote_stream() argument
25 use forwarder::stream::{StreamSocket, StreamSocketError};59 fn run_forwarder(local_stream: StreamSocket, remote_stream: StreamSocket) -> Result<()> { in run_forwarder() argument118 let local_stream = StreamSocket::connect(&args.local_sockaddr).map_err(Error::ConnectSocket)?; in main()120 StreamSocket::connect(&args.remote_sockaddr).map_err(Error::ConnectSocket)?; in main()