Searched defs:listener (Results 1 – 15 of 15) sorted by relevance
114 let listener = TcpListener::bind(addr).await.unwrap(); in main() localVariable158 let listener = tokioTcpListener::bind("127.0.0.1:9082").await.unwrap(); in main() localVariable
16 mod listener; module
14 mod listener; module
45 let listener = unsafe { TcpListener::from_raw_socket(socket.as_raw_socket() as _) }; in bind() localVariable
17 mod listener; module
45 let listener = ylong_io::UnixListener::bind(path)?; in bind() localVariable88 let listener = ylong_io::UnixListener::from_std(listener); in from_std() localVariable
137 let listener = TcpListener::bind(addr).await.unwrap(); in ut_test_borrow_half() localVariable183 let listener = TcpListener::bind(addr).await.unwrap(); in ut_test_owned_half() localVariable229 let listener = TcpListener::bind(addr).await.unwrap(); in ut_test_borrow_half_vector() localVariable282 let listener = TcpListener::bind(addr).await.unwrap(); in ut_test_owned_half_vector() localVariable
653 let listener = TcpListener::bind(addr).await.unwrap(); in ut_tcp_stream_basic() localVariable694 let listener = TcpListener::bind(addr).await.unwrap(); in ut_tcp_stream_peek() localVariable728 let listener = TcpListener::bind(addr).await.unwrap(); in ut_tcp_stream_try() localVariable
37 let listener = UnixListener::bind(PATH).unwrap(); in uds_stream_test() localVariable
60 let listener = TcpListener::bind(addr).await; in sdv_tcp_global_runtime() localVariable66 let listener = listener.unwrap(); in sdv_tcp_global_runtime() localVariable
99 let listener = TcpListener::bind(addr).await.unwrap(); in sdv_join_set_spawn_io() localVariable
165 let listener = loop { localVariable
564 auto listener = new WorkerListener(env, callback, mode); in AddListener() local986 auto listener = new WorkerListener(env, callback, PERMANENT); in ParentPortAddEventListener() local1809 std::string listener(type); in HandleEventListeners() local1912 void Worker::AddListenerInner(napi_env env, const char* type, const WorkerListener* listener) in AddListenerInner()1968 WorkerListener* listener = *item; in RemoveAllListenerInner() local2083 … Worker::ParentPortAddListenerInner(napi_env env, const char* type, const WorkerListener* listener) in ParentPortAddListenerInner()2107 WorkerListener* listener = *item; in ParentPortRemoveAllListenerInner() local2140 std::string listener(type); in ParentPortHandleEventListeners() local