TaskHelpers

63 references to TaskHelpers

System.ServiceModel.Http (6)

System\ServiceModel\Channels\HttpChannelFactory.cs (1)

601return TaskHelpers.CompletedTask();

System\ServiceModel\Channels\TransportDuplexSessionChannel.cs (3)

83await TaskHelpers.EnsureDefaultTaskScheduler(); 147await TaskHelpers.EnsureDefaultTaskScheduler(); 189await TaskHelpers.EnsureDefaultTaskScheduler();

System\ServiceModel\Channels\WebSocketTransportDuplexSessionChannel.cs (2)

529await TaskHelpers.EnsureDefaultTaskScheduler(); 1137await TaskHelpers.EnsureDefaultTaskScheduler();

System.ServiceModel.NetFramingBase (6)

System\ServiceModel\Channels\FramingChannels.cs (2)

60await TaskHelpers.EnsureDefaultTaskScheduler(); 273using (TaskHelpers.RunTaskContinuationsOnOurThreads())

System\ServiceModel\Channels\SslStreamSecurityUpgradeProvider.cs (1)

168return TaskHelpers.CompletedTask();

System\ServiceModel\Channels\TransportDuplexSessionChannel.cs (3)

86await TaskHelpers.EnsureDefaultTaskScheduler(); 149await TaskHelpers.EnsureDefaultTaskScheduler(); 191await TaskHelpers.EnsureDefaultTaskScheduler();

System.ServiceModel.Primitives (51)

System\ServiceModel\Channels\BufferedReadStream.cs (2)

230using (TaskHelpers.RunTaskContinuationsOnOurThreads()) 420using (TaskHelpers.RunTaskContinuationsOnOurThreads())

System\ServiceModel\Channels\ChannelFactoryBase.cs (1)

69return TaskHelpers.CompletedTask();

System\ServiceModel\Channels\ClientReliableChannelBinder.cs (1)

295(success, message) = await TaskHelpers.FromAsync<TimeSpan, bool, Message>(channel.BeginTryReceive, channel.EndTryReceive, timeout, null);

System\ServiceModel\Channels\ClientReliableDuplexSessionChannel.cs (4)

747TaskHelpers.WaitForCompletionNoSpin(OnCloseAsync(timeout)); 1123TaskHelpers.WaitForCompletion(OnCloseAsync(timeout)); 1171TaskHelpers.WaitForCompletion(OnOpenAsync(timeout)); 1304TaskHelpers.WaitForCompletionNoSpin(channel.OnCloseOutputSessionAsync(timeout));

System\ServiceModel\Channels\CommunicationObject.cs (10)

225await TaskHelpers.EnsureDefaultTaskScheduler(); 321await TaskHelpers.CallActionAsync(OnClose, timeout); 533await TaskHelpers.EnsureDefaultTaskScheduler(); 571await TaskHelpers.CallActionAsync(OnOpen, timeout); 1003return TaskHelpers.CompletedTask(); 1012return TaskHelpers.CompletedTask(); 1037return TaskHelpers.CallActionAsync(other.Open, timeout); 1067return TaskHelpers.CallActionAsync(other.Close, timeout); 1173await TaskHelpers.EnsureDefaultTaskScheduler(); 1179await TaskHelpers.EnsureDefaultTaskScheduler();

System\ServiceModel\Channels\DuplexChannel.cs (4)

81TaskHelpers.WaitForCompletionNoSpin(SendAsync(message, timeout)); 110return TaskHelpers.WaitForCompletion(ReceiveAsync(timeout)); 141(success, message) = TaskHelpers.WaitForCompletion(TryReceiveAsync(timeout)); 169return TaskHelpers.WaitForCompletion(WaitForMessageAsync(timeout));

System\ServiceModel\Channels\LayeredChannelFactory.cs (1)

194(retVal, message) = await TaskHelpers.FromAsync<TimeSpan, bool, Message>(InnerChannel.BeginTryReceive, InnerChannel.EndTryReceive, timeout, null);

System\ServiceModel\Channels\Message.cs (3)

454return TaskHelpers.CompletedTask(); 473return TaskHelpers.CompletedTask(); 717return TaskHelpers.CompletedTask();

System\ServiceModel\Channels\MtomMessageEncoder.cs (1)

510using (TaskHelpers.RunTaskContinuationsOnOurThreads())

System\ServiceModel\Channels\ReliableChannelBinder.cs (2)

2029(success, message) = await TaskHelpers.FromAsync<TimeSpan, bool, Message>(channel.BeginTryReceive, channel.EndTryReceive, timeout, null); 2104(success, context) = await TaskHelpers.FromAsync<TimeSpan, bool, RequestContext>(channel.BeginTryReceiveRequest, channel.EndTryReceiveRequest, iterationTimeout, null);

System\ServiceModel\Channels\ReliableMessagingHelpers.cs (1)

649await TaskHelpers.EnsureDefaultTaskScheduler();

System\ServiceModel\Channels\ReliableOutputSessionChannel.cs (1)

361TaskHelpers.WaitForCompletionNoSpin(OnSendAsync(message, timeout));

System\ServiceModel\Channels\ReliableRequestSessionChannel.cs (3)

266TaskHelpers.WaitForCompletionNoSpin(OnCloseAsync(timeout)); 383TaskHelpers.WaitForCompletionNoSpin(OnOpenAsync(timeout)); 791expired = !await TaskHelpers.AwaitWithTimeout(_tcs.Task, timeoutHelper.RemainingTime());

System\ServiceModel\Channels\RequestChannel.cs (1)

237await TaskHelpers.EnsureDefaultTaskScheduler();

System\ServiceModel\Channels\SecurityChannelFactory.cs (2)

478await TaskHelpers.EnsureDefaultTaskScheduler(); 623(success, message) = await TaskHelpers.FromAsync<TimeSpan, bool, Message>(InnerDuplexChannel.BeginTryReceive, InnerDuplexChannel.EndTryReceive, timeout, null);

System\ServiceModel\Channels\ServiceChannelFactory.cs (1)

500await TaskHelpers.CallActionAsync(base.OnClose, timeoutHelper.RemainingTime());

System\ServiceModel\Channels\TextMessageEncoder.cs (1)

549await TaskHelpers.EnsureDefaultTaskScheduler();

System\ServiceModel\Channels\TimeoutStream.cs (2)

76await TaskHelpers.EnsureDefaultTaskScheduler(); 119await TaskHelpers.EnsureDefaultTaskScheduler();

System\ServiceModel\ClientBase.cs (2)

296await TaskHelpers.EnsureDefaultTaskScheduler(); 357await TaskHelpers.EnsureDefaultTaskScheduler();

System\ServiceModel\Dispatcher\ChannelDispatcher.cs (2)

457return TaskHelpers.CompletedTask(); 463return TaskHelpers.CompletedTask();

System\ServiceModel\Dispatcher\ListenerHandler.cs (1)

80return TaskHelpers.CompletedTask();

System\ServiceModel\Dispatcher\StreamFormatter.cs (1)

315using (TaskHelpers.RunTaskContinuationsOnOurThreads())

System\ServiceModel\InstanceContext.cs (1)

260return TaskHelpers.CompletedTask();

System\ServiceModel\Security\SecuritySessionClientSettings.cs (3)

1524await TaskHelpers.EnsureDefaultTaskScheduler(); 1616await TaskHelpers.EnsureDefaultTaskScheduler(); 1638await TaskHelpers.EnsureDefaultTaskScheduler();