111 …LE_AcceptStreamClient(LE_GetDefaultLoop(), (TaskHandle)serverTask_, &clientTaskHandle, &streamInfo…  in StreamTaskTest()
115         ((StreamConnectTask *)clientTaskHandle)->stream.base.handleEvent(LE_GetDefaultLoop(),  in StreamTaskTest()
117         ((StreamConnectTask *)clientTaskHandle)->stream.base.handleEvent(LE_GetDefaultLoop(),  in StreamTaskTest()
123         LE_CreateStreamClient(LE_GetDefaultLoop(), &clientTaskHandlec, &streamInfo);  in StreamTaskTest()
130         LE_CreateStreamClient(LE_GetDefaultLoop(), &clientTaskHandled, &streamInfo);  in StreamTaskTest()
142         LE_CreateStreamServer(LE_GetDefaultLoop(), &serverTask_, &info);  in LeTaskTest()
146 … ((StreamServerTask *)serverTask_)->base.handleEvent(LE_GetDefaultLoop(), serverTask_, Event_Read);  in LeTaskTest()
159         BufferHandle handle = LE_CreateBuffer(LE_GetDefaultLoop(), 1 + sizeof(eventId));  in LeTaskTest()
162 …((StreamConnectTask *)client)->stream.base.handleEvent(LE_GetDefaultLoop(), (TaskHandle)(client), …  in LeTaskTest()
166 …((StreamConnectTask *)client)->recvMessage(LE_GetDefaultLoop(), reinterpret_cast<uint8_t *>(reques…  in LeTaskTest()
174         LE_FreeBuffer(LE_GetDefaultLoop(), (TaskHandle)client, nullptr);  in LeTaskTest()
179         ProcessEvent((EventLoop *)LE_GetDefaultLoop(), 1, Event_Read);  in ProcessEventTest()
182         BaseTask *task = CreateTask(LE_GetDefaultLoop(), testfd, &info, sizeof(StreamClientTask));  in ProcessEventTest()
185             ProcessEvent((EventLoop *)LE_GetDefaultLoop(), testfd, Event_Read);  in ProcessEventTest()
191         LE_CreateAsyncTask(LE_GetDefaultLoop(), &asynHandle, ProcessAsyncEvent);  in ProcessasynEvent()
195 …((AsyncEventTask *)asynHandle)->stream.base.handleEvent(LE_GetDefaultLoop(), asynHandle, Event_Rea…  in ProcessasynEvent()
196 …((AsyncEventTask *)asynHandle)->stream.base.handleEvent(LE_GetDefaultLoop(), asynHandle, Event_Wri…  in ProcessasynEvent()
197         LE_StopAsyncTask(LE_GetDefaultLoop(), asynHandle);  in ProcessasynEvent()
207         LE_StartWatcher(LE_GetDefaultLoop(), &handle, &info, nullptr);  in ProcessWatcherTask()
211 …    ((WatcherTask *)handle)->base.handleEvent(LE_GetDefaultLoop(), (TaskHandle)handle, Event_Read);  in ProcessWatcherTask()
212         ((WatcherTask *)handle)->base.handleEvent(LE_GetDefaultLoop(), (TaskHandle)handle, 0);  in ProcessWatcherTask()
214 …    ((WatcherTask *)handle)->base.handleEvent(LE_GetDefaultLoop(), (TaskHandle)handle, Event_Read);  in ProcessWatcherTask()
215         LE_RemoveWatcher(LE_GetDefaultLoop(), handle);  in ProcessWatcherTask()
226         LE_CreateStreamServer(LE_GetDefaultLoop(), &serverTask, &info);  in CreateSocketTest()
232         OnIncomingConnect(LE_GetDefaultLoop(), serverTask);  in CreateSocketTest()
317     LE_StartWatcher(LE_GetDefaultLoop(), nullptr, &info, nullptr);
318     LE_StartWatcher(LE_GetDefaultLoop(), nullptr, nullptr, nullptr);