30 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.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.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.Net.Http (1)
System\Net\Http\SocketsHttpHandler\CreditWaiter.cs (1)
12
internal sealed class CreditWaiter :
IValueTaskSource
<int>
System.Net.Sockets (4)
System\Net\Sockets\Socket.Tasks.cs (4)
977
internal sealed class AwaitableSocketAsyncEventArgs : SocketAsyncEventArgs, IValueTaskSource,
IValueTaskSource
<int>,
IValueTaskSource
<Socket>,
IValueTaskSource
<SocketReceiveFromResult>,
IValueTaskSource
<SocketReceiveMessageFromResult>
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.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)
477
internal abstract class AsyncOperation<TSelf, TResult> : AsyncOperation<TSelf>,
IValueTaskSource
<TResult>
67 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.Net.Http (3)
System\Net\Http\SocketsHttpHandler\CreditWaiter.cs (3)
97
int
IValueTaskSource
<int>.GetResult(short token) =>
99
ValueTaskSourceStatus
IValueTaskSource
<int>.GetStatus(short token) =>
101
void
IValueTaskSource
<int>.OnCompleted(Action<object?> continuation, object? state, short token, ValueTaskSourceOnCompletedFlags flags) =>
System.Net.Sockets (4)
System\Net\Sockets\Socket.Tasks.cs (4)
1247
int
IValueTaskSource
<int>.GetResult(short token)
1285
Socket
IValueTaskSource
<Socket>.GetResult(short token)
1307
SocketReceiveFromResult
IValueTaskSource
<SocketReceiveFromResult>.GetResult(short token)
1329
SocketReceiveMessageFromResult
IValueTaskSource
<SocketReceiveMessageFromResult>.GetResult(short token)
System.Private.CoreLib (54)
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 (30)
468
/// <see cref="ValueTask{TResult}"/> instances may be backed by <see cref="
IValueTaskSource
{TResult}"/> instances that are reusable, and such
475
/// was constructed from an <see cref="
IValueTaskSource
{TResult}"/>.
490
/// <summary>null if <see cref="_result"/> has the result, otherwise a <see cref="Task{TResult}"/> or a <see cref="
IValueTaskSource
{TResult}"/>.</summary>
494
/// <summary>Opaque value passed through to the <see cref="
IValueTaskSource
{TResult}"/>.</summary>
532
/// <summary>Initialize the <see cref="ValueTask{TResult}"/> with a <see cref="
IValueTaskSource
{TResult}"/> object that represents the operation.</summary>
536
public ValueTask(
IValueTaskSource
<TResult> source, short token)
600
Debug.Assert(obj == null || obj is Task<TResult> || obj is
IValueTaskSource
<TResult>);
612
return GetTaskForValueTaskSource(Unsafe.As<
IValueTaskSource
<TResult>>(obj));
618
Debug.Assert(obj is Task<TResult> || obj is
IValueTaskSource
<TResult>);
621
(object)new ValueTaskSourceNotifier(Unsafe.As<
IValueTaskSource
<TResult>>(obj), _token);
626
private
IValueTaskSource
<TResult> _valueTaskSource;
629
public ValueTaskSourceNotifier(
IValueTaskSource
<TResult> valueTaskSource, short token)
642
/// <summary>Creates a <see cref="Task{TResult}"/> to represent the <see cref="
IValueTaskSource
{TResult}"/>.</summary>
644
/// The <see cref="
IValueTaskSource
{TResult}"/> is passed in rather than reading and casting <see cref="_obj"/>
647
private Task<TResult> GetTaskForValueTaskSource(
IValueTaskSource
<TResult> t)
687
/// <summary>Type used to create a <see cref="Task{TResult}"/> to represent a <see cref="
IValueTaskSource
{TResult}"/>.</summary>
693
vtst._source is not
IValueTaskSource
<TResult> source)
737
private
IValueTaskSource
<TResult>? _source;
741
public ValueTaskSourceAsTask(
IValueTaskSource
<TResult> source, short token)
756
Debug.Assert(obj == null || obj is Task<TResult> || obj is
IValueTaskSource
<TResult>);
768
return Unsafe.As<
IValueTaskSource
<TResult>>(obj).GetStatus(_token) != ValueTaskSourceStatus.Pending;
779
Debug.Assert(obj == null || obj is Task<TResult> || obj is
IValueTaskSource
<TResult>);
791
return Unsafe.As<
IValueTaskSource
<TResult>>(obj).GetStatus(_token) == ValueTaskSourceStatus.Succeeded;
801
Debug.Assert(obj == null || obj is Task<TResult> || obj is
IValueTaskSource
<TResult>);
813
return Unsafe.As<
IValueTaskSource
<TResult>>(obj).GetStatus(_token) == ValueTaskSourceStatus.Faulted;
819
/// If the <see cref="ValueTask{TResult}"/> is backed by a result or by a <see cref="
IValueTaskSource
{TResult}"/>,
828
Debug.Assert(obj == null || obj is Task<TResult> || obj is
IValueTaskSource
<TResult>);
840
return Unsafe.As<
IValueTaskSource
<TResult>>(obj).GetStatus(_token) == ValueTaskSourceStatus.Canceled;
852
Debug.Assert(obj == null || obj is Task<TResult> || obj is
IValueTaskSource
<TResult>);
865
return Unsafe.As<
IValueTaskSource
<TResult>>(obj).GetResult(_token);
System.Runtime (1)
artifacts\obj\System.Runtime\Debug\net11.0\System.Runtime.Forwards.cs (1)
824
[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.Tasks.Sources.
IValueTaskSource
<>))]
System.ServiceModel.NetTcp (1)
System\ServiceModel\Channels\SocketAwaitableEventArgs.cs (1)
79
int
IValueTaskSource
<int>.GetResult(short token)
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
<>))]