16 implementations of IValueTaskSource
Microsoft.AspNetCore.Server.IIS (2)
Core\IO\AsyncIOOperation.cs (1)
11
internal abstract class AsyncIOOperation : IValueTaskSource<int>,
IValueTaskSource
src\aspnetcore\src\Shared\ServerInfrastructure\ManualResetValueTaskSource.cs (1)
11
internal sealed class ManualResetValueTaskSource<T> : IValueTaskSource<T>,
IValueTaskSource
Microsoft.AspNetCore.Server.Kestrel.Core (1)
src\aspnetcore\src\Shared\ServerInfrastructure\ManualResetValueTaskSource.cs (1)
11
internal sealed class ManualResetValueTaskSource<T> : IValueTaskSource<T>,
IValueTaskSource
System.Net.Http (1)
System\Net\Http\SocketsHttpHandler\Http2Stream.cs (1)
22
private sealed class Http2Stream :
IValueTaskSource
, IHttpStreamHeadersHandler, IHttpTrace
System.Net.Quic (3)
src\runtime\src\libraries\Common\src\System\Net\StreamBuffer.cs (1)
285
private sealed class ResettableValueTaskSource :
IValueTaskSource
System\Net\Quic\Internal\ResettableValueTaskSource.cs (1)
14
internal sealed class ResettableValueTaskSource :
IValueTaskSource
System\Net\Quic\Internal\ValueTaskSource.cs (1)
14
internal sealed class ValueTaskSource :
IValueTaskSource
System.Net.Sockets (2)
System\Net\Sockets\Socket.Tasks.cs (1)
977
internal sealed class AwaitableSocketAsyncEventArgs : SocketAsyncEventArgs,
IValueTaskSource
, IValueTaskSource<int>, IValueTaskSource<Socket>, IValueTaskSource<SocketReceiveFromResult>, IValueTaskSource<SocketReceiveMessageFromResult>
System\Net\Sockets\SocketAsyncEventArgs.cs (1)
924
private sealed class MultiConnectSocketAsyncEventArgs : SocketAsyncEventArgs,
IValueTaskSource
System.Private.CoreLib (4)
src\runtime\src\libraries\System.Private.CoreLib\src\Microsoft\Win32\SafeHandles\SafeFileHandle.ThreadPoolValueTaskSource.cs (1)
30
internal sealed class ThreadPoolValueTaskSource : IThreadPoolWorkItem, IValueTaskSource<int>, IValueTaskSource<long>,
IValueTaskSource
src\runtime\src\libraries\System.Private.CoreLib\src\System\Runtime\CompilerServices\PoolingAsyncValueTaskMethodBuilderT.cs (2)
246
internal abstract class StateMachineBox : IValueTaskSource<TResult>,
IValueTaskSource
311
IValueTaskSource<TResult>,
IValueTaskSource
, IAsyncStateMachineBox, IThreadPoolWorkItem
src\runtime\src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\Task.cs (1)
7084
private sealed class WhenEachState : Queue<Task>,
IValueTaskSource
, ITaskCompletionAction
System.ServiceModel.NetTcp (1)
System\ServiceModel\Channels\SocketAwaitableEventArgs.cs (1)
19
internal class SocketAwaitableEventArgs : SocketAsyncEventArgs, IValueTaskSource<int>,
IValueTaskSource
System.ServiceModel.UnixDomainSocket (1)
System\ServiceModel\Channels\SocketAwaitableEventArgs.cs (1)
19
internal class SocketAwaitableEventArgs : SocketAsyncEventArgs, IValueTaskSource<int>,
IValueTaskSource
System.Threading.Channels (1)
System\Threading\Channels\AsyncOperation.cs (1)
432
internal abstract class AsyncOperation<TSelf> : AsyncOperation,
IValueTaskSource
95 references to IValueTaskSource
Microsoft.AspNetCore.Server.IIS (2)
Core\IO\AsyncIOOperation.cs (1)
58
void
IValueTaskSource
.GetResult(short token)
src\aspnetcore\src\Shared\ServerInfrastructure\ManualResetValueTaskSource.cs (1)
22
void
IValueTaskSource
.GetResult(short token) => _core.GetResult(token);
Microsoft.AspNetCore.Server.Kestrel.Core (1)
src\aspnetcore\src\Shared\ServerInfrastructure\ManualResetValueTaskSource.cs (1)
22
void
IValueTaskSource
.GetResult(short token) => _core.GetResult(token);
mscorlib (1)
mscorlib.cs (1)
107
[assembly:System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.Tasks.Sources.
IValueTaskSource
))]
netstandard (1)
netstandard.cs (1)
2112
[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.Tasks.Sources.
IValueTaskSource
))]
System.Net.Http (4)
System\Net\Http\SocketsHttpHandler\CreditWaiter.cs (1)
23
/// <summary><see cref="
IValueTaskSource
"/> implementation.</summary>
System\Net\Http\SocketsHttpHandler\Http2Stream.cs (3)
1417
ValueTaskSourceStatus
IValueTaskSource
.GetStatus(short token) => _waitSource.GetStatus(token);
1418
void
IValueTaskSource
.OnCompleted(Action<object?> continuation, object? state, short token, ValueTaskSourceOnCompletedFlags flags) => _waitSource.OnCompleted(continuation, state, token, flags);
1419
void
IValueTaskSource
.GetResult(short token)
System.Net.Quic (9)
src\runtime\src\libraries\Common\src\System\Net\StreamBuffer.cs (3)
297
ValueTaskSourceStatus
IValueTaskSource
.GetStatus(short token) => _waitSource.GetStatus(token);
299
void
IValueTaskSource
.OnCompleted(Action<object?> continuation, object? state, short token, ValueTaskSourceOnCompletedFlags flags) => _waitSource.OnCompleted(continuation, state, token, flags);
301
void
IValueTaskSource
.GetResult(short token)
System\Net\Quic\Internal\ResettableValueTaskSource.cs (3)
240
ValueTaskSourceStatus
IValueTaskSource
.GetStatus(short token)
243
void
IValueTaskSource
.OnCompleted(Action<object?> continuation, object? state, short token, ValueTaskSourceOnCompletedFlags flags)
246
void
IValueTaskSource
.GetResult(short token)
System\Net\Quic\Internal\ValueTaskSource.cs (3)
169
ValueTaskSourceStatus
IValueTaskSource
.GetStatus(short token)
172
void
IValueTaskSource
.OnCompleted(Action<object?> continuation, object? state, short token, ValueTaskSourceOnCompletedFlags flags)
175
void
IValueTaskSource
.GetResult(short token)
System.Net.Sockets (1)
System\Net\Sockets\Socket.Tasks.cs (1)
1267
void
IValueTaskSource
.GetResult(short token)
System.Private.CoreLib (71)
src\runtime\src\coreclr\System.Private.CoreLib\src\System\Runtime\CompilerServices\AsyncHelpers.CoreCLR.cs (3)
488
Debug.Assert(obj is
IValueTaskSource
);
489
vtsCont.Initialize(Unsafe.As<object,
IValueTaskSource
>(ref obj), valueTask._token);
503
private static unsafe void Suspend(
IValueTaskSource
source, short token, bool continueOnCapturedContext)
src\runtime\src\coreclr\System.Private.CoreLib\src\System\Runtime\CompilerServices\AsyncHelpers.ValueTaskSourceContinuation.cs (7)
36
public void Initialize(
IValueTaskSource
source, short token)
54
Debug.Assert(source is
IValueTaskSource
);
55
IValueTaskSource
typedSource = Unsafe.As<object,
IValueTaskSource
>(ref source);
61
Debug.Assert(source is
IValueTaskSource
);
62
IValueTaskSource
typedSource = Unsafe.As<object,
IValueTaskSource
>(ref source);
src\runtime\src\libraries\System.Private.CoreLib\src\Microsoft\Win32\SafeHandles\SafeFileHandle.ThreadPoolValueTaskSource.cs (2)
26
/// A reusable <see cref="
IValueTaskSource
"/> implementation that
65
void
IValueTaskSource
.GetResult(short token) => GetResult(token);
src\runtime\src\libraries\System.Private.CoreLib\src\System\Runtime\CompilerServices\AsyncHelpers.cs (6)
229
Debug.Assert(obj is
IValueTaskSource
);
230
IValueTaskSource
vts = Unsafe.As<object,
IValueTaskSource
>(ref obj);
313
Debug.Assert(obj is
IValueTaskSource
);
314
IValueTaskSource
vts = Unsafe.As<object,
IValueTaskSource
>(ref obj);
src\runtime\src\libraries\System.Private.CoreLib\src\System\Runtime\CompilerServices\ConfiguredValueTaskAwaitable.cs (6)
55
Debug.Assert(obj == null || obj is Task || obj is
IValueTaskSource
);
63
Unsafe.As<
IValueTaskSource
>(obj).OnCompleted(ValueTaskAwaiter.s_invokeActionDelegate, continuation, _value._token,
77
Debug.Assert(obj == null || obj is Task || obj is
IValueTaskSource
);
85
Unsafe.As<
IValueTaskSource
>(obj).OnCompleted(ValueTaskAwaiter.s_invokeActionDelegate, continuation, _value._token,
97
Debug.Assert(obj == null || obj is Task || obj is
IValueTaskSource
);
113
Unsafe.As<
IValueTaskSource
>(obj).OnCompleted(ThreadPool.s_invokeAsyncStateMachineBox, box, _value._token,
src\runtime\src\libraries\System.Private.CoreLib\src\System\Runtime\CompilerServices\PoolingAsyncValueTaskMethodBuilderT.cs (2)
299
void
IValueTaskSource
.GetResult(short token) => throw NotImplemented.ByDesign;
468
void
IValueTaskSource
.GetResult(short token)
src\runtime\src\libraries\System.Private.CoreLib\src\System\Runtime\CompilerServices\ValueTaskAwaiter.cs (6)
50
Debug.Assert(obj == null || obj is Task || obj is
IValueTaskSource
);
58
Unsafe.As<
IValueTaskSource
>(obj).OnCompleted(s_invokeActionDelegate, continuation, _value._token, ValueTaskSourceOnCompletedFlags.UseSchedulingContext | ValueTaskSourceOnCompletedFlags.FlowExecutionContext);
70
Debug.Assert(obj == null || obj is Task || obj is
IValueTaskSource
);
78
Unsafe.As<
IValueTaskSource
>(obj).OnCompleted(s_invokeActionDelegate, continuation, _value._token, ValueTaskSourceOnCompletedFlags.UseSchedulingContext);
89
Debug.Assert(obj == null || obj is Task || obj is
IValueTaskSource
);
105
Unsafe.As<
IValueTaskSource
>(obj).OnCompleted(ThreadPool.s_invokeAsyncStateMachineBox, box, _value._token, ValueTaskSourceOnCompletedFlags.UseSchedulingContext);
src\runtime\src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\Sources\IValueTaskSource.cs (4)
8
/// <see cref="
IValueTaskSource
.OnCompleted"/> and <see cref="IValueTaskSource{TResult}.OnCompleted"/>
30
/// <summary>Indicates the status of an <see cref="
IValueTaskSource
"/> or <see cref="IValueTaskSource{TResult}"/>.</summary>
50
/// <summary>Schedules the continuation action for this <see cref="
IValueTaskSource
"/>.</summary>
57
/// <summary>Gets the result of the <see cref="
IValueTaskSource
"/>.</summary>
src\runtime\src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\Sources\ManualResetValueTaskSourceCore.cs (1)
10
/// <summary>Provides the core logic for implementing a manual-reset <see cref="
IValueTaskSource
"/> or <see cref="IValueTaskSource{TResult}"/>.</summary>
src\runtime\src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\Task.cs (3)
7118
void
IValueTaskSource
.GetResult(short token) => _waitForNextCompletedTask.GetResult(token);
7119
ValueTaskSourceStatus
IValueTaskSource
.GetStatus(short token) => _waitForNextCompletedTask.GetStatus(token);
7120
void
IValueTaskSource
.OnCompleted(Action<object?> continuation, object? state, short token, ValueTaskSourceOnCompletedFlags flags) =>
src\runtime\src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\ValueTask.cs (31)
38
/// <see cref="ValueTask"/> instances may be backed by <see cref="
IValueTaskSource
"/> instances that are reusable, and such
45
/// was constructed from an <see cref="
IValueTaskSource
"/>.
61
/// <summary>null if representing a successful synchronous completion, otherwise a <see cref="Task"/> or a <see cref="
IValueTaskSource
"/>.</summary>
63
/// <summary>Opaque value passed through to the <see cref="
IValueTaskSource
"/>.</summary>
88
/// <summary>Initialize the <see cref="ValueTask"/> with a <see cref="
IValueTaskSource
"/> object that represents the operation.</summary>
90
/// <param name="token">Opaque value passed through to the <see cref="
IValueTaskSource
"/>.</param>
92
public ValueTask(
IValueTaskSource
source, short token)
182
Debug.Assert(obj == null || obj is Task || obj is
IValueTaskSource
);
186
GetTaskForValueTaskSource(Unsafe.As<
IValueTaskSource
>(obj));
192
/// <summary>Creates a <see cref="Task"/> to represent the <see cref="
IValueTaskSource
"/>.</summary>
194
/// The <see cref="
IValueTaskSource
"/> is passed in rather than reading and casting <see cref="_obj"/>
197
private Task GetTaskForValueTaskSource(
IValueTaskSource
t)
238
/// <summary>Type used to create a <see cref="Task"/> to represent a <see cref="
IValueTaskSource
"/>.</summary>
244
vtst._source is not
IValueTaskSource
source)
288
/// <summary>The associated <see cref="
IValueTaskSource
"/>.</summary>
289
private
IValueTaskSource
? _source;
293
internal ValueTaskSourceAsTask(
IValueTaskSource
source, short token)
308
Debug.Assert(obj == null || obj is Task || obj is
IValueTaskSource
);
320
return Unsafe.As<
IValueTaskSource
>(obj).GetStatus(_token) != ValueTaskSourceStatus.Pending;
331
Debug.Assert(obj == null || obj is Task || obj is
IValueTaskSource
);
343
return Unsafe.As<
IValueTaskSource
>(obj).GetStatus(_token) == ValueTaskSourceStatus.Succeeded;
353
Debug.Assert(obj == null || obj is Task || obj is
IValueTaskSource
);
365
return Unsafe.As<
IValueTaskSource
>(obj).GetStatus(_token) == ValueTaskSourceStatus.Faulted;
371
/// If the <see cref="ValueTask"/> is backed by a result or by a <see cref="
IValueTaskSource
"/>,
380
Debug.Assert(obj == null || obj is Task || obj is
IValueTaskSource
);
392
return Unsafe.As<
IValueTaskSource
>(obj).GetStatus(_token) == ValueTaskSourceStatus.Canceled;
401
Debug.Assert(obj == null || obj is Task || obj is
IValueTaskSource
);
411
Unsafe.As<
IValueTaskSource
>(obj).GetResult(_token);
423
Debug.Assert(valueTask._obj is null or Task or
IValueTaskSource
, "If the ValueTask<>'s backing object is an IValueTaskSource<TResult>, it must also be IValueTaskSource.");
519
/// <param name="token">Opaque value passed through to the <see cref="
IValueTaskSource
"/>.</param>
698
/// <summary>The associated <see cref="
IValueTaskSource
"/>.</summary>
System.Runtime (1)
src\runtime\artifacts\obj\System.Runtime\Release\net11.0\System.Runtime.Forwards.cs (1)
836
[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.Tasks.Sources.
IValueTaskSource
))]
System.ServiceModel.NetTcp (1)
System\ServiceModel\Channels\SocketAwaitableEventArgs.cs (1)
91
void
IValueTaskSource
.GetResult(short token)
System.ServiceModel.UnixDomainSocket (1)
System\ServiceModel\Channels\SocketAwaitableEventArgs.cs (1)
91
void
IValueTaskSource
.GetResult(short token)
System.Threading.Channels (1)
System\Threading\Channels\AsyncOperation.cs (1)
467
void
IValueTaskSource
.GetResult(short token)
System.Threading.Tasks.Extensions (1)
System.Threading.Tasks.Extensions.cs (1)
11
[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.Tasks.Sources.
IValueTaskSource
))]