1 type derived from TaskCompletionSource
mscorlib (1)
system\threading\Tasks\ConcurrentExclusiveSchedulerPair.cs (1)
474private sealed class CompletionState : TaskCompletionSource<VoidTaskResult>
92 instantiations of TaskCompletionSource
System (20)
net\System\Net\mail\SmtpClient.cs (1)
731var tcs = new TaskCompletionSource<object>();
net\System\Net\NetworkInformation\ping.cs (1)
545var tcs = new TaskCompletionSource<PingReply>();
net\System\Net\webclient.cs (9)
2552var tcs = new TaskCompletionSource<string>(address); 2582var tcs = new TaskCompletionSource<Stream>(address); 2627var tcs = new TaskCompletionSource<Stream>(address); 2676var tcs = new TaskCompletionSource<string>(address); 2707var tcs = new TaskCompletionSource<byte[]>(address); 2738var tcs = new TaskCompletionSource<object>(address); 2787var tcs = new TaskCompletionSource<byte[]>(address); 2836var tcs = new TaskCompletionSource<byte[]>(address); 2888var tcs = new TaskCompletionSource<byte[]>(address);
net\System\Net\WebSockets\WebSocketBase.cs (2)
809m_CloseReceivedTaskCompletionSource = new TaskCompletionSource<object>(); 1501m_CloseReceivedTaskCompletionSource = new TaskCompletionSource<object>();
net\System\Net\WebSockets\WebSocketConnectionStream.cs (3)
656m_WriteTaskCompletionSource = new TaskCompletionSource<object>(); 708m_WriteTaskCompletionSource = new TaskCompletionSource<object>(); 767m_ReadTaskCompletionSource = new TaskCompletionSource<int>();
net\System\Net\WebSockets\WebSocketHttpListenerDuplexStream.cs (4)
167m_ReadTaskCompletionSource = new TaskCompletionSource<int>(); 384m_WriteTaskCompletionSource = new TaskCompletionSource<object>(); 454m_WriteTaskCompletionSource = new TaskCompletionSource<object>(); 637m_WriteTaskCompletionSource = new TaskCompletionSource<object>();
System.Data (52)
fx\src\data\System\Data\Common\AdapterUtil.cs (2)
55TaskCompletionSource<T> completion = new TaskCompletionSource<T>(); 61TaskCompletionSource<T> completion = new TaskCompletionSource<T>();
fx\src\data\System\Data\Common\DBConnection.cs (1)
185TaskCompletionSource<object> taskCompletionSource = new TaskCompletionSource<object>();
fx\src\data\System\Data\ProviderBase\DbConnectionFactory.cs (1)
179TaskCompletionSource<DbConnectionInternal> source = new TaskCompletionSource<DbConnectionInternal>();
fx\src\data\System\Data\SqlClient\SqlBulkCopy.cs (13)
1018TaskCompletionSource<bool> tcs = new TaskCompletionSource<bool>(); 1614TaskCompletionSource<object> source = new TaskCompletionSource<object>(); 1751TaskCompletionSource<object> tcs = new TaskCompletionSource<object>(); 2028source = new TaskCompletionSource<object>(); 2129tcs = new TaskCompletionSource<object>(); 2183source = new TaskCompletionSource<object>(); 2192source = source ?? new TaskCompletionSource<object>(); 2258source = new TaskCompletionSource<object>(); 2310source = new TaskCompletionSource<object>(); 2353source = new TaskCompletionSource<object>(); 2480source = new TaskCompletionSource<object>(); 2581TaskCompletionSource<object> cancellableReconnectTS = new TaskCompletionSource<object>(); 2666source = new TaskCompletionSource<object>(); //creating the completion source/Task that we pass to application
fx\src\data\System\Data\SqlClient\SqlCommand.cs (13)
1254TaskCompletionSource<object> globalCompletion = new TaskCompletionSource<object>(stateObject); 1255TaskCompletionSource<object> localCompletion = new TaskCompletionSource<object>(stateObject); 1745TaskCompletionSource<object> globalCompletion = new TaskCompletionSource<object>(stateObject); 1746TaskCompletionSource<object> localCompletion = new TaskCompletionSource<object>(stateObject); 2138TaskCompletionSource<object> globalCompletion = new TaskCompletionSource<object>(stateObject); 2139TaskCompletionSource<object> localCompletion = new TaskCompletionSource<object>(stateObject); 2410TaskCompletionSource<int> source = new TaskCompletionSource<int>(); 2474TaskCompletionSource<SqlDataReader> source = new TaskCompletionSource<SqlDataReader>(); 2515TaskCompletionSource<object> source = new TaskCompletionSource<object>(); 2578TaskCompletionSource<XmlReader> source = new TaskCompletionSource<XmlReader>(); 3068TaskCompletionSource<object> completion = new TaskCompletionSource<object>(); 4282TaskCompletionSource<object> completion = new TaskCompletionSource<object>(); 4354TaskCompletionSource<object> completion = new TaskCompletionSource<object>();
fx\src\data\System\Data\SqlClient\SqlConnection.cs (2)
1404TaskCompletionSource<DbConnectionInternal> completion = new TaskCompletionSource<DbConnectionInternal>(transaction); 1405TaskCompletionSource<object> result = new TaskCompletionSource<object>();
fx\src\data\System\Data\SqlClient\SqlDataReader.cs (11)
3937TaskCompletionSource<bool> source = new TaskCompletionSource<bool>(); 4000TaskCompletionSource<int> source = new TaskCompletionSource<int>(); 4006TaskCompletionSource<int> source = new TaskCompletionSource<int>(); 4020TaskCompletionSource<int> source = new TaskCompletionSource<int>(); 4112source = new TaskCompletionSource<int>(); 4263TaskCompletionSource<bool> source = new TaskCompletionSource<bool>(); 4383TaskCompletionSource<bool> source = new TaskCompletionSource<bool>(); 4484TaskCompletionSource<T> source = new TaskCompletionSource<T>(); 4570TaskCompletionSource<T> source = new TaskCompletionSource<T>(); 4578TaskCompletionSource<T> exceptionSource = new TaskCompletionSource<T>(); 4613TaskCompletionSource<T> source = new TaskCompletionSource<T>();
fx\src\data\System\Data\SqlClient\SqlSequentialStream.cs (1)
157TaskCompletionSource<int> completion = new TaskCompletionSource<int>();
fx\src\data\System\Data\SqlClient\SqlSequentialTextReader.cs (1)
130TaskCompletionSource<int> completion = new TaskCompletionSource<int>();
fx\src\data\System\Data\SqlClient\SqlUtil.cs (1)
38TaskCompletionSource<object> completion = new TaskCompletionSource<object>();
fx\src\data\System\Data\SqlClient\TdsParser.cs (2)
8540completion = new TaskCompletionSource<object>(); 8586completion = new TaskCompletionSource<object>();
fx\src\data\System\Data\SqlClient\TdsParserStateObject.cs (4)
1916ReadSni(new TaskCompletionSource<object>()); 2680_writeCompletionSource = new TaskCompletionSource<object>(); 2766completion = new TaskCompletionSource<object>(); 2927_writeCompletionSource = new TaskCompletionSource<object>();
System.ServiceModel (4)
System\ServiceModel\Channels\HttpPipeline.cs (1)
491this.channelModelIntegrationHandlerTask = new TaskCompletionSource<HttpResponseMessage>();
System\ServiceModel\Channels\WebSocketTransportDuplexSessionChannel.cs (2)
835this.receiveTask = new TaskCompletionSource<object>(); 854this.streamWaitTask = new TaskCompletionSource<object>();
System\ServiceModel\Dispatcher\TaskMethodInvoker.cs (1)
283var tcs = new TaskCompletionSource<TResult>(state);
System.ServiceModel.Activation (2)
System\ServiceModel\Activation\HostedHttpContext.cs (2)
89this.webSocketContextTaskSource = new TaskCompletionSource<WebSocketContext>(); 119this.webSocketWaitingTask = new TaskCompletionSource<object>();
System.ServiceModel.Discovery (2)
System\ServiceModel\Discovery\DiscoveryClient.cs (2)
438TaskCompletionSource<FindResponse> taskCompletionSource = new TaskCompletionSource<FindResponse>(); 459TaskCompletionSource<ResolveResponse> taskCompletionSource = new TaskCompletionSource<ResolveResponse>();
System.ServiceModel.Internals (2)
System\Runtime\TaskExtensions.cs (2)
25var tcs = new TaskCompletionSource<T>(state); 67var tcs = new TaskCompletionSource<object>(state);
System.Web (9)
AspNetSynchronizationContextBase.cs (1)
44TaskCompletionSource<object> tcs = new TaskCompletionSource<object>();
Hosting\ApplicationManager.cs (1)
647TaskCompletionSource<ApplicationResumeStateContainer> tcs = new TaskCompletionSource<ApplicationResumeStateContainer>();
UI\PageAsyncTaskApm.cs (1)
34TaskCompletionSource<object> taskCompletionSource = new TaskCompletionSource<object>();
Util\CountdownTask.cs (1)
21private readonly TaskCompletionSource<object> _tcs = new TaskCompletionSource<object>();
Util\SynchronizationHelper.cs (2)
82TaskCompletionSource<object> tcs = new TaskCompletionSource<object>(); 181TaskCompletionSource<Task> tcs = new TaskCompletionSource<Task>();
WebSockets\WebSocketPipe.cs (3)
40TaskCompletionSource<object> tcs = new TaskCompletionSource<object>(); 86TaskCompletionSource<object> tcs = new TaskCompletionSource<object>(); 119TaskCompletionSource<WebSocketReceiveResult> tcs = new TaskCompletionSource<WebSocketReceiveResult>();
WindowsBase (1)
Base\System\Windows\Threading\DispatcherOperationTaskSource.cs (1)
29_taskCompletionSource = new TaskCompletionSource<TResult>(new DispatcherOperationTaskMapping(operation));
165 references to TaskCompletionSource
mscorlib (10)
system\threading\Tasks\TaskCompletionSource.cs (10)
38/// <see cref="TaskCompletionSource{TResult}">TaskCompletionSource</see> is provided for this purpose. It enables 47/// All members of <see cref="TaskCompletionSource{TResult}"/> are thread-safe 52/// cref="TaskCompletionSource{TResult}"/>.</typeparam> 59/// Creates a <see cref="TaskCompletionSource{TResult}"/>. 67/// Creates a <see cref="TaskCompletionSource{TResult}"/> 79/// with a <see cref="TaskCompletionSource{TResult}"/>. 87/// Creates a <see cref="TaskCompletionSource{TResult}"/> 98/// Creates a <see cref="TaskCompletionSource{TResult}"/> with 107/// with a <see cref="TaskCompletionSource{TResult}"/>. 117/// by this <see cref="TaskCompletionSource{TResult}"/>.
System (24)
net\System\Net\mail\SmtpClient.cs (2)
731var tcs = new TaskCompletionSource<object>(); 750private void HandleCompletion(TaskCompletionSource<object> tcs, AsyncCompletedEventArgs e, SendCompletedEventHandler handler)
net\System\Net\NetworkInformation\ping.cs (3)
542private Task<PingReply> SendPingAsyncCore(Action<TaskCompletionSource<PingReply>> sendAsync) 545var tcs = new TaskCompletionSource<PingReply>(); 564private void HandleCompletion(TaskCompletionSource<PingReply> tcs, PingCompletedEventArgs e, PingCompletedEventHandler handler)
net\System\Net\webclient.cs (10)
2552var tcs = new TaskCompletionSource<string>(address); 2582var tcs = new TaskCompletionSource<Stream>(address); 2627var tcs = new TaskCompletionSource<Stream>(address); 2676var tcs = new TaskCompletionSource<string>(address); 2707var tcs = new TaskCompletionSource<byte[]>(address); 2738var tcs = new TaskCompletionSource<object>(address); 2787var tcs = new TaskCompletionSource<byte[]>(address); 2836var tcs = new TaskCompletionSource<byte[]>(address); 2888var tcs = new TaskCompletionSource<byte[]>(address); 2908private void HandleCompletion<TAsyncCompletedEventArgs, TCompletionDelegate, T>(TaskCompletionSource<T> tcs, TAsyncCompletedEventArgs e, Func<TAsyncCompletedEventArgs, T> getResult, TCompletionDelegate handler, Action<WebClient, TCompletionDelegate> unregisterHandler)
net\System\Net\WebSockets\WebSocketBase.cs (1)
54private volatile TaskCompletionSource<object> m_CloseReceivedTaskCompletionSource;
net\System\Net\WebSockets\WebSocketConnectionStream.cs (4)
479private TaskCompletionSource<object> m_WriteTaskCompletionSource; 480private TaskCompletionSource<int> m_ReadTaskCompletionSource; 843TaskCompletionSource<int> readTaskCompletionSourceSnapshot = thisPtr.m_ReadTaskCompletionSource; 850TaskCompletionSource<object> writeTaskCompletionSourceSnapshot = thisPtr.m_WriteTaskCompletionSource;
net\System\Net\WebSockets\WebSocketHttpListenerDuplexStream.cs (4)
37private TaskCompletionSource<object> m_WriteTaskCompletionSource; 38private TaskCompletionSource<int> m_ReadTaskCompletionSource; 731TaskCompletionSource<int> readTaskCompletionSourceSnapshot = thisPtr.m_ReadTaskCompletionSource; 738TaskCompletionSource<object> writeTaskCompletionSourceSnapshot = thisPtr.m_WriteTaskCompletionSource;
System.Data (106)
fx\src\data\System\Data\Common\AdapterUtil.cs (2)
55TaskCompletionSource<T> completion = new TaskCompletionSource<T>(); 61TaskCompletionSource<T> completion = new TaskCompletionSource<T>();
fx\src\data\System\Data\Common\DBConnection.cs (1)
185TaskCompletionSource<object> taskCompletionSource = new TaskCompletionSource<object>();
fx\src\data\System\Data\ProviderBase\DbConnectionClosed.cs (5)
65internal override bool TryOpenConnection(DbConnection outerConnection, DbConnectionFactory connectionFactory, TaskCompletionSource<DbConnectionInternal> retry, DbConnectionOptions userOptions) { 75internal override bool TryOpenConnection(DbConnection outerConnection, DbConnectionFactory connectionFactory, TaskCompletionSource<DbConnectionInternal> retry, DbConnectionOptions userOptions) { 109internal override bool TryReplaceConnection(DbConnection outerConnection, DbConnectionFactory connectionFactory, TaskCompletionSource<DbConnectionInternal> retry, DbConnectionOptions userOptions) { 113internal override bool TryOpenConnection(DbConnection outerConnection, DbConnectionFactory connectionFactory, TaskCompletionSource<DbConnectionInternal> retry, DbConnectionOptions userOptions) { 154internal override bool TryReplaceConnection(DbConnection outerConnection, DbConnectionFactory connectionFactory, TaskCompletionSource<DbConnectionInternal> retry, DbConnectionOptions userOptions) {
fx\src\data\System\Data\ProviderBase\DbConnectionFactory.cs (2)
179TaskCompletionSource<DbConnectionInternal> source = new TaskCompletionSource<DbConnectionInternal>(); 186internal bool TryGetConnection(DbConnection owningConnection, TaskCompletionSource<DbConnectionInternal> retry, DbConnectionOptions userOptions, DbConnectionInternal oldConnection, out DbConnectionInternal connection) {
fx\src\data\System\Data\ProviderBase\DbConnectionInternal.cs (3)
665internal virtual bool TryOpenConnection(DbConnection outerConnection, DbConnectionFactory connectionFactory, TaskCompletionSource<DbConnectionInternal> retry, DbConnectionOptions userOptions) { 669internal virtual bool TryReplaceConnection(DbConnection outerConnection, DbConnectionFactory connectionFactory, TaskCompletionSource<DbConnectionInternal> retry, DbConnectionOptions userOptions) { 673protected bool TryOpenConnectionInternal(DbConnection outerConnection, DbConnectionFactory connectionFactory, TaskCompletionSource<DbConnectionInternal> retry, DbConnectionOptions userOptions) {
fx\src\data\System\Data\ProviderBase\DbConnectionPool.cs (3)
57public PendingGetConnection(long dueTime, DbConnection owner, TaskCompletionSource<DbConnectionInternal> completion, DbConnectionOptions userOptions) { 64public TaskCompletionSource<DbConnectionInternal> Completion { get; private set; } 1171internal bool TryGetConnection(DbConnection owningObject, TaskCompletionSource<DbConnectionInternal> retry, DbConnectionOptions userOptions, out DbConnectionInternal connection) {
fx\src\data\System\Data\SqlClient\SqlBulkCopy.cs (18)
1018TaskCompletionSource<bool> tcs = new TaskCompletionSource<bool>(); 1614TaskCompletionSource<object> source = new TaskCompletionSource<object>(); 1751TaskCompletionSource<object> tcs = new TaskCompletionSource<object>(); 2018private Task CopyColumnsAsync(int col, TaskCompletionSource<object> source = null) { 2050private void CopyColumnsAsyncSetupContinuation(TaskCompletionSource<object> source, Task task, int i) { 2126Task CheckForCancellation(CancellationToken cts, TaskCompletionSource<object> tcs) { 2139private TaskCompletionSource<object> ContinueTaskPend(Task task, TaskCompletionSource<object> source, Func<TaskCompletionSource<object>> action) { 2147TaskCompletionSource<object> newSource = action(); 2158private Task CopyRowsAsync(int rowsSoFar, int totalRows, CancellationToken cts, TaskCompletionSource<object> source = null) { 2229private Task CopyBatchesAsync(BulkCopySimpleResultSet internalResults, string updateBulkCommandText, CancellationToken cts, TaskCompletionSource<object> source = null) { 2294private Task CopyBatchesAsyncContinued(BulkCopySimpleResultSet internalResults, string updateBulkCommandText, CancellationToken cts, TaskCompletionSource<object> source) { 2339private Task CopyBatchesAsyncContinuedOnSuccess(BulkCopySimpleResultSet internalResults, string updateBulkCommandText, CancellationToken cts, TaskCompletionSource<object> source) { 2457private void WriteToServerInternalRestContinuedAsync(BulkCopySimpleResultSet internalResults, CancellationToken cts, TaskCompletionSource<object> source) { 2554private void WriteToServerInternalRestAsync(CancellationToken cts, TaskCompletionSource<object> source) { 2581TaskCompletionSource<object> cancellableReconnectTS = new TaskCompletionSource<object>(); 2662TaskCompletionSource<object> source = null;
fx\src\data\System\Data\SqlClient\SqlCommand.cs (26)
136TaskCompletionSource<object> _reconnectionCompletionSource = null; 169private TaskCompletionSource<object> _cachedAsyncResult = null; 213internal void SetActiveConnectionAndResult(TaskCompletionSource<object> completion, string endMethod, SqlConnection activeConnection) { 1005var reconnectCompletionSource = _reconnectionCompletionSource; 1254TaskCompletionSource<object> globalCompletion = new TaskCompletionSource<object>(stateObject); 1255TaskCompletionSource<object> localCompletion = new TaskCompletionSource<object>(stateObject); 1312private void BeginExecuteNonQueryInternalReadStage(TaskCompletionSource<object> completion) { 1434var reconnectionCompletionSource = _reconnectionCompletionSource; 1600private Task InternalExecuteNonQuery(TaskCompletionSource<object> completion, string methodName, bool sendToPipe, int timeout, out bool usedCache, bool asyncWrite = false, bool inRetry = false) { 1745TaskCompletionSource<object> globalCompletion = new TaskCompletionSource<object>(stateObject); 1746TaskCompletionSource<object> localCompletion = new TaskCompletionSource<object>(stateObject); 1804private void BeginExecuteXmlReaderInternalReadStage(TaskCompletionSource<object> completion) { 2138TaskCompletionSource<object> globalCompletion = new TaskCompletionSource<object>(stateObject); 2139TaskCompletionSource<object> localCompletion = new TaskCompletionSource<object>(stateObject); 2198private bool TriggerInternalEndAndRetryIfNecessary(CommandBehavior behavior, object stateObject, int timeout, string endMethod, bool usedCache, bool inRetry, bool asyncWrite, TaskCompletionSource<object> globalCompletion, TaskCompletionSource<object> localCompletion, Func<IAsyncResult, string, bool, object> endFunc, Func<CommandBehavior, AsyncCallback, object, int, bool, bool, IAsyncResult> retryFunc) { 2301private void BeginExecuteReaderInternalReadStage(TaskCompletionSource<object> completion) { 2410TaskCompletionSource<int> source = new TaskCompletionSource<int>(); 2474TaskCompletionSource<SqlDataReader> source = new TaskCompletionSource<SqlDataReader>(); 2515TaskCompletionSource<object> source = new TaskCompletionSource<object>(); 2578TaskCompletionSource<XmlReader> source = new TaskCompletionSource<XmlReader>(); 3068TaskCompletionSource<object> completion = new TaskCompletionSource<object>(); 3281private void PrepareForTransparentEncryption(CommandBehavior cmdBehavior, bool returnStream, bool async, int timeout, TaskCompletionSource<object> completion, out Task returnTask, bool asyncWrite, out bool usedCache, bool inRetry) { 4105internal SqlDataReader RunExecuteReader(CommandBehavior cmdBehavior, RunBehavior runBehavior, bool returnStream, string method, TaskCompletionSource<object> completion, int timeout, out Task task, out bool usedCache, bool asyncWrite = false, bool inRetry = false) { 4282TaskCompletionSource<object> completion = new TaskCompletionSource<object>(); 4354TaskCompletionSource<object> completion = new TaskCompletionSource<object>();
fx\src\data\System\Data\SqlClient\SqlConnection.cs (10)
278Tuple<TaskCompletionSource<DbConnectionInternal>, Task> _currentCompletion; 1404TaskCompletionSource<DbConnectionInternal> completion = new TaskCompletionSource<DbConnectionInternal>(transaction); 1405TaskCompletionSource<object> result = new TaskCompletionSource<object>(); 1437_currentCompletion = new Tuple<TaskCompletionSource<DbConnectionInternal>, Task>(completion, result.Task); 1455TaskCompletionSource<DbConnectionInternal> _retry; 1456TaskCompletionSource<object> _result; 1459public OpenAsyncRetry(SqlConnection parent, TaskCompletionSource<DbConnectionInternal> retry, TaskCompletionSource<object> result, CancellationTokenRegistration registration) { 1516private bool TryOpen(TaskCompletionSource<DbConnectionInternal> retry) { 1551private bool TryOpenInner(TaskCompletionSource<DbConnectionInternal> retry) {
fx\src\data\System\Data\SqlClient\SqlDataReader.cs (16)
816var networkPacketTaskSource = stateObj._networkPacketTaskSource; 1099var networkPacketTaskSource = stateObj._networkPacketTaskSource; 3937TaskCompletionSource<bool> source = new TaskCompletionSource<bool>(); 4000TaskCompletionSource<int> source = new TaskCompletionSource<int>(); 4006TaskCompletionSource<int> source = new TaskCompletionSource<int>(); 4020TaskCompletionSource<int> source = new TaskCompletionSource<int>(); 4099TaskCompletionSource<int> source = null; 4263TaskCompletionSource<bool> source = new TaskCompletionSource<bool>(); 4383TaskCompletionSource<bool> source = new TaskCompletionSource<bool>(); 4484TaskCompletionSource<T> source = new TaskCompletionSource<T>(); 4567TaskCompletionSource<object> completionSource = _stateObj._networkPacketTaskSource; 4570TaskCompletionSource<T> source = new TaskCompletionSource<T>(); 4578TaskCompletionSource<T> exceptionSource = new TaskCompletionSource<T>(); 4613TaskCompletionSource<T> source = new TaskCompletionSource<T>(); 4620private Task<T> InvokeRetryable<T>(Func<Task, Task<T>> moreFunc, TaskCompletionSource<T> source, IDisposable objectToDispose = null) { 4648private void CompleteRetryable<T>(Task<T> task, TaskCompletionSource<T> source, IDisposable objectToDispose) {
fx\src\data\System\Data\SqlClient\SqlInternalConnectionTds.cs (1)
2680internal override bool TryReplaceConnection(DbConnection outerConnection, DbConnectionFactory connectionFactory, TaskCompletionSource<DbConnectionInternal> retry, DbConnectionOptions userOptions) {
fx\src\data\System\Data\SqlClient\SqlSequentialStream.cs (1)
157TaskCompletionSource<int> completion = new TaskCompletionSource<int>();
fx\src\data\System\Data\SqlClient\SqlSequentialTextReader.cs (1)
130TaskCompletionSource<int> completion = new TaskCompletionSource<int>();
fx\src\data\System\Data\SqlClient\SqlUtil.cs (3)
38TaskCompletionSource<object> completion = new TaskCompletionSource<object>(); 51TaskCompletionSource<object> completion, 169internal static void SetTimeoutException(TaskCompletionSource<object> completion, int timeout, Func<Exception> exc, CancellationToken ctoken) {
fx\src\data\System\Data\SqlClient\TdsParser.cs (3)
1286var taskSource = stateObj._networkPacketTaskSource; 8045TaskCompletionSource<object> completion = null, int startRpc = 0, int startParam = 0) { 8688private void ExecuteFlushTaskCallback(Task tsk, TdsParserStateObject stateObj, TaskCompletionSource<object> completion, bool releaseConnectionLock) {
fx\src\data\System\Data\SqlClient\TdsParserStateObject.cs (11)
189internal TaskCompletionSource<object> _networkPacketTaskSource; 216volatile private TaskCompletionSource<object> _writeCompletionSource = null; 2017var taskSource = _networkPacketTaskSource; 2038TaskCompletionSource<object> source = _networkPacketTaskSource; 2114internal void ReadSni(TaskCompletionSource<object> completion) { 2468TaskCompletionSource<object> source = _networkPacketTaskSource; 2523private void ReadAsyncCallbackCaptureException(TaskCompletionSource<object> source) { 2569var writeCompletionSource = _writeCompletionSource; 2619var completionSource = _writeCompletionSource; 2725internal Task WriteByteArray(Byte[] b, int len, int offsetBuffer, bool canAccumulate=true, TaskCompletionSource<object> completion = null) { 2803private void WriteByteArraySetupContinuation(Byte[] b, int len, TaskCompletionSource<object> completion, int offset, Task packetTask) {
System.ServiceModel (7)
System\ServiceModel\Channels\HttpPipeline.cs (1)
395TaskCompletionSource<HttpResponseMessage> channelModelIntegrationHandlerTask;
System\ServiceModel\Channels\WebSocketTransportDuplexSessionChannel.cs (2)
501TaskCompletionSource<object> streamWaitTask; 508TaskCompletionSource<object> receiveTask;
System\ServiceModel\Dispatcher\TaskMethodInvoker.cs (4)
283var tcs = new TaskCompletionSource<TResult>(state); 288Tuple<TaskCompletionSource<TResult>, AsyncCallback> tuple = (Tuple<TaskCompletionSource<TResult>, AsyncCallback>)obj; 289TaskCompletionSource<TResult> tcsObj = tuple.Item1;
System.ServiceModel.Activation (2)
System\ServiceModel\Activation\HostedHttpContext.cs (2)
32TaskCompletionSource<object> webSocketWaitingTask; 34TaskCompletionSource<WebSocketContext> webSocketContextTaskSource;
System.ServiceModel.Discovery (4)
System\ServiceModel\Discovery\DiscoveryClient.cs (4)
438TaskCompletionSource<FindResponse> taskCompletionSource = new TaskCompletionSource<FindResponse>(); 459TaskCompletionSource<ResolveResponse> taskCompletionSource = new TaskCompletionSource<ResolveResponse>(); 1393TaskCompletionSource<TResult> taskCompletionSource; 1396internal TaskAsyncOperationState(DiscoveryClient discoveryClient, TaskCompletionSource<TResult> taskCompletionSource, CancellationToken cancellationToken)
System.ServiceModel.Internals (2)
System\Runtime\TaskExtensions.cs (2)
25var tcs = new TaskCompletionSource<T>(state); 67var tcs = new TaskCompletionSource<object>(state);
System.Web (9)
AspNetSynchronizationContextBase.cs (1)
44TaskCompletionSource<object> tcs = new TaskCompletionSource<object>();
Hosting\ApplicationManager.cs (1)
647TaskCompletionSource<ApplicationResumeStateContainer> tcs = new TaskCompletionSource<ApplicationResumeStateContainer>();
UI\PageAsyncTaskApm.cs (1)
34TaskCompletionSource<object> taskCompletionSource = new TaskCompletionSource<object>();
Util\CountdownTask.cs (1)
21private readonly TaskCompletionSource<object> _tcs = new TaskCompletionSource<object>();
Util\SynchronizationHelper.cs (2)
82TaskCompletionSource<object> tcs = new TaskCompletionSource<object>(); 181TaskCompletionSource<Task> tcs = new TaskCompletionSource<Task>();
WebSockets\WebSocketPipe.cs (3)
40TaskCompletionSource<object> tcs = new TaskCompletionSource<object>(); 86TaskCompletionSource<object> tcs = new TaskCompletionSource<object>(); 119TaskCompletionSource<WebSocketReceiveResult> tcs = new TaskCompletionSource<WebSocketReceiveResult>();
WindowsBase (1)
Base\System\Windows\Threading\DispatcherOperationTaskSource.cs (1)
72private TaskCompletionSource<TResult> _taskCompletionSource;