Searched refs:tcp_stream (Results 1 – 1 of 1) sorted by relevance
132 pub fn new_and_handshake(tcp_stream: &'a mut dyn TcpStream) -> Result<Self, TransportError> { in new_and_handshake()134 tcp_stream.write_exact(TCP_HANDSHAKE_MESSAGE)?; in new_and_handshake()135 tcp_stream.read_exact(&mut handshake[..])?; in new_and_handshake()137 true => Ok(Self(tcp_stream)), in new_and_handshake()715 tcp_stream: &mut dyn TcpStream, in run_tcp_session()718 self.run(&mut TcpTransport::new_and_handshake(tcp_stream)?, fb_impl) in run_tcp_session()1551 let mut tcp_stream: TestTcpStream = Default::default(); in test_fastboot_tcp() localVariable1552 tcp_stream.add_input(TCP_HANDSHAKE_MESSAGE); in test_fastboot_tcp()1554 tcp_stream.add_length_prefixed_input(b"getvar:max-download-size"); in test_fastboot_tcp()1555 tcp_stream.add_length_prefixed_input( in test_fastboot_tcp()[all …]