24 implementations of IValueTaskSource
http2cat (1)
src\Shared\ServerInfrastructure\ManualResetValueTaskSource.cs (1)
11internal sealed class ManualResetValueTaskSource<T> : IValueTaskSource<T>, IValueTaskSource
IIS.FunctionalTests (1)
src\Shared\ServerInfrastructure\ManualResetValueTaskSource.cs (1)
11internal sealed class ManualResetValueTaskSource<T> : IValueTaskSource<T>, IValueTaskSource
IIS.LongTests (1)
src\Shared\ServerInfrastructure\ManualResetValueTaskSource.cs (1)
11internal sealed class ManualResetValueTaskSource<T> : IValueTaskSource<T>, IValueTaskSource
IIS.NewHandler.FunctionalTests (1)
src\Shared\ServerInfrastructure\ManualResetValueTaskSource.cs (1)
11internal sealed class ManualResetValueTaskSource<T> : IValueTaskSource<T>, IValueTaskSource
IIS.ShadowCopy.Tests (1)
src\Shared\ServerInfrastructure\ManualResetValueTaskSource.cs (1)
11internal sealed class ManualResetValueTaskSource<T> : IValueTaskSource<T>, IValueTaskSource
IISExpress.FunctionalTests (1)
src\Shared\ServerInfrastructure\ManualResetValueTaskSource.cs (1)
11internal sealed class ManualResetValueTaskSource<T> : IValueTaskSource<T>, IValueTaskSource
Microsoft.AspNetCore.Server.HttpSys.FunctionalTests (1)
src\Shared\ServerInfrastructure\ManualResetValueTaskSource.cs (1)
11internal sealed class ManualResetValueTaskSource<T> : IValueTaskSource<T>, IValueTaskSource
Microsoft.AspNetCore.Server.IIS (2)
Core\IO\AsyncIOOperation.cs (1)
11internal abstract class AsyncIOOperation : IValueTaskSource<int>, IValueTaskSource
src\Shared\ServerInfrastructure\ManualResetValueTaskSource.cs (1)
11internal sealed class ManualResetValueTaskSource<T> : IValueTaskSource<T>, IValueTaskSource
Microsoft.AspNetCore.Server.Kestrel.Core (1)
src\Shared\ServerInfrastructure\ManualResetValueTaskSource.cs (1)
11internal sealed class ManualResetValueTaskSource<T> : IValueTaskSource<T>, IValueTaskSource
Microsoft.AspNetCore.Shared.Tests (1)
src\Shared\ServerInfrastructure\ManualResetValueTaskSource.cs (1)
11internal sealed class ManualResetValueTaskSource<T> : IValueTaskSource<T>, IValueTaskSource
System.Net.Http (1)
System\Net\Http\SocketsHttpHandler\Http2Stream.cs (1)
22private sealed class Http2Stream : IValueTaskSource, IHttpStreamHeadersHandler, IHttpTrace
System.Net.Quic (3)
src\libraries\Common\src\System\Net\StreamBuffer.cs (1)
285private sealed class ResettableValueTaskSource : IValueTaskSource
System\Net\Quic\Internal\ResettableValueTaskSource.cs (1)
14internal sealed class ResettableValueTaskSource : IValueTaskSource
System\Net\Quic\Internal\ValueTaskSource.cs (1)
14internal sealed class ValueTaskSource : IValueTaskSource
System.Net.Sockets (2)
System\Net\Sockets\Socket.Tasks.cs (1)
977internal sealed class AwaitableSocketAsyncEventArgs : SocketAsyncEventArgs, IValueTaskSource, IValueTaskSource<int>, IValueTaskSource<Socket>, IValueTaskSource<SocketReceiveFromResult>, IValueTaskSource<SocketReceiveMessageFromResult>
System\Net\Sockets\SocketAsyncEventArgs.cs (1)
920private sealed class MultiConnectSocketAsyncEventArgs : SocketAsyncEventArgs, IValueTaskSource
System.Private.CoreLib (4)
src\libraries\System.Private.CoreLib\src\Microsoft\Win32\SafeHandles\SafeFileHandle.ThreadPoolValueTaskSource.cs (1)
30internal sealed class ThreadPoolValueTaskSource : IThreadPoolWorkItem, IValueTaskSource<int>, IValueTaskSource<long>, IValueTaskSource
src\libraries\System.Private.CoreLib\src\System\Runtime\CompilerServices\PoolingAsyncValueTaskMethodBuilderT.cs (2)
237internal abstract class StateMachineBox : IValueTaskSource<TResult>, IValueTaskSource 282IValueTaskSource<TResult>, IValueTaskSource, IAsyncStateMachineBox, IThreadPoolWorkItem
src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\Task.cs (1)
6983private sealed class WhenEachState : Queue<Task>, IValueTaskSource, ITaskCompletionAction
System.ServiceModel.NetTcp (1)
System\ServiceModel\Channels\SocketAwaitableEventArgs.cs (1)
19internal class SocketAwaitableEventArgs : SocketAsyncEventArgs, IValueTaskSource<int>, IValueTaskSource
System.ServiceModel.UnixDomainSocket (1)
System\ServiceModel\Channels\SocketAwaitableEventArgs.cs (1)
19internal class SocketAwaitableEventArgs : SocketAsyncEventArgs, IValueTaskSource<int>, IValueTaskSource
System.Threading.Channels (1)
System\Threading\Channels\AsyncOperation.cs (1)
415internal abstract class AsyncOperation<TSelf> : AsyncOperation, IValueTaskSource
91 references to IValueTaskSource
http2cat (1)
src\Shared\ServerInfrastructure\ManualResetValueTaskSource.cs (1)
22void IValueTaskSource.GetResult(short token) => _core.GetResult(token);
IIS.FunctionalTests (1)
src\Shared\ServerInfrastructure\ManualResetValueTaskSource.cs (1)
22void IValueTaskSource.GetResult(short token) => _core.GetResult(token);
IIS.LongTests (1)
src\Shared\ServerInfrastructure\ManualResetValueTaskSource.cs (1)
22void IValueTaskSource.GetResult(short token) => _core.GetResult(token);
IIS.NewHandler.FunctionalTests (1)
src\Shared\ServerInfrastructure\ManualResetValueTaskSource.cs (1)
22void IValueTaskSource.GetResult(short token) => _core.GetResult(token);
IIS.ShadowCopy.Tests (1)
src\Shared\ServerInfrastructure\ManualResetValueTaskSource.cs (1)
22void IValueTaskSource.GetResult(short token) => _core.GetResult(token);
IISExpress.FunctionalTests (1)
src\Shared\ServerInfrastructure\ManualResetValueTaskSource.cs (1)
22void IValueTaskSource.GetResult(short token) => _core.GetResult(token);
Microsoft.AspNetCore.Server.HttpSys.FunctionalTests (1)
src\Shared\ServerInfrastructure\ManualResetValueTaskSource.cs (1)
22void IValueTaskSource.GetResult(short token) => _core.GetResult(token);
Microsoft.AspNetCore.Server.IIS (2)
Core\IO\AsyncIOOperation.cs (1)
58void IValueTaskSource.GetResult(short token)
src\Shared\ServerInfrastructure\ManualResetValueTaskSource.cs (1)
22void IValueTaskSource.GetResult(short token) => _core.GetResult(token);
Microsoft.AspNetCore.Server.Kestrel.Core (1)
src\Shared\ServerInfrastructure\ManualResetValueTaskSource.cs (1)
22void IValueTaskSource.GetResult(short token) => _core.GetResult(token);
Microsoft.AspNetCore.Shared.Tests (1)
src\Shared\ServerInfrastructure\ManualResetValueTaskSource.cs (1)
22void 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)
1417ValueTaskSourceStatus IValueTaskSource.GetStatus(short token) => _waitSource.GetStatus(token); 1418void IValueTaskSource.OnCompleted(Action<object?> continuation, object? state, short token, ValueTaskSourceOnCompletedFlags flags) => _waitSource.OnCompleted(continuation, state, token, flags); 1419void IValueTaskSource.GetResult(short token)
System.Net.Quic (9)
src\libraries\Common\src\System\Net\StreamBuffer.cs (3)
297ValueTaskSourceStatus IValueTaskSource.GetStatus(short token) => _waitSource.GetStatus(token); 299void IValueTaskSource.OnCompleted(Action<object?> continuation, object? state, short token, ValueTaskSourceOnCompletedFlags flags) => _waitSource.OnCompleted(continuation, state, token, flags); 301void IValueTaskSource.GetResult(short token)
System\Net\Quic\Internal\ResettableValueTaskSource.cs (3)
240ValueTaskSourceStatus IValueTaskSource.GetStatus(short token) 243void IValueTaskSource.OnCompleted(Action<object?> continuation, object? state, short token, ValueTaskSourceOnCompletedFlags flags) 246void IValueTaskSource.GetResult(short token)
System\Net\Quic\Internal\ValueTaskSource.cs (3)
169ValueTaskSourceStatus IValueTaskSource.GetStatus(short token) 172void IValueTaskSource.OnCompleted(Action<object?> continuation, object? state, short token, ValueTaskSourceOnCompletedFlags flags) 175void IValueTaskSource.GetResult(short token)
System.Net.Sockets (1)
System\Net\Sockets\Socket.Tasks.cs (1)
1267void IValueTaskSource.GetResult(short token)
System.Private.CoreLib (59)
src\libraries\System.Private.CoreLib\src\Microsoft\Win32\SafeHandles\SafeFileHandle.ThreadPoolValueTaskSource.cs (2)
26/// A reusable <see cref="IValueTaskSource"/> implementation that 65void IValueTaskSource.GetResult(short token) => GetResult(token);
src\libraries\System.Private.CoreLib\src\System\Runtime\CompilerServices\ConfiguredValueTaskAwaitable.cs (6)
55Debug.Assert(obj == null || obj is Task || obj is IValueTaskSource); 63Unsafe.As<IValueTaskSource>(obj).OnCompleted(ValueTaskAwaiter.s_invokeActionDelegate, continuation, _value._token, 77Debug.Assert(obj == null || obj is Task || obj is IValueTaskSource); 85Unsafe.As<IValueTaskSource>(obj).OnCompleted(ValueTaskAwaiter.s_invokeActionDelegate, continuation, _value._token, 97Debug.Assert(obj == null || obj is Task || obj is IValueTaskSource); 105Unsafe.As<IValueTaskSource>(obj).OnCompleted(ThreadPool.s_invokeAsyncStateMachineBox, box, _value._token,
src\libraries\System.Private.CoreLib\src\System\Runtime\CompilerServices\PoolingAsyncValueTaskMethodBuilderT.cs (2)
270void IValueTaskSource.GetResult(short token) => throw NotImplemented.ByDesign; 431void IValueTaskSource.GetResult(short token)
src\libraries\System.Private.CoreLib\src\System\Runtime\CompilerServices\ValueTaskAwaiter.cs (6)
50Debug.Assert(obj == null || obj is Task || obj is IValueTaskSource); 58Unsafe.As<IValueTaskSource>(obj).OnCompleted(s_invokeActionDelegate, continuation, _value._token, ValueTaskSourceOnCompletedFlags.UseSchedulingContext | ValueTaskSourceOnCompletedFlags.FlowExecutionContext); 70Debug.Assert(obj == null || obj is Task || obj is IValueTaskSource); 78Unsafe.As<IValueTaskSource>(obj).OnCompleted(s_invokeActionDelegate, continuation, _value._token, ValueTaskSourceOnCompletedFlags.UseSchedulingContext); 89Debug.Assert(obj == null || obj is Task || obj is IValueTaskSource); 97Unsafe.As<IValueTaskSource>(obj).OnCompleted(ThreadPool.s_invokeAsyncStateMachineBox, box, _value._token, ValueTaskSourceOnCompletedFlags.UseSchedulingContext);
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\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\libraries\System.Private.CoreLib\src\System\Threading\Tasks\Task.cs (3)
7017void IValueTaskSource.GetResult(short token) => _waitForNextCompletedTask.GetResult(token); 7018ValueTaskSourceStatus IValueTaskSource.GetStatus(short token) => _waitForNextCompletedTask.GetStatus(token); 7019void IValueTaskSource.OnCompleted(Action<object?> continuation, object? state, short token, ValueTaskSourceOnCompletedFlags flags) =>
src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\ValueTask.cs (35)
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> 87/// <summary>Initialize the <see cref="ValueTask"/> with a <see cref="IValueTaskSource"/> object that represents the operation.</summary> 89/// <param name="token">Opaque value passed through to the <see cref="IValueTaskSource"/>.</param> 91public ValueTask(IValueTaskSource source, short token) 175Debug.Assert(obj == null || obj is Task || obj is IValueTaskSource); 179GetTaskForValueTaskSource(Unsafe.As<IValueTaskSource>(obj)); 185Debug.Assert(obj is Task || obj is IValueTaskSource); 188(object)new ValueTaskSourceNotifier(Unsafe.As<IValueTaskSource>(obj), _token); 193private IValueTaskSource _valueTaskSource; 196public ValueTaskSourceNotifier(IValueTaskSource valueTaskSource, short token) 209/// <summary>Creates a <see cref="Task"/> to represent the <see cref="IValueTaskSource"/>.</summary> 211/// The <see cref="IValueTaskSource"/> is passed in rather than reading and casting <see cref="_obj"/> 214private Task GetTaskForValueTaskSource(IValueTaskSource t) 255/// <summary>Type used to create a <see cref="Task"/> to represent a <see cref="IValueTaskSource"/>.</summary> 261vtst._source is not IValueTaskSource source) 305/// <summary>The associated <see cref="IValueTaskSource"/>.</summary> 306private IValueTaskSource? _source; 310internal ValueTaskSourceAsTask(IValueTaskSource source, short token) 325Debug.Assert(obj == null || obj is Task || obj is IValueTaskSource); 337return Unsafe.As<IValueTaskSource>(obj).GetStatus(_token) != ValueTaskSourceStatus.Pending; 348Debug.Assert(obj == null || obj is Task || obj is IValueTaskSource); 360return Unsafe.As<IValueTaskSource>(obj).GetStatus(_token) == ValueTaskSourceStatus.Succeeded; 370Debug.Assert(obj == null || obj is Task || obj is IValueTaskSource); 382return Unsafe.As<IValueTaskSource>(obj).GetStatus(_token) == ValueTaskSourceStatus.Faulted; 388/// If the <see cref="ValueTask"/> is backed by a result or by a <see cref="IValueTaskSource"/>, 397Debug.Assert(obj == null || obj is Task || obj is IValueTaskSource); 409return Unsafe.As<IValueTaskSource>(obj).GetStatus(_token) == ValueTaskSourceStatus.Canceled; 418Debug.Assert(obj == null || obj is Task || obj is IValueTaskSource); 428Unsafe.As<IValueTaskSource>(obj).GetResult(_token); 440Debug.Assert(valueTask._obj is null or Task or IValueTaskSource, "If the ValueTask<>'s backing object is an IValueTaskSource<TResult>, it must also be IValueTaskSource."); 534/// <param name="token">Opaque value passed through to the <see cref="IValueTaskSource"/>.</param> 736/// <summary>The associated <see cref="IValueTaskSource"/>.</summary>
System.Runtime (1)
artifacts\obj\System.Runtime\Debug\net11.0\System.Runtime.Forwards.cs (1)
823[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.Tasks.Sources.IValueTaskSource))]
System.ServiceModel.NetTcp (1)
System\ServiceModel\Channels\SocketAwaitableEventArgs.cs (1)
91void IValueTaskSource.GetResult(short token)
System.ServiceModel.UnixDomainSocket (1)
System\ServiceModel\Channels\SocketAwaitableEventArgs.cs (1)
91void IValueTaskSource.GetResult(short token)
System.Threading.Channels (1)
System\Threading\Channels\AsyncOperation.cs (1)
450void 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))]