186 references to TaskToAsyncResult
Microsoft.AspNetCore.HttpLogging (4)
RequestBufferingStream.cs (2)
163return TaskToAsyncResult.Begin(ReadAsync(buffer, offset, count), callback, state); 168return TaskToAsyncResult.End<int>(asyncResult);
ResponseBufferingStream.cs (2)
98return TaskToAsyncResult.Begin(WriteAsync(buffer, offset, count), callback, state); 103TaskToAsyncResult.End(asyncResult);
Microsoft.AspNetCore.OutputCaching (2)
Streams\OutputCacheStream.cs (2)
220=> TaskToAsyncResult.Begin(WriteAsync(buffer, offset, count, CancellationToken.None), callback, state); 223=> TaskToAsyncResult.End(asyncResult);
Microsoft.AspNetCore.ResponseCaching (4)
src\aspnetcore\src\Shared\SegmentWriteStream.cs (2)
181=> TaskToAsyncResult.Begin(WriteAsync(buffer, offset, count, CancellationToken.None), callback, state); 184=> TaskToAsyncResult.End(asyncResult);
Streams\ResponseCachingStream.cs (2)
185=> TaskToAsyncResult.Begin(WriteAsync(buffer, offset, count, CancellationToken.None), callback, state); 188=> TaskToAsyncResult.End(asyncResult);
Microsoft.AspNetCore.ResponseCompression (2)
ResponseCompressionBody.cs (2)
172=> TaskToAsyncResult.Begin(WriteAsync(buffer, offset, count, CancellationToken.None), callback, state); 175=> TaskToAsyncResult.End(asyncResult);
Microsoft.AspNetCore.Server.HttpSys (6)
RequestProcessing\RequestStream.cs (2)
173=> TaskToAsyncResult.Begin(ReadAsync(buffer, offset, size, CancellationToken.None), callback, state); 176=> TaskToAsyncResult.End<int>(asyncResult);
RequestProcessing\ResponseBody.cs (2)
564return TaskToAsyncResult.Begin(WriteAsync(buffer, offset, count), callback, state); 571TaskToAsyncResult.End(asyncResult);
ResponseStream.cs (2)
74=> TaskToAsyncResult.Begin(WriteAsync(buffer, offset, count, CancellationToken.None), callback, state); 77=> TaskToAsyncResult.End(asyncResult);
Microsoft.AspNetCore.Server.IIS (8)
Core\HttpRequestStream.cs (2)
36return TaskToAsyncResult.Begin(ReadAsync(buffer, offset, count), callback, state); 41return TaskToAsyncResult.End<int>(asyncResult);
Core\HttpResponseStream.cs (2)
45return TaskToAsyncResult.Begin(WriteAsync(buffer, offset, count), callback, state); 50TaskToAsyncResult.End(asyncResult);
src\aspnetcore\src\Shared\ServerInfrastructure\DuplexPipeStream.cs (4)
156return TaskToAsyncResult.Begin(ReadAsync(buffer, offset, count), callback, state); 161return TaskToAsyncResult.End<int>(asyncResult); 166return TaskToAsyncResult.Begin(WriteAsync(buffer, offset, count), callback, state); 171TaskToAsyncResult.End(asyncResult);
Microsoft.AspNetCore.Server.Kestrel.Core (12)
Internal\Http\HttpRequestStream.cs (2)
92return TaskToAsyncResult.Begin(ReadAsync(buffer, offset, count), callback, state); 98return TaskToAsyncResult.End<int>(asyncResult);
Internal\Http\HttpResponseStream.cs (2)
84return TaskToAsyncResult.Begin(WriteAsync(buffer, offset, count), callback, state); 89TaskToAsyncResult.End(asyncResult);
Middleware\Internal\LoggingStream.cs (4)
230return TaskToAsyncResult.Begin(ReadAsync(buffer, offset, count), callback, state); 235return TaskToAsyncResult.End<int>(asyncResult); 240return TaskToAsyncResult.Begin(WriteAsync(buffer, offset, count), callback, state); 245TaskToAsyncResult.End(asyncResult);
src\aspnetcore\src\Shared\ServerInfrastructure\DuplexPipeStream.cs (4)
156return TaskToAsyncResult.Begin(ReadAsync(buffer, offset, count), callback, state); 161return TaskToAsyncResult.End<int>(asyncResult); 166return TaskToAsyncResult.Begin(WriteAsync(buffer, offset, count), callback, state); 171TaskToAsyncResult.End(asyncResult);
System.IO.Compression (12)
System\IO\Compression\DeflateManaged\DeflateManagedStream.cs (2)
155TaskToAsyncResult.Begin(ReadAsync(buffer, offset, count, CancellationToken.None), asyncCallback, asyncState); 158TaskToAsyncResult.End<int>(asyncResult);
System\IO\Compression\DeflateZLib\DeflateStream.cs (4)
414TaskToAsyncResult.Begin(ReadAsync(buffer, offset, count, CancellationToken.None), asyncCallback, asyncState); 420return TaskToAsyncResult.End<int>(asyncResult); 813TaskToAsyncResult.Begin(WriteAsync(buffer, offset, count, CancellationToken.None), asyncCallback, asyncState); 819TaskToAsyncResult.End(asyncResult);
System\IO\Compression\GZipStream.cs (2)
92TaskToAsyncResult.Begin(ReadAsync(buffer, offset, count, CancellationToken.None), asyncCallback, asyncState); 120TaskToAsyncResult.Begin(WriteAsync(buffer, offset, count, CancellationToken.None), asyncCallback, asyncState);
System\IO\Compression\Zstandard\ZstandardStream.Compress.cs (2)
304return TaskToAsyncResult.Begin(WriteAsync(buffer, offset, count, CancellationToken.None), callback, state); 311TaskToAsyncResult.End(asyncResult);
System\IO\Compression\Zstandard\ZstandardStream.Decompress.cs (2)
399return TaskToAsyncResult.Begin(ReadAsync(buffer, offset, count, CancellationToken.None), callback, state); 407return TaskToAsyncResult.End<int>(asyncResult);
System.IO.Compression.Brotli (4)
System\IO\Compression\dec\BrotliStream.Decompress.cs (2)
109TaskToAsyncResult.Begin(ReadAsync(buffer, offset, count, CancellationToken.None), asyncCallback, asyncState); 118TaskToAsyncResult.End<int>(asyncResult);
System\IO\Compression\enc\BrotliStream.Compress.cs (2)
114TaskToAsyncResult.Begin(WriteAsync(buffer, offset, count, CancellationToken.None), asyncCallback, asyncState); 120TaskToAsyncResult.End(asyncResult);
System.IO.Hashing (2)
System\IO\Hashing\NonCryptographicHashAlgorithm.cs (2)
339TaskToAsyncResult.Begin(WriteAsync(buffer, offset, count), callback, state); 342TaskToAsyncResult.End(asyncResult);
System.IO.Pipelines (4)
System\IO\Pipelines\PipeReaderStream.cs (2)
78TaskToAsyncResult.Begin(ReadAsync(buffer, offset, count, default), callback, state); 81TaskToAsyncResult.End<int>(asyncResult);
System\IO\Pipelines\PipeWriterStream.cs (2)
64TaskToAsyncResult.Begin(WriteAsync(buffer, offset, count, default), callback, state); 67TaskToAsyncResult.End(asyncResult);
System.IO.Pipes (6)
System\IO\Pipes\NamedPipeServerStream.cs (2)
163TaskToAsyncResult.Begin(WaitForConnectionAsync(), callback, state); 166TaskToAsyncResult.End(asyncResult);
System\IO\Pipes\PipeStream.Unix.cs (4)
106=> TaskToAsyncResult.Begin(ReadAsync(buffer, offset, count, CancellationToken.None), callback, state); 109=> TaskToAsyncResult.End<int>(asyncResult); 180=> TaskToAsyncResult.Begin(WriteAsync(buffer, offset, count, CancellationToken.None), callback, state); 183=> TaskToAsyncResult.End(asyncResult);
System.IO.Ports (3)
System\IO\Ports\SerialStream.Unix.cs (3)
522return TaskToAsyncResult.Begin(ReadAsync(array, offset, numBytes), userCallback, stateObject); 578return TaskToAsyncResult.Begin(WriteAsync(array, offset, count), userCallback, stateObject); 588return TaskToAsyncResult.End<int>(asyncResult);
System.Net.Http (8)
System\Net\Http\HttpBaseStream.cs (4)
16TaskToAsyncResult.Begin(ReadAsync(buffer, offset, count, default), callback, state); 19TaskToAsyncResult.End<int>(asyncResult); 22TaskToAsyncResult.Begin(WriteAsync(buffer, offset, count, default), callback, state); 25TaskToAsyncResult.End(asyncResult);
System\Net\Http\HttpContent.cs (2)
1139TaskToAsyncResult.Begin(WriteAsync(buffer, offset, count, CancellationToken.None), asyncCallback, asyncState); 1142TaskToAsyncResult.End(asyncResult);
System\Net\Http\MultipartContent.cs (2)
520TaskToAsyncResult.Begin(ReadAsync(array, offset, count, CancellationToken.None), asyncCallback, asyncState); 523TaskToAsyncResult.End<int>(asyncResult);
System.Net.Http.WinHttpHandler (4)
System\Net\Http\WinHttpRequestStream.cs (2)
141TaskToAsyncResult.Begin(WriteAsync(buffer, offset, count, CancellationToken.None), asyncCallback, asyncState); 144TaskToAsyncResult.End(asyncResult);
System\Net\Http\WinHttpResponseStream.cs (2)
202TaskToAsyncResult.Begin(ReadAsync(buffer, offset, count, CancellationToken.None), callback, state); 205TaskToAsyncResult.End<int>(asyncResult);
System.Net.Mail (4)
System\Net\DelegatedStream.cs (4)
61return TaskToAsyncResult.Begin(ReadAsync(buffer, offset, count, CancellationToken.None), callback, state); 65return TaskToAsyncResult.End<int>(asyncResult); 70return TaskToAsyncResult.Begin(WriteAsync(buffer, offset, count, CancellationToken.None), callback, state); 75TaskToAsyncResult.End(asyncResult);
System.Net.NameResolution (10)
System\Net\Dns.cs (10)
174TaskToAsyncResult.Begin(GetHostEntryAsync(address), requestCallback, stateObject); 177TaskToAsyncResult.Begin(GetHostEntryAsync(hostNameOrAddress), requestCallback, stateObject); 185return TaskToAsyncResult.End<IPHostEntry>(asyncResult); 253TaskToAsyncResult.Begin(GetHostAddressesAsync(hostNameOrAddress), requestCallback, state); 261return TaskToAsyncResult.End<IPAddress[]>(asyncResult); 279TaskToAsyncResult.Begin(GetHostEntryCoreAsync(hostName, justReturnParsedIp: true, throwOnIIPAny: true, AddressFamily.Unspecified, CancellationToken.None), requestCallback, stateObject); 288return TaskToAsyncResult.End<IPHostEntry>(asyncResult); 348TaskToAsyncResult.Begin(GetHostEntryCoreAsync(hostName, justReturnParsedIp: false, throwOnIIPAny: false, AddressFamily.Unspecified, CancellationToken.None), requestCallback, stateObject); 359ipHostEntry = TaskToAsyncResult.End<IPHostEntry>(asyncResult); 363object? asyncState = TaskToAsyncResult.Unwrap(asyncResult).AsyncState;
System.Net.NetworkInformation (2)
System\Net\NetworkInformation\UnixIPGlobalProperties.cs (2)
46return TaskToAsyncResult.Begin(t, callback, state); 51return TaskToAsyncResult.End<UnicastIPAddressInformationCollection>(asyncResult);
System.Net.Quic (4)
System\Net\Quic\QuicStream.Stream.cs (4)
93=> TaskToAsyncResult.Begin(ReadAsync(buffer, offset, count, default), callback, state); 97=> TaskToAsyncResult.End<int>(asyncResult); 156=> TaskToAsyncResult.Begin(WriteAsync(buffer, offset, count, default), callback, state); 160=> TaskToAsyncResult.End(asyncResult);
System.Net.Requests (4)
System\Net\FileWebRequest.cs (4)
162return TaskToAsyncResult.Begin(t, callback, state); 223return TaskToAsyncResult.Begin(t, callback, state); 240Stream stream = TaskToAsyncResult.End<Stream>(asyncResult); 247WebResponse response = TaskToAsyncResult.End<WebResponse>(asyncResult);
System.Net.Security (18)
System\Net\Security\NegotiateStream.cs (8)
123TaskToAsyncResult.Begin(AuthenticateAsClientAsync(credential, binding, targetName, requiredProtectionLevel, allowedImpersonationLevel), asyncCallback, asyncState); 125public virtual void EndAuthenticateAsClient(IAsyncResult asyncResult) => TaskToAsyncResult.End(asyncResult); 156TaskToAsyncResult.Begin(AuthenticateAsServerAsync(credential, policy, requiredProtectionLevel, requiredImpersonationLevel), asyncCallback, asyncState); 158public virtual void EndAuthenticateAsServer(IAsyncResult asyncResult) => TaskToAsyncResult.End(asyncResult); 569TaskToAsyncResult.Begin(ReadAsync(buffer, offset, count), asyncCallback, asyncState); 572TaskToAsyncResult.End<int>(asyncResult); 575TaskToAsyncResult.Begin(WriteAsync(buffer, offset, count), asyncCallback, asyncState); 578TaskToAsyncResult.End(asyncResult);
System\Net\Security\SslStream.cs (10)
263TaskToAsyncResult.Begin(AuthenticateAsClientAsync(sslClientAuthenticationOptions, cancellationToken)!, asyncCallback, asyncState); 265public virtual void EndAuthenticateAsClient(IAsyncResult asyncResult) => TaskToAsyncResult.End(asyncResult); 302TaskToAsyncResult.Begin(AuthenticateAsServerAsync(sslServerAuthenticationOptions, cancellationToken)!, asyncCallback, asyncState); 304public virtual void EndAuthenticateAsServer(IAsyncResult asyncResult) => TaskToAsyncResult.End(asyncResult); 306internal IAsyncResult BeginShutdown(AsyncCallback? asyncCallback, object? asyncState) => TaskToAsyncResult.Begin(ShutdownAsync(), asyncCallback, asyncState); 308internal static void EndShutdown(IAsyncResult asyncResult) => TaskToAsyncResult.End(asyncResult); 857return TaskToAsyncResult.Begin(ReadAsync(buffer, offset, count, CancellationToken.None), asyncCallback, asyncState); 863return TaskToAsyncResult.End<int>(asyncResult); 869return TaskToAsyncResult.Begin(WriteAsync(buffer, offset, count, CancellationToken.None), asyncCallback, asyncState); 875TaskToAsyncResult.End(asyncResult);
System.Net.Sockets (33)
System\Net\Sockets\Socket.cs (30)
2458TaskToAsyncResult.Begin(ConnectAsync(remoteEP), callback, state); 2461TaskToAsyncResult.Begin(ConnectAsync(host, port), requestCallback, state); 2464TaskToAsyncResult.Begin(ConnectAsync(address, port), requestCallback, state); 2467TaskToAsyncResult.Begin(ConnectAsync(addresses, port), requestCallback, state); 2469public void EndConnect(IAsyncResult asyncResult) => TaskToAsyncResult.End(asyncResult); 2472TaskToAsyncResult.Begin(DisconnectAsync(reuseSocket).AsTask(), callback, state); 2495public void EndDisconnect(IAsyncResult asyncResult) => TaskToAsyncResult.End(asyncResult); 2504return TaskToAsyncResult.Begin(SendAsync(new ReadOnlyMemory<byte>(buffer, offset, size), socketFlags, default).AsTask(), callback, state); 2522return TaskToAsyncResult.Begin(t, callback, state); 2531return TaskToAsyncResult.Begin(SendAsync(buffers, socketFlags), callback, state); 2548return TaskToAsyncResult.Begin(t, callback, state); 2551public int EndSend(IAsyncResult asyncResult) => TaskToAsyncResult.End<int>(asyncResult); 2576return TaskToAsyncResult.Begin(SendFileAsync(fileName, preBuffer, postBuffer, flags).AsTask(), callback, state); 2579public void EndSendFile(IAsyncResult asyncResult) => TaskToAsyncResult.End(asyncResult); 2590return TaskToAsyncResult.Begin(t, callback, state); 2593public int EndSendTo(IAsyncResult asyncResult) => TaskToAsyncResult.End<int>(asyncResult); 2601return TaskToAsyncResult.Begin(ReceiveAsync(new ArraySegment<byte>(buffer, offset, size), socketFlags, fromNetworkStream: false, default).AsTask(), callback, state); 2619return TaskToAsyncResult.Begin(t, callback, state); 2627return TaskToAsyncResult.Begin(ReceiveAsync(buffers, socketFlags), callback, state); 2644return TaskToAsyncResult.Begin(t, callback, state); 2647public int EndReceive(IAsyncResult asyncResult) => TaskToAsyncResult.End<int>(asyncResult); 2656Task<int> ti = TaskToAsyncResult.Unwrap<int>(asyncResult); 2688IAsyncResult asyncResult = TaskToAsyncResult.Begin(t, callback, state); 2703SocketReceiveMessageFromResult result = TaskToAsyncResult.End<SocketReceiveMessageFromResult>(asyncResult); 2730return TaskToAsyncResult.Begin(t, callback, state); 2743SocketReceiveFromResult result = TaskToAsyncResult.End<SocketReceiveFromResult>(asyncResult); 2752TaskToAsyncResult.Begin(AcceptAsync(), callback, state); 2754public Socket EndAccept(IAsyncResult asyncResult) => TaskToAsyncResult.End<Socket>(asyncResult); 2793TaskToAsyncResult.Begin(AcceptAndReceiveHelperAsync(acceptSocket, receiveSize), callback, state); 2810(s, buffer, bytesTransferred) = TaskToAsyncResult.End<(Socket, byte[], int)>(asyncResult);
System\Net\Sockets\TCPListener.cs (3)
210TaskToAsyncResult.Begin(AcceptSocketAsync(), callback, state); 216TaskToAsyncResult.Begin(AcceptTcpClientAsync(), callback, state); 294return TaskToAsyncResult.End<TResult>(asyncResult);
System.Net.WebSockets (4)
System\Net\WebSockets\WebSocketStream.cs (4)
138TaskToAsyncResult.Begin(ReadAsync(buffer, offset, count), callback, state); 142TaskToAsyncResult.End<int>(asyncResult); 158TaskToAsyncResult.Begin(WriteAsync(buffer, offset, count), callback, state); 162TaskToAsyncResult.End(asyncResult);
System.Private.CoreLib (21)
src\runtime\src\libraries\Common\src\System\Threading\Tasks\TaskToAsyncResult.cs (1)
28/// in new code; the methods on <see cref="TaskToAsyncResult"/> are intended only to help implement such Begin/End methods when they must be exposed, for example
src\runtime\src\libraries\System.Private.CoreLib\src\System\IO\BufferedStream.cs (4)
728TaskToAsyncResult.Begin(ReadAsync(buffer, offset, count, CancellationToken.None), callback, state); 731TaskToAsyncResult.End<int>(asyncResult); 1142TaskToAsyncResult.Begin(WriteAsync(buffer, offset, count, CancellationToken.None), callback, state); 1145TaskToAsyncResult.End(asyncResult);
src\runtime\src\libraries\System.Private.CoreLib\src\System\IO\Strategies\BufferedFileStreamStrategy.cs (4)
460=> TaskToAsyncResult.Begin(ReadAsync(buffer, offset, count, CancellationToken.None), callback, state); 463=> TaskToAsyncResult.End<int>(asyncResult); 744=> TaskToAsyncResult.Begin(WriteAsync(buffer, offset, count, CancellationToken.None), callback, state); 747=> TaskToAsyncResult.End(asyncResult);
src\runtime\src\libraries\System.Private.CoreLib\src\System\IO\Strategies\OSFileStreamStrategy.cs (4)
248TaskToAsyncResult.Begin(WriteAsync(buffer, offset, count), callback, state); 251TaskToAsyncResult.End(asyncResult); 263TaskToAsyncResult.Begin(ReadAsync(buffer, offset, count), callback, state); 266TaskToAsyncResult.End<int>(asyncResult);
src\runtime\src\libraries\System.Private.CoreLib\src\System\IO\Stream.cs (4)
1037TaskToAsyncResult.Begin(Task<int>.s_defaultResultTask, callback, state); 1040TaskToAsyncResult.End<int>(asyncResult); 1043TaskToAsyncResult.Begin(Task.CompletedTask, callback, state); 1046TaskToAsyncResult.End(asyncResult);
src\runtime\src\libraries\System.Private.CoreLib\src\System\Text\TranscodingStream.cs (4)
86=> TaskToAsyncResult.Begin(ReadAsync(buffer, offset, count, CancellationToken.None), callback, state); 89=> TaskToAsyncResult.Begin(WriteAsync(buffer, offset, count, CancellationToken.None), callback, state); 165=> TaskToAsyncResult.End<int>(asyncResult); 168=> TaskToAsyncResult.End(asyncResult);
System.Runtime (1)
src\runtime\artifacts\obj\System.Runtime\Release\net11.0\System.Runtime.Forwards.cs (1)
855[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.Tasks.TaskToAsyncResult))]
System.Security.Cryptography (4)
System\Security\Cryptography\CryptoStream.cs (4)
252TaskToAsyncResult.Begin(ReadAsync(buffer, offset, count, CancellationToken.None), callback, state); 255TaskToAsyncResult.End<int>(asyncResult); 491TaskToAsyncResult.Begin(WriteAsync(buffer, offset, count, CancellationToken.None), callback, state); 494TaskToAsyncResult.End(asyncResult);