Searched refs:tcp_stream (Results 1 – 1 of 1) sorted by relevance
138 pub fn new_and_handshake(tcp_stream: &'a mut T) -> Result<Self> { in new_and_handshake()140 block_on(tcp_stream.write_exact(TCP_HANDSHAKE_MESSAGE))?; in new_and_handshake()141 block_on(tcp_stream.read_exact(&mut handshake[..]))?; in new_and_handshake()143 true => Ok(Self(tcp_stream)), in new_and_handshake()1015 tcp_stream: &mut impl TcpStream, in run_tcp_session()1018 run(&mut TcpTransport::new_and_handshake(tcp_stream)?, fb_impl).await in run_tcp_session()1621 let mut tcp_stream: TestTcpStream = Default::default(); in test_fastboot_tcp() localVariable1622 tcp_stream.add_input(TCP_HANDSHAKE_MESSAGE); in test_fastboot_tcp()1624 tcp_stream.add_length_prefixed_input(b"getvar:max-download-size"); in test_fastboot_tcp()1625 tcp_stream.add_length_prefixed_input( in test_fastboot_tcp()[all …]