26 implementations of IValueTaskSource
http2cat (1)
src\Shared\ServerInfrastructure\ManualResetValueTaskSource.cs (1)
11
internal sealed class ManualResetValueTaskSource<T> :
IValueTaskSource
<T>, IValueTaskSource
IIS.FunctionalTests (1)
src\Shared\ServerInfrastructure\ManualResetValueTaskSource.cs (1)
11
internal sealed class ManualResetValueTaskSource<T> :
IValueTaskSource
<T>, IValueTaskSource
IIS.LongTests (1)
src\Shared\ServerInfrastructure\ManualResetValueTaskSource.cs (1)
11
internal sealed class ManualResetValueTaskSource<T> :
IValueTaskSource
<T>, IValueTaskSource
IIS.NewHandler.FunctionalTests (1)
src\Shared\ServerInfrastructure\ManualResetValueTaskSource.cs (1)
11
internal sealed class ManualResetValueTaskSource<T> :
IValueTaskSource
<T>, IValueTaskSource
IIS.NewShim.FunctionalTests (1)
src\Shared\ServerInfrastructure\ManualResetValueTaskSource.cs (1)
11
internal sealed class ManualResetValueTaskSource<T> :
IValueTaskSource
<T>, IValueTaskSource
IIS.ShadowCopy.Tests (1)
src\Shared\ServerInfrastructure\ManualResetValueTaskSource.cs (1)
11
internal sealed class ManualResetValueTaskSource<T> :
IValueTaskSource
<T>, IValueTaskSource
IISExpress.FunctionalTests (1)
src\Shared\ServerInfrastructure\ManualResetValueTaskSource.cs (1)
11
internal sealed class ManualResetValueTaskSource<T> :
IValueTaskSource
<T>, IValueTaskSource
InMemory.FunctionalTests (1)
TestTransport\InMemoryTransportConnection.cs (1)
162
private class ObservableValueTask<T> :
IValueTaskSource
<T>
Microsoft.AspNetCore.ConcurrencyLimiter.Tests (1)
MiddlewareTests.cs (1)
216
private class TestValueResult :
IValueTaskSource
<bool>
Microsoft.AspNetCore.Server.HttpSys (1)
AsyncAcceptContext.cs (1)
10
internal sealed unsafe partial class AsyncAcceptContext :
IValueTaskSource
<RequestContext>, IDisposable
Microsoft.AspNetCore.Server.HttpSys.FunctionalTests (1)
src\Shared\ServerInfrastructure\ManualResetValueTaskSource.cs (1)
11
internal sealed class ManualResetValueTaskSource<T> :
IValueTaskSource
<T>, IValueTaskSource
Microsoft.AspNetCore.Server.IIS (3)
Core\IO\AsyncIOOperation.cs (1)
11
internal abstract class AsyncIOOperation :
IValueTaskSource
<int>, IValueTaskSource
Core\NativeSafeHandle.cs (1)
9
internal sealed class NativeSafeHandle : SafeHandle,
IValueTaskSource
<object?>
src\Shared\ServerInfrastructure\ManualResetValueTaskSource.cs (1)
11
internal sealed class ManualResetValueTaskSource<T> :
IValueTaskSource
<T>, IValueTaskSource
Microsoft.AspNetCore.Server.Kestrel.Core (1)
src\Shared\ServerInfrastructure\ManualResetValueTaskSource.cs (1)
11
internal sealed class ManualResetValueTaskSource<T> :
IValueTaskSource
<T>, IValueTaskSource
Microsoft.AspNetCore.Server.Kestrel.Transport.Sockets (1)
Internal\SocketAwaitableEventArgs.cs (1)
15
internal class SocketAwaitableEventArgs : SocketAsyncEventArgs,
IValueTaskSource
<SocketOperationResult>
Microsoft.AspNetCore.Shared.Tests (1)
src\Shared\ServerInfrastructure\ManualResetValueTaskSource.cs (1)
11
internal sealed class ManualResetValueTaskSource<T> :
IValueTaskSource
<T>, IValueTaskSource
System.IO.Pipelines (2)
System\IO\Pipelines\Pipe.DefaultPipeReader.cs (1)
13
private sealed class DefaultPipeReader : PipeReader,
IValueTaskSource
<ReadResult>
System\IO\Pipelines\Pipe.DefaultPipeWriter.cs (1)
13
private sealed class DefaultPipeWriter : PipeWriter,
IValueTaskSource
<FlushResult>
System.Private.CoreLib (5)
src\libraries\System.Private.CoreLib\src\Microsoft\Win32\SafeHandles\SafeFileHandle.ThreadPoolValueTaskSource.cs (2)
30
internal sealed class ThreadPoolValueTaskSource : IThreadPoolWorkItem,
IValueTaskSource
<int>,
IValueTaskSource
<long>, IValueTaskSource
src\libraries\System.Private.CoreLib\src\System\Runtime\CompilerServices\PoolingAsyncValueTaskMethodBuilderT.cs (2)
237
internal abstract class StateMachineBox :
IValueTaskSource
<TResult>, IValueTaskSource
282
IValueTaskSource
<TResult>, IValueTaskSource, IAsyncStateMachineBox, IThreadPoolWorkItem
src\libraries\System.Private.CoreLib\src\System\Threading\PeriodicTimer.cs (1)
153
private sealed class State :
IValueTaskSource
<bool>
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)
473
internal abstract class AsyncOperation<TSelf, TResult> : AsyncOperation<TSelf>,
IValueTaskSource
<TResult>
55 references to IValueTaskSource
mscorlib (1)
mscorlib.cs (1)
108
[assembly:System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.Tasks.Sources.
IValueTaskSource
<>))]
netstandard (1)
netstandard.cs (1)
2113
[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.Tasks.Sources.
IValueTaskSource
<>))]
System.Private.CoreLib (50)
src\libraries\System.Private.CoreLib\src\Microsoft\Win32\SafeHandles\SafeFileHandle.ThreadPoolValueTaskSource.cs (1)
66
int
IValueTaskSource
<int>.GetResult(short token) => (int)GetResult(token);
src\libraries\System.Private.CoreLib\src\System\Runtime\CompilerServices\ConfiguredValueTaskAwaitable.cs (6)
160
Debug.Assert(obj == null || obj is Task<TResult> || obj is
IValueTaskSource
<TResult>);
168
Unsafe.As<
IValueTaskSource
<TResult>>(obj).OnCompleted(ValueTaskAwaiter.s_invokeActionDelegate, continuation, _value._token,
182
Debug.Assert(obj == null || obj is Task<TResult> || obj is
IValueTaskSource
<TResult>);
190
Unsafe.As<
IValueTaskSource
<TResult>>(obj).OnCompleted(ValueTaskAwaiter.s_invokeActionDelegate, continuation, _value._token,
202
Debug.Assert(obj == null || obj is Task<TResult> || obj is
IValueTaskSource
<TResult>);
210
Unsafe.As<
IValueTaskSource
<TResult>>(obj).OnCompleted(ThreadPool.s_invokeAsyncStateMachineBox, box, _value._token,
src\libraries\System.Private.CoreLib\src\System\Runtime\CompilerServices\PoolingAsyncValueTaskMethodBuilderT.cs (2)
267
TResult
IValueTaskSource
<TResult>.GetResult(short token) => throw NotImplemented.ByDesign;
418
TResult
IValueTaskSource
<TResult>.GetResult(short token)
src\libraries\System.Private.CoreLib\src\System\Runtime\CompilerServices\ValueTaskAwaiter.cs (6)
132
Debug.Assert(obj == null || obj is Task<TResult> || obj is
IValueTaskSource
<TResult>);
140
Unsafe.As<
IValueTaskSource
<TResult>>(obj).OnCompleted(ValueTaskAwaiter.s_invokeActionDelegate, continuation, _value._token, ValueTaskSourceOnCompletedFlags.UseSchedulingContext | ValueTaskSourceOnCompletedFlags.FlowExecutionContext);
152
Debug.Assert(obj == null || obj is Task<TResult> || obj is
IValueTaskSource
<TResult>);
160
Unsafe.As<
IValueTaskSource
<TResult>>(obj).OnCompleted(ValueTaskAwaiter.s_invokeActionDelegate, continuation, _value._token, ValueTaskSourceOnCompletedFlags.UseSchedulingContext);
171
Debug.Assert(obj == null || obj is Task<TResult> || obj is
IValueTaskSource
<TResult>);
179
Unsafe.As<
IValueTaskSource
<TResult>>(obj).OnCompleted(ThreadPool.s_invokeAsyncStateMachineBox, box, _value._token, ValueTaskSourceOnCompletedFlags.UseSchedulingContext);
src\libraries\System.Private.CoreLib\src\System\Threading\PeriodicTimer.cs (4)
176
/// <summary>Core of the <see cref="
IValueTaskSource
{TResult}"/> implementation.</summary>
265
bool
IValueTaskSource
<bool>.GetResult(short token)
302
ValueTaskSourceStatus
IValueTaskSource
<bool>.GetStatus(short token) => _mrvtsc.GetStatus(token);
305
void
IValueTaskSource
<bool>.OnCompleted(Action<object?> continuation, object? state, short token, ValueTaskSourceOnCompletedFlags flags) =>
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>
70
/// <summary>Schedules the continuation action for this <see cref="
IValueTaskSource
{TResult}"/>.</summary>
77
/// <summary>Gets the result of the <see cref="
IValueTaskSource
{TResult}"/>.</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\ValueTask.cs (26)
444
/// <see cref="ValueTask{TResult}"/> instances may be backed by <see cref="
IValueTaskSource
{TResult}"/> instances that are reusable, and such
451
/// was constructed from an <see cref="
IValueTaskSource
{TResult}"/>.
466
/// <summary>null if <see cref="_result"/> has the result, otherwise a <see cref="Task{TResult}"/> or a <see cref="
IValueTaskSource
{TResult}"/>.</summary>
470
/// <summary>Opaque value passed through to the <see cref="
IValueTaskSource
{TResult}"/>.</summary>
508
/// <summary>Initialize the <see cref="ValueTask{TResult}"/> with a <see cref="
IValueTaskSource
{TResult}"/> object that represents the operation.</summary>
512
public ValueTask(
IValueTaskSource
<TResult> source, short token)
576
Debug.Assert(obj == null || obj is Task<TResult> || obj is
IValueTaskSource
<TResult>);
588
return GetTaskForValueTaskSource(Unsafe.As<
IValueTaskSource
<TResult>>(obj));
594
/// <summary>Creates a <see cref="Task{TResult}"/> to represent the <see cref="
IValueTaskSource
{TResult}"/>.</summary>
596
/// The <see cref="
IValueTaskSource
{TResult}"/> is passed in rather than reading and casting <see cref="_obj"/>
599
private Task<TResult> GetTaskForValueTaskSource(
IValueTaskSource
<TResult> t)
639
/// <summary>Type used to create a <see cref="Task{TResult}"/> to represent a <see cref="
IValueTaskSource
{TResult}"/>.</summary>
645
vtst._source is not
IValueTaskSource
<TResult> source)
689
private
IValueTaskSource
<TResult>? _source;
693
public ValueTaskSourceAsTask(
IValueTaskSource
<TResult> source, short token)
708
Debug.Assert(obj == null || obj is Task<TResult> || obj is
IValueTaskSource
<TResult>);
720
return Unsafe.As<
IValueTaskSource
<TResult>>(obj).GetStatus(_token) != ValueTaskSourceStatus.Pending;
731
Debug.Assert(obj == null || obj is Task<TResult> || obj is
IValueTaskSource
<TResult>);
743
return Unsafe.As<
IValueTaskSource
<TResult>>(obj).GetStatus(_token) == ValueTaskSourceStatus.Succeeded;
753
Debug.Assert(obj == null || obj is Task<TResult> || obj is
IValueTaskSource
<TResult>);
765
return Unsafe.As<
IValueTaskSource
<TResult>>(obj).GetStatus(_token) == ValueTaskSourceStatus.Faulted;
771
/// If the <see cref="ValueTask{TResult}"/> is backed by a result or by a <see cref="
IValueTaskSource
{TResult}"/>,
780
Debug.Assert(obj == null || obj is Task<TResult> || obj is
IValueTaskSource
<TResult>);
792
return Unsafe.As<
IValueTaskSource
<TResult>>(obj).GetStatus(_token) == ValueTaskSourceStatus.Canceled;
804
Debug.Assert(obj == null || obj is Task<TResult> || obj is
IValueTaskSource
<TResult>);
817
return Unsafe.As<
IValueTaskSource
<TResult>>(obj).GetResult(_token);
System.Runtime (1)
artifacts\obj\System.Runtime\Debug\net10.0\System.Runtime.Forwards.cs (1)
816
[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.Tasks.Sources.
IValueTaskSource
<>))]
System.ServiceModel.UnixDomainSocket (1)
System\ServiceModel\Channels\SocketAwaitableEventArgs.cs (1)
79
int
IValueTaskSource
<int>.GetResult(short token)
System.Threading.Tasks.Extensions (1)
System.Threading.Tasks.Extensions.cs (1)
12
[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.Tasks.Sources.
IValueTaskSource
<>))]