Searched defs:tcp (Results 1 – 10 of 10) sorted by relevance
34 let tcp = TcpListener::bind(addr).await.unwrap(); in sdv_buf_reader_read_until() localVariable50 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_reader_read_until() localVariable54 let mut tcp = tcp.unwrap(); in sdv_buf_reader_read_until() localVariable78 let tcp = TcpListener::bind(addr).await.unwrap(); in sdv_buf_reader_read_line() localVariable92 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_reader_read_line() localVariable96 let mut tcp = tcp.unwrap(); in sdv_buf_reader_read_line() localVariable119 let tcp = TcpListener::bind(addr).await.unwrap(); in sdv_buf_reader_split() localVariable131 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_reader_split() localVariable135 let mut tcp = tcp.unwrap(); in sdv_buf_reader_split() localVariable158 let tcp = TcpListener::bind(addr).await.unwrap(); in sdv_buf_reader_lines() localVariable[all …]
109 let tcp = TcpListener::bind(addr).await.unwrap(); in sdv_tcp_multi_runtime() localVariable121 let mut tcp = TcpStream::connect(addr).await; in sdv_tcp_multi_runtime() localVariable125 let mut tcp = tcp.unwrap(); in sdv_tcp_multi_runtime() localVariable149 let tcp = TcpListener::bind("127.0.0.1:8200").await.unwrap(); in sdv_tcp_drop_out_context() localVariable161 let mut tcp = TcpStream::connect("127.0.0.1:8200").await; in sdv_tcp_drop_out_context() localVariable165 let mut tcp = tcp.unwrap(); in sdv_tcp_drop_out_context() localVariable
32 let tcp = TcpListener::bind(addr).await.unwrap(); in sdv_buf_writer_write() localVariable43 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_writer_write() localVariable47 let tcp = tcp.unwrap(); in sdv_buf_writer_write() localVariable71 let tcp = TcpListener::bind(addr).await.unwrap(); in sdv_buf_writer_write_vectored() localVariable82 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_writer_write_vectored() localVariable86 let tcp = tcp.unwrap(); in sdv_buf_writer_write_vectored() localVariable
65 let tcp = TcpListener::bind(addr).await.unwrap(); in sdv_buf_reader_read_to_string() localVariable76 let mut tcp = TcpStream::connect(addr).await; in sdv_buf_reader_read_to_string() localVariable80 let mut tcp = tcp.unwrap(); in sdv_buf_reader_read_to_string() localVariable
110 let mut tcp = TcpStream::connect(addr).await; in sdv_join_set_spawn_io() localVariable
26 let tcp = tokioTcpListener::bind(addr).await.unwrap(); localVariable39 let mut tcp = tokioTcpStream::connect(addr.clone()).await; localVariable43 let mut tcp = tcp.unwrap(); localVariable78 let tcp = TcpListener::bind(addr).await.unwrap(); localVariable91 let mut tcp = TcpStream::connect(addr).await; localVariable95 let mut tcp = tcp.unwrap(); localVariable
25 let tcp = TcpListener::bind(addr).await.unwrap(); in ylong_tcp_server() localVariable38 let mut tcp = TcpStream::connect(addr).await; in ylong_tcp_client() localVariable42 let mut tcp = tcp.unwrap(); in ylong_tcp_client() localVariable
14 mod tcp; module
237 let tcp = TcpListener::bind(addr).await.unwrap(); localVariable250 let mut tcp = TcpStream::connect(addr).await; localVariable254 let mut tcp = tcp.unwrap(); localVariable
150 let mut tcp = tcp_stream(&addr).await?; in connect() localVariable