Searched defs:server (Results 1 – 11 of 11) sorted by relevance
32 let server = ylong_runtime::spawn(async move { in sdv_buf_reader_read_until() localVariable76 let server = ylong_runtime::spawn(async move { in sdv_buf_reader_read_line() localVariable117 let server = ylong_runtime::spawn(async move { in sdv_buf_reader_split() localVariable156 let server = ylong_runtime::spawn(async move { in sdv_buf_reader_lines() localVariable
107 let server = runtime.spawn(async move { in sdv_tcp_multi_runtime() localVariable175 let server = ylong_runtime::block_on(handle1).unwrap(); in sdv_tcp_drop_out_context() localVariable
30 let server = ylong_runtime::spawn(async move { in sdv_buf_writer_write() localVariable69 let server = ylong_runtime::spawn(async move { in sdv_buf_writer_write_vectored() localVariable
63 let server = ylong_runtime::spawn(async move { in sdv_buf_reader_read_to_string() localVariable
100 let mut server = listener.accept().await.unwrap().0; in sdv_join_set_spawn_io() localVariable
27 let server = match TcpListener::bind(addr).await { in main() localVariable
40 let mut server = socket.accept().await.unwrap().0; in run_server() localVariable
67 …let server = TcpListener::bind("127.0.0.1:0").await.expect("server is failed to bind a address !"); localVariable164 … let server = TcpListener::bind("127.0.0.1:0").expect("server is failed to bind a address !"); localVariable
30 let mut server = TcpListener::bind(addr)?; in main() localVariable
128 …let server = hyper::Server::from_tcp(tcp_listener).expect("build hyper server from tcp listener fa… localVariable
239 let server = TcpListener::bind(addr).await.unwrap(); in ut_tcp_listener_basic() localVariable