Searched refs:task (Results 1 – 2 of 2) sorted by relevance
429 var task = channelTaskFactory.FromAsync( in TrySendMessage()433 return WaitSendOrReceiveTask(task, size); in TrySendMessage()469 var task = channelTaskFactory.FromAsync( in TryReceive()473 var isSuccess = WaitSendOrReceiveTask(task, size); in TryReceive()493 private bool WaitSendOrReceiveTask(Task<int> task, int size) in WaitSendOrReceiveTask() argument497 task.Wait(timeout, channelTaskFactory.CancellationToken); in WaitSendOrReceiveTask()512 if(task.Status != TaskStatus.RanToCompletion) in WaitSendOrReceiveTask()514 if(task.Status == TaskStatus.Canceled) in WaitSendOrReceiveTask()520 … logger.DebugLog("Error while trying to Send/Receive. Task status: {0}", task.Status); in WaitSendOrReceiveTask()525 if(task.Result != size) in WaitSendOrReceiveTask()[all …]
186 self.task: Awaitable[Any]236 self.task = result if async_ else None249 self.task = result if async_ else None295 await self.task300 self.task = self.process.expect([r".+\n", r"\(gdb\)"], timeout, async_=True)301 await self.task
