ValueTask

TestFiles\ApiConventionAnalyzerIntegrationTest\DiagnosticsAreReturned_IfAsyncMethodReturningValueTaskWithProducesResponseTypeAttribute_ReturnsUndocumentedStatusCode.cs (1)

13public async ValueTask<IActionResult> Method(int id)

StartupForDynamic.cs (2)

49public override ValueTask<RouteValueDictionary> TransformAsync(HttpContext httpContext, RouteValueDictionary values) 65public override ValueTask<IReadOnlyList<Endpoint>> FilterAsync(HttpContext httpContext, RouteValueDictionary values, IReadOnlyList<Endpoint> endpoints)

StartupForDynamicAndRazorPages.cs (1)

35public override ValueTask<RouteValueDictionary> TransformAsync(HttpContext httpContext, RouteValueDictionary values)

StartupForDynamicOrder.cs (1)

89public override ValueTask<RouteValueDictionary> TransformAsync(HttpContext httpContext, RouteValueDictionary values)

StartupRoutingDifferentBranches.cs (1)

93public override ValueTask<RouteValueDictionary> TransformAsync(HttpContext httpContext, RouteValueDictionary values)

netstandard.cs (1)

2132[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.Tasks.ValueTask<>))]

ICounterGrain.cs (2)

8ValueTask<int> Increment(); 9ValueTask<int> Get();

Program.cs (2)

19public ValueTask<int> Get() 24public async ValueTask<int> Increment()

Startup.cs (1)

58public static Task GetAsTask(this in ValueTask<FlushResult> valueTask)

src\RoslynAnalyzers\NuGet\PerformanceSensitiveAnalyzers\PerformanceSensitiveAttribute.cs (1)

94/// <see cref="System.Threading.Tasks.ValueTask{TResult}"/>.</para>

src\RoslynAnalyzers\Utilities\Workspaces\DocumentExtensions.cs (3)

16public static async ValueTask<SemanticModel> GetRequiredSemanticModelAsync(this Document document, CancellationToken cancellationToken) 25public static async ValueTask<SyntaxTree> GetRequiredSyntaxTreeAsync(this Document document, CancellationToken cancellationToken) 34public static async ValueTask<SyntaxNode> GetRequiredSyntaxRootAsync(this Document document, CancellationToken cancellationToken)

Remote\SerializationValidator.cs (1)

25public override async ValueTask<T> GetAssetAsync<T>(AssetPath assetPath, Checksum checksum, CancellationToken cancellationToken)

ProcessRunner.cs (1)

132static async ValueTask<int> GetExitCodeAsync(Process process)

ServerSentEvents\SseParser_1.cs (1)

516private async ValueTask<int> FillLineBufferAsync(CancellationToken cancellationToken)

src\Servers\Kestrel\shared\test\PassThroughConnectionMiddleware.cs (2)

54public override ValueTask<FlushResult> FlushAsync(CancellationToken cancellationToken = default) => _output.FlushAsync(cancellationToken); 78public override ValueTask<ReadResult> ReadAsync(CancellationToken cancellationToken = default) => _input.ReadAsync(cancellationToken);

src\Servers\Kestrel\test\FunctionalTests\ConnectionMiddlewareTests.cs (2)

117public override ValueTask<ReadResult> ReadAsync(CancellationToken cancellationToken = default) 152public override ValueTask<FlushResult> FlushAsync(CancellationToken cancellationToken = default)

System\IO\SyncTextReader.cs (1)

99public override ValueTask<string?> ReadLineAsync(CancellationToken cancellationToken)

System\Data\Common\DbConnection.cs (3)

67protected virtual ValueTask<DbTransaction> BeginDbTransactionAsync(IsolationLevel isolationLevel, CancellationToken cancellationToken) 84public ValueTask<DbTransaction> BeginTransactionAsync(CancellationToken cancellationToken = default) 87public ValueTask<DbTransaction> BeginTransactionAsync(IsolationLevel isolationLevel, CancellationToken cancellationToken = default)

System\Data\Common\DbDataSource.cs (2)

33protected virtual async ValueTask<DbConnection> OpenDbConnectionAsync(CancellationToken cancellationToken = default) 66public ValueTask<DbConnection> OpenConnectionAsync(CancellationToken cancellationToken = default)

System\Formats\Tar\SeekableSubReadStream.cs (1)

70public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

System\Formats\Tar\SubReadStream.cs (2)

144public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default) 155protected async ValueTask<int> ReadAsyncCore(Memory<byte> buffer, CancellationToken cancellationToken)

System\Formats\Tar\TarHeader.Read.cs (2)

40internal static async ValueTask<TarHeader?> TryGetNextHeaderAsync(Stream archiveStream, bool copyData, TarEntryFormat initialFormat, bool processDataBlock, CancellationToken cancellationToken) 336private static async ValueTask<Stream?> GetDataStreamAsync(Stream archiveStream, bool copyData, long size, CancellationToken cancellationToken)

System\Formats\Tar\TarHelpers.cs (1)

322internal static async ValueTask<int> SkipBlockAlignmentPaddingAsync(Stream archiveStream, long size, CancellationToken cancellationToken)

System\Formats\Tar\TarReader.cs (5)

175public ValueTask<TarEntry?> GetNextEntryAsync(bool copyData = false, CancellationToken cancellationToken = default) 282private async ValueTask<TarEntry?> GetNextEntryInternalAsync(bool copyData, CancellationToken cancellationToken) 357private async ValueTask<TarHeader?> TryGetNextEntryHeaderAsync(bool copyData, CancellationToken cancellationToken) 428private async ValueTask<TarHeader?> TryProcessExtendedAttributesHeaderAsync(TarHeader extendedAttributesHeader, bool copyData, CancellationToken cancellationToken) 542private async ValueTask<TarHeader?> TryProcessGnuMetadataHeaderAsync(TarHeader header, bool copyData, CancellationToken cancellationToken)

System\IO\Compression\DeflateManaged\DeflateManagedStream.cs (5)

160private ValueTask<int> ReadAsyncInternal(Memory<byte> buffer, CancellationToken cancellationToken) 188ValueTask<int> readTask = _stream!.ReadAsync(_buffer.AsMemory(), cancellationToken); 203private async ValueTask<int> ReadAsyncCore(ValueTask<int> readTask, Memory<byte> buffer, CancellationToken cancellationToken) 260public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

System\IO\Compression\DeflateZLib\DeflateStream.cs (3)

409public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default) 423internal ValueTask<int> ReadAsyncMemory(Memory<byte> buffer, CancellationToken cancellationToken) 439async ValueTask<int> Core(Memory<byte> buffer, CancellationToken cancellationToken)

System\IO\Compression\GZipStream.cs (1)

205public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default(CancellationToken))

System\IO\Compression\PositionPreservingWriteOnlyStreamWrapper.cs (1)

117public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default) => throw new NotSupportedException(SR.NotSupported);

System\IO\Compression\ZipArchiveEntry.cs (1)

1446public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

System\IO\Compression\ZipCustomStreams.cs (4)

125public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default) 341public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default) 347async ValueTask<int> Core(Memory<byte> buffer, CancellationToken cancellationToken) 495public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

System\IO\Compression\ZLibStream.cs (1)

164public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

System\IO\Compression\dec\BrotliStream.Decompress.cs (2)

132public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default(CancellationToken)) 146async ValueTask<int> Core(Memory<byte> buffer, CancellationToken cancellationToken)

System\IO\IsolatedStorage\IsolatedStorageFileStream.cs (1)

261public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken)

System\IO\Pipelines\Pipe.cs (9)

363internal ValueTask<FlushResult> FlushAsync(CancellationToken cancellationToken) 371ValueTask<FlushResult> result; 382private void PrepareFlushUnsynchronized(out CompletionData completionData, out ValueTask<FlushResult> result, CancellationToken cancellationToken) 682internal ValueTask<ReadResult> ReadAtLeastAsync(int minimumBytes, CancellationToken token) 695ValueTask<ReadResult> result; 741internal ValueTask<ReadResult> ReadAsync(CancellationToken token) 753ValueTask<ReadResult> result; 1052internal ValueTask<FlushResult> WriteAsync(ReadOnlyMemory<byte> source, CancellationToken cancellationToken) 1070ValueTask<FlushResult> result;

System\IO\Pipelines\Pipe.DefaultPipeReader.cs (2)

24public override ValueTask<ReadResult> ReadAsync(CancellationToken cancellationToken = default) => _pipe.ReadAsync(cancellationToken); 26protected override ValueTask<ReadResult> ReadAtLeastAsyncCore(int minimumBytes, CancellationToken cancellationToken) => _pipe.ReadAtLeastAsync(minimumBytes, cancellationToken);

System\IO\Pipelines\Pipe.DefaultPipeWriter.cs (2)

32public override ValueTask<FlushResult> FlushAsync(CancellationToken cancellationToken = default) => _pipe.FlushAsync(cancellationToken); 48public override ValueTask<FlushResult> WriteAsync(ReadOnlyMemory<byte> source, CancellationToken cancellationToken = default)

System\IO\Pipelines\PipeReader.cs (9)

31/// <returns>A <see cref="System.Threading.Tasks.ValueTask{T}" /> representing the asynchronous read operation.</returns> 32public abstract ValueTask<ReadResult> ReadAsync(CancellationToken cancellationToken = default); 37/// <returns>A <see cref="System.Threading.Tasks.ValueTask{T}" /> representing the asynchronous read operation.</returns> 43/// Passing a value of 0 for <paramref name="minimumSize" /> will return a <see cref="System.Threading.Tasks.ValueTask{T}" /> that will not complete until 51public ValueTask<ReadResult> ReadAtLeastAsync(int minimumSize, CancellationToken cancellationToken = default) 64/// <returns>A <see cref="System.Threading.Tasks.ValueTask{T}" /> representing the asynchronous read operation.</returns> 66protected virtual async ValueTask<ReadResult> ReadAtLeastAsyncCore(int minimumSize, CancellationToken cancellationToken) 221static async ValueTask<FlushResult> Awaited(ValueTask writeTask) 232private async Task CopyToAsyncCore<TStream>(TStream destination, Func<TStream, ReadOnlyMemory<byte>, CancellationToken, ValueTask<FlushResult>> writeAsync, CancellationToken cancellationToken)

System\IO\Pipelines\PipeReaderStream.cs (3)

66ValueTask<ReadResult> vt = _pipeReader.ReadAsync(); 99public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default) 105private async ValueTask<int> ReadAsyncInternal(Memory<byte> buffer, CancellationToken cancellationToken)

System\IO\Pipelines\PipeWriter.cs (2)

59public abstract ValueTask<FlushResult> FlushAsync(CancellationToken cancellationToken = default); 113public virtual ValueTask<FlushResult> WriteAsync(ReadOnlyMemory<byte> source, CancellationToken cancellationToken = default)

System\IO\Pipelines\PipeWriterStream.cs (5)

79ValueTask<FlushResult> valueTask = _pipeWriter.WriteAsync(new ReadOnlyMemory<byte>(buffer, offset, count), cancellationToken); 87ValueTask<FlushResult> valueTask = _pipeWriter.WriteAsync(buffer, cancellationToken); 95ValueTask<FlushResult> valueTask = _pipeWriter.FlushAsync(cancellationToken); 100private static Task GetFlushResultAsTask(ValueTask<FlushResult> valueTask) 113static async Task AwaitTask(ValueTask<FlushResult> valueTask)

System\IO\Pipelines\SequencePipeReader.cs (1)

62public override ValueTask<ReadResult> ReadAsync(CancellationToken cancellationToken = default)

System\IO\Pipelines\StreamPipeReader.cs (4)

201public override ValueTask<ReadResult> ReadAsync(CancellationToken cancellationToken = default) 206protected override ValueTask<ReadResult> ReadAtLeastAsyncCore(int minimumSize, CancellationToken cancellationToken) 211private ValueTask<ReadResult> ReadInternalAsync(int? minimumSize, CancellationToken cancellationToken) 245static async ValueTask<ReadResult> Core(StreamPipeReader reader, int? minimumSize, CancellationTokenSource tokenSource, CancellationToken cancellationToken)

System\IO\Pipelines\StreamPipeWriter.cs (3)

266public override ValueTask<FlushResult> FlushAsync(CancellationToken cancellationToken = default) 279public override ValueTask<FlushResult> WriteAsync(ReadOnlyMemory<byte> source, CancellationToken cancellationToken = default) 292private async ValueTask<FlushResult> FlushAsyncInternal(bool writeToStream, ReadOnlyMemory<byte> data, CancellationToken cancellationToken = default)

System\IO\Pipes\PipeStream.Unix.cs (2)

82public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default(CancellationToken)) 303private async ValueTask<int> ReadAsyncCore(Memory<byte> destination, CancellationToken cancellationToken)

System\IO\Ports\SerialStream.Unix.cs (1)

463public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

System\Linq\AggregateAsync.cs (20)

System\Linq\AggregateBy.cs (10)

System\Linq\AllAsync.cs (6)

24public static ValueTask<bool> AllAsync<TSource>( 34static async ValueTask<bool> Impl( 61public static ValueTask<bool> AllAsync<TSource>( 64ValueTask<bool>> predicate, 72static async ValueTask<bool> Impl( 74Func<TSource, CancellationToken, ValueTask<bool>> predicate,

System\Linq\AnyAsync.cs (8)

19public static ValueTask<bool> AnyAsync<TSource>( 27static async ValueTask<bool> Impl( 48public static ValueTask<bool> AnyAsync<TSource>( 58static async ValueTask<bool> Impl( 85public static ValueTask<bool> AnyAsync<TSource>( 87Func<TSource, CancellationToken, ValueTask<bool>> predicate, 95static async ValueTask<bool> Impl( 97Func<TSource, CancellationToken, ValueTask<bool>> predicate,

System\Linq\AverageAsync.cs (20)

System\Linq\ContainsAsync.cs (2)

21public static ValueTask<bool> ContainsAsync<TSource>( 31async static ValueTask<bool> Impl(

System\Linq\CountAsync.cs (16)

20public static ValueTask<int> CountAsync<TSource>( 28static async ValueTask<int> Impl( 52public static ValueTask<int> CountAsync<TSource>( 62static async ValueTask<int> Impl( 87public static ValueTask<int> CountAsync<TSource>( 89Func<TSource, CancellationToken, ValueTask<bool>> predicate, 97static async ValueTask<int> Impl( 99Func<TSource, CancellationToken, ValueTask<bool>> predicate, 121public static ValueTask<long> LongCountAsync<TSource>( 129static async ValueTask<long> Impl( 152public static ValueTask<long> LongCountAsync<TSource>( 162static async ValueTask<long> Impl( 186public static ValueTask<long> LongCountAsync<TSource>( 188Func<TSource, CancellationToken, ValueTask<bool>> predicate, 196static async ValueTask<long> Impl( 198Func<TSource, CancellationToken, ValueTask<bool>> predicate,

System\Linq\CountBy.cs (2)

76Func<TSource, CancellationToken, ValueTask<TKey>> keySelector, 87IAsyncEnumerable<TSource> source, Func<TSource, CancellationToken, ValueTask<TKey>> keySelector, IEqualityComparer<TKey>? keyComparer, [EnumeratorCancellation] CancellationToken cancellationToken)

System\Linq\DistinctBy.cs (3)

73/// <para>The <see cref="DistinctBy{TSource, TKey}(IAsyncEnumerable{TSource}, Func{TSource, CancellationToken, ValueTask{TKey}}, IEqualityComparer{TKey}?)" /> method returns an unordered sequence that contains no duplicate values. If <paramref name="comparer" /> is <see langword="null" />, the default equality comparer, <see cref="EqualityComparer{T}.Default" />, is used to compare values.</para> 79Func<TSource, CancellationToken, ValueTask<TKey>> keySelector, 91Func<TSource, CancellationToken, ValueTask<TKey>> keySelector,

System\Linq\ElementAtAsync.cs (6)

20public static ValueTask<TSource> ElementAtAsync<TSource>( 40public static ValueTask<TSource?> ElementAtOrDefaultAsync<TSource>( 64public static ValueTask<TSource> ElementAtAsync<TSource>( 91public static ValueTask<TSource?> ElementAtOrDefaultAsync<TSource>( 106private static async ValueTask<TSource?> ElementAtOrDefaultAsync<TSource>( 135private static async ValueTask<TSource?> ElementAtFromEndOrDefault<TSource>(

System\Linq\Empty.cs (2)

30public ValueTask<bool> MoveNextAsync() => default; 42public IOrderedAsyncEnumerable<TResult> CreateOrderedAsyncEnumerable<TKey>(Func<TResult, CancellationToken, ValueTask<TKey>> keySelector, IComparer<TKey>? comparer, bool descending)

System\Linq\ExceptBy.cs (2)

89Func<TSource, CancellationToken, ValueTask<TKey>> keySelector, 103Func<TSource, CancellationToken, ValueTask<TKey>> keySelector,

System\Linq\FirstAsync.cs (20)

System\Linq\GroupBy.cs (16)

System\Linq\GroupJoin.cs (6)

104Func<TOuter, CancellationToken, ValueTask<TKey>> outerKeySelector, 105Func<TInner, CancellationToken, ValueTask<TKey>> innerKeySelector, 106Func<TOuter, IEnumerable<TInner>, CancellationToken, ValueTask<TResult>> resultSelector, 122Func<TOuter, CancellationToken, ValueTask<TKey>> outerKeySelector, 123Func<TInner, CancellationToken, ValueTask<TKey>> innerKeySelector, 124Func<TOuter, IEnumerable<TInner>, CancellationToken, ValueTask<TResult>> resultSelector,

System\Linq\IntersectBy.cs (2)

99Func<TSource, CancellationToken, ValueTask<TKey>> keySelector, 113Func<TSource, CancellationToken, ValueTask<TKey>> keySelector,

System\Linq\Join.cs (6)

109Func<TOuter, CancellationToken, ValueTask<TKey>> outerKeySelector, 110Func<TInner, CancellationToken, ValueTask<TKey>> innerKeySelector, 111Func<TOuter, TInner, CancellationToken, ValueTask<TResult>> resultSelector, 127Func<TOuter, CancellationToken, ValueTask<TKey>> outerKeySelector, 128Func<TInner, CancellationToken, ValueTask<TKey>> innerKeySelector, 129Func<TOuter, TInner, CancellationToken, ValueTask<TResult>> resultSelector,

System\Linq\LastAsync.cs (20)

System\Linq\LeftJoin.cs (6)

104Func<TOuter, CancellationToken, ValueTask<TKey>> outerKeySelector, 105Func<TInner, CancellationToken, ValueTask<TKey>> innerKeySelector, 106Func<TOuter, TInner?, CancellationToken, ValueTask<TResult>> resultSelector, 122Func<TOuter, CancellationToken, ValueTask<TKey>> outerKeySelector, 123Func<TInner, CancellationToken, ValueTask<TKey>> innerKeySelector, 124Func<TOuter, TInner?, CancellationToken, ValueTask<TResult>> resultSelector,

System\Linq\MaxAsync.cs (10)

24public static ValueTask<TSource?> MaxAsync<TSource>( 38return (ValueTask<TSource?>)(object)MaxAsync((IAsyncEnumerable<float>)(object)source, cancellationToken); 43return (ValueTask<TSource?>)(object)MaxAsync((IAsyncEnumerable<double>)(object)source, cancellationToken); 48return (ValueTask<TSource?>)(object)MaxAsync((IAsyncEnumerable<float?>)(object)source, cancellationToken); 53return (ValueTask<TSource?>)(object)MaxAsync((IAsyncEnumerable<double?>)(object)source, cancellationToken); 59static async ValueTask<TSource?> Impl( 129private static async ValueTask<float> MaxAsync( 170private static async ValueTask<double> MaxAsync( 211private static async ValueTask<float?> MaxAsync(IAsyncEnumerable<float?> source, CancellationToken cancellationToken) 234private static async ValueTask<double?> MaxAsync(IAsyncEnumerable<double?> source, CancellationToken cancellationToken)

System\Linq\MaxByAsync.cs (6)

25public static ValueTask<TSource?> MaxByAsync<TSource, TKey>( 36static async ValueTask<TSource?> Impl( 135public static ValueTask<TSource?> MaxByAsync<TSource, TKey>( 137Func<TSource, CancellationToken, ValueTask<TKey>> keySelector, 146static async ValueTask<TSource?> Impl( 148Func<TSource, CancellationToken, ValueTask<TKey>> keySelector,

System\Linq\MinAsync.cs (10)

24public static ValueTask<TSource?> MinAsync<TSource>( 38return (ValueTask<TSource?>)(object)MinAsync((IAsyncEnumerable<float>)(object)source, cancellationToken); 43return (ValueTask<TSource?>)(object)MinAsync((IAsyncEnumerable<double>)(object)source, cancellationToken); 48return (ValueTask<TSource?>)(object)MinAsync((IAsyncEnumerable<float?>)(object)source, cancellationToken); 53return (ValueTask<TSource?>)(object)MinAsync((IAsyncEnumerable<double?>)(object)source, cancellationToken); 59static async ValueTask<TSource?> Impl(IAsyncEnumerable<TSource> source, IComparer<TSource> comparer, CancellationToken cancellationToken) 126private static async ValueTask<float> MinAsync( 171private static async ValueTask<double> MinAsync( 216private static async ValueTask<float?> MinAsync( 241private static async ValueTask<double?> MinAsync(

System\Linq\MinByAsync.cs (6)

25public static ValueTask<TSource?> MinByAsync<TSource, TKey>( 36static async ValueTask<TSource?> Impl( 135public static ValueTask<TSource?> MinByAsync<TSource, TKey>( 137Func<TSource, CancellationToken, ValueTask<TKey>> keySelector, 146static async ValueTask<TSource?> Impl( 148Func<TSource, CancellationToken, ValueTask<TKey>> keySelector,

System\Linq\OrderBy.cs (10)

System\Linq\RightJoin.cs (6)

105Func<TOuter, CancellationToken, ValueTask<TKey>> outerKeySelector, 106Func<TInner, CancellationToken, ValueTask<TKey>> innerKeySelector, 107Func<TOuter?, TInner, CancellationToken, ValueTask<TResult>> resultSelector, 123Func<TOuter, CancellationToken, ValueTask<TKey>> outerKeySelector, 124Func<TInner, CancellationToken, ValueTask<TKey>> innerKeySelector, 125Func<TOuter?, TInner, CancellationToken, ValueTask<TResult>> resultSelector,

System\Linq\Select.cs (4)

60Func<TSource, CancellationToken, ValueTask<TResult>> selector) 71Func<TSource, CancellationToken, ValueTask<TResult>> selector, 135Func<TSource, int, CancellationToken, ValueTask<TResult>> selector) 146Func<TSource, int, CancellationToken, ValueTask<TResult>> selector,

System\Linq\SelectMany.cs (16)

System\Linq\SequenceEqualAsync.cs (2)

22public static ValueTask<bool> SequenceEqualAsync<TSource>( 33static async ValueTask<bool> Impl(

System\Linq\SingleAsync.cs (20)

System\Linq\SkipWhile.cs (4)

78Func<TSource, CancellationToken, ValueTask<bool>> predicate) 89Func<TSource, CancellationToken, ValueTask<bool>> predicate, 185Func<TSource, int, CancellationToken, ValueTask<bool>> predicate) 196Func<TSource, int, CancellationToken, ValueTask<bool>> predicate,

System\Linq\SumAsync.cs (20)

System\Linq\TakeWhile.cs (4)

62Func<TSource, CancellationToken, ValueTask<bool>> predicate) 73Func<TSource, CancellationToken, ValueTask<bool>> predicate, 145Func<TSource, int, CancellationToken, ValueTask<bool>> predicate) 156Func<TSource, int, CancellationToken, ValueTask<bool>> predicate,

System\Linq\ToArrayAsync.cs (2)

19public static ValueTask<TSource[]> ToArrayAsync<TSource>( 27static async ValueTask<TSource[]> Impl(

System\Linq\ToDictionaryAsync.cs (17)

System\Linq\ToHashSetAsync.cs (2)

20public static ValueTask<HashSet<TSource>> ToHashSetAsync<TSource>( 29static async ValueTask<HashSet<TSource>> Impl(

System\Linq\ToListAsync.cs (2)

19public static ValueTask<List<TSource>> ToListAsync<TSource>( 27static async ValueTask<List<TSource>> Impl(

System\Linq\ToLookupAsync.cs (18)

System\Linq\UnionBy.cs (2)

77Func<TSource, CancellationToken, ValueTask<TKey>> keySelector, 91Func<TSource, CancellationToken, ValueTask<TKey>> keySelector,

System\Linq\Where.cs (4)

55Func<TSource, CancellationToken, ValueTask<bool>> predicate) 66Func<TSource, CancellationToken, ValueTask<bool>> predicate, 134Func<TSource, int, CancellationToken, ValueTask<bool>> predicate) 145Func<TSource, int, CancellationToken, ValueTask<bool>> predicate,

System\Linq\Zip.cs (2)

74Func<TFirst, TSecond, CancellationToken, ValueTask<TResult>> resultSelector) 87Func<TFirst, TSecond, CancellationToken, ValueTask<TResult>> resultSelector,

src\libraries\Common\src\System\IO\ReadOnlyMemoryStream.cs (1)

136public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default(CancellationToken))

src\libraries\Common\src\System\IO\DelegatingStream.cs (1)

110public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

src\libraries\Common\src\System\IO\ReadOnlyMemoryStream.cs (1)

136public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default(CancellationToken))

src\libraries\Common\src\System\Threading\Tasks\TaskCompletionSourceWithCancellation.cs (2)

17public async ValueTask<T> WaitWithCancellationAsync(CancellationToken cancellationToken) 33public ValueTask<T> WaitWithCancellationAsync(bool async, CancellationToken cancellationToken)

System\Net\Http\DiagnosticsHandler.cs (2)

74internal override ValueTask<HttpResponseMessage> SendAsync(HttpRequestMessage request, bool async, CancellationToken cancellationToken) 88private async ValueTask<HttpResponseMessage> SendAsyncCore(HttpRequestMessage request, bool async, CancellationToken cancellationToken)

System\Net\Http\EmptyReadStream.cs (1)

24public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken) =>

System\Net\Http\HttpBaseStream.cs (1)

88public abstract override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken);

System\Net\Http\Metrics\MetricsHandler.cs (2)

39internal override ValueTask<HttpResponseMessage> SendAsync(HttpRequestMessage request, bool async, CancellationToken cancellationToken) 53private async ValueTask<HttpResponseMessage> SendAsyncWithMetrics(HttpRequestMessage request, bool async, CancellationToken cancellationToken)

System\Net\Http\MultipartContent.cs (4)

235ValueTask<Stream> task = CreateContentReadStreamAsyncCore(async: false, cancellationToken); 249private async ValueTask<Stream> CreateContentReadStreamAsyncCore(bool async, CancellationToken cancellationToken) 526public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default) => 535public async ValueTask<int> ReadAsyncPrivate(Memory<byte> buffer, CancellationToken cancellationToken)

System\Net\Http\SocketsHttpHandler\AuthenticationHelper.cs (5)

187private static async ValueTask<bool> TrySetDigestAuthToken(HttpRequestMessage request, NetworkCredential credential, DigestResponse digestResponse, bool isProxyAuth) 206private static ValueTask<HttpResponseMessage> InnerSendAsync(HttpRequestMessage request, bool async, bool isProxyAuth, bool doRequestAuth, HttpConnectionPool pool, CancellationToken cancellationToken) 213private static async ValueTask<HttpResponseMessage> SendWithAuthAsync(HttpRequestMessage request, Uri authUri, bool async, ICredentials credentials, bool preAuthenticate, bool isProxyAuth, bool doRequestAuth, HttpConnectionPool pool, CancellationToken cancellationToken) 360public static ValueTask<HttpResponseMessage> SendWithProxyAuthAsync(HttpRequestMessage request, Uri proxyUri, bool async, ICredentials proxyCredentials, bool doRequestAuth, HttpConnectionPool pool, CancellationToken cancellationToken) 365public static ValueTask<HttpResponseMessage> SendWithRequestAuthAsync(HttpRequestMessage request, bool async, ICredentials credentials, bool preAuthenticate, HttpConnectionPool pool, CancellationToken cancellationToken)

System\Net\Http\SocketsHttpHandler\ChunkedEncodingReadStream.cs (3)

119public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken) 162private async ValueTask<int> ReadAsyncCore(Memory<byte> buffer, CancellationToken cancellationToken) 468public override async ValueTask<bool> DrainAsync(int maxDrainBytes)

System\Net\Http\SocketsHttpHandler\ConnectHelper.cs (2)

58public static async ValueTask<SslStream> EstablishSslConnectionAsync(SslClientAuthenticationOptions sslOptions, HttpRequestMessage request, bool async, Stream stream, CancellationToken cancellationToken) 115public static async ValueTask<QuicConnection> ConnectQuicAsync(HttpRequestMessage request, DnsEndPoint endPoint, TimeSpan idleTimeout, SslClientAuthenticationOptions clientAuthenticationOptions, Action<QuicConnection, QuicStreamCapacityChangedArgs> streamCapacityCallback, CancellationToken cancellationToken)

System\Net\Http\SocketsHttpHandler\ConnectionCloseReadStream.cs (2)

38public override async ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken) 49ValueTask<int> readTask = connection.ReadAsync(buffer);

System\Net\Http\SocketsHttpHandler\ConnectionPool\HttpConnectionPool.cs (10)

System\Net\Http\SocketsHttpHandler\ConnectionPool\HttpConnectionPool.Http1.cs (2)

294internal async ValueTask<HttpConnection> CreateHttp11ConnectionAsync(HttpRequestMessage request, bool async, CancellationToken cancellationToken) 300private async ValueTask<HttpConnection> ConstructHttp11ConnectionAsync(bool async, Stream stream, TransportContext? transportContext, HttpRequestMessage request, Activity? activity, IPEndPoint? remoteEndPoint, CancellationToken cancellationToken)

System\Net\Http\SocketsHttpHandler\ConnectionPool\HttpConnectionPool.Http2.cs (1)

246private async ValueTask<Http2Connection> ConstructHttp2ConnectionAsync(Stream stream, HttpRequestMessage request, Activity? activity, IPEndPoint? remoteEndPoint, CancellationToken cancellationToken)

System\Net\Http\SocketsHttpHandler\ConnectionPool\HttpConnectionPool.Http3.cs (1)

68private async ValueTask<HttpResponseMessage?> TrySendUsingHttp3Async(HttpRequestMessage request, CancellationToken cancellationToken)

System\Net\Http\SocketsHttpHandler\ConnectionPool\HttpConnectionWaiter.cs (2)

20public ValueTask<T> WaitForConnectionAsync(HttpRequestMessage request, HttpConnectionPool pool, bool async, CancellationToken requestCancellationToken) 30private async ValueTask<T> WaitForConnectionWithTelemetryAsync(HttpRequestMessage request, HttpConnectionPool pool, bool async, CancellationToken requestCancellationToken)

System\Net\Http\SocketsHttpHandler\ContentLengthReadStream.cs (3)

57public override async ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken) 74ValueTask<int> readTask = _connection.ReadAsync(buffer); 195public override async ValueTask<bool> DrainAsync(int maxDrainBytes)

System\Net\Http\SocketsHttpHandler\CreditManager.cs (1)

48public ValueTask<int> RequestCreditAsync(int amount, CancellationToken cancellationToken)

System\Net\Http\SocketsHttpHandler\CreditWaiter.cs (2)

61/// <summary>Wraps the instance as a <see cref="ValueTask{TResult}"/> to make it awaitable.</summary> 62public ValueTask<int> AsValueTask() => new ValueTask<int>(this, _source.Version);

System\Net\Http\SocketsHttpHandler\DecompressionHandler.cs (7)

52internal override async ValueTask<HttpResponseMessage> SendAsync(HttpRequestMessage request, bool async, CancellationToken cancellationToken) 156ValueTask<Stream> task = CreateContentReadStreamAsyncCore(async: false, cancellationToken); 164private async ValueTask<Stream> CreateContentReadStreamAsyncCore(bool async, CancellationToken cancellationToken) 272public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken) 278static async ValueTask<int> CreateAndReadAsync(ZLibOrDeflateStream thisRef, Memory<byte> buffer, CancellationToken cancellationToken) 347public async ValueTask<int> PeekFirstByteAsync(CancellationToken cancellationToken) 383public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken)

System\Net\Http\SocketsHttpHandler\Http2Connection.cs (3)

403private async ValueTask<FrameHeader> ReadFrameAsync(bool initialFrame = false) 534ValueTask<int> zeroByteReadTask = _stream.ReadAsync(Memory<byte>.Empty); 1633private async ValueTask<Http2Stream> SendHeadersAsync(HttpRequestMessage request, CancellationToken cancellationToken, bool mustFlush)

System\Net\Http\SocketsHttpHandler\Http2Stream.cs (4)

333public async ValueTask<bool> WaitFor100ContinueAsync(CancellationToken cancellationToken) 1162public async ValueTask<int> ReadDataAsync(Memory<byte> buffer, HttpResponseMessage responseMessage, CancellationToken cancellationToken) 1525public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken) => ValueTask.FromException<int>(new NotSupportedException(SR.net_http_content_writeonly_stream)); 1605public override ValueTask<int> ReadAsync(Memory<byte> destination, CancellationToken cancellationToken)

System\Net\Http\SocketsHttpHandler\Http3Connection.cs (2)

539ValueTask<QuicStream> streamTask; 800async ValueTask<(Http3FrameType? frameType, long payloadLength)> ReadFrameEnvelopeAsync()

System\Net\Http\SocketsHttpHandler\Http3RequestStream.cs (5)

848private async ValueTask<(Http3FrameType? frameType, long payloadLength)> ReadFrameEnvelopeAsync(CancellationToken cancellationToken) 1218private async ValueTask<int> ReadResponseContentAsync(HttpResponseMessage response, Memory<byte> buffer, CancellationToken cancellationToken) 1338private async ValueTask<bool> ReadNextDataFrameAsync(HttpResponseMessage response, CancellationToken cancellationToken) 1473public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken) 1519public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken)

System\Net\Http\SocketsHttpHandler\HttpAuthenticatedConnectionHandler.cs (1)

18internal override ValueTask<HttpResponseMessage> SendAsync(HttpRequestMessage request, bool async, CancellationToken cancellationToken)

System\Net\Http\SocketsHttpHandler\HttpConnection.cs (7)

61private ValueTask<int> _readAheadTask; 244async ValueTask<int> ReadAheadWithZeroByteReadAsync() 618ValueTask<int> vt = _readAheadTask; 1773private ValueTask<int> ReadAsync(Memory<byte> destination) 1791async ValueTask<int> ReadAndLogBytesReadAsync(Memory<byte> destination) 1824private ValueTask<int> ReadBufferedAsync(Memory<byte> destination) 1837private async ValueTask<int> ReadBufferedAsyncCore(Memory<byte> destination)

System\Net\Http\SocketsHttpHandler\HttpConnectionHandler.cs (1)

18internal override ValueTask<HttpResponseMessage> SendAsync(HttpRequestMessage request, bool async, CancellationToken cancellationToken)

System\Net\Http\SocketsHttpHandler\HttpConnectionPoolManager.cs (4)

330public ValueTask<HttpResponseMessage> SendAsyncCore(HttpRequestMessage request, Uri? proxyUri, bool async, bool doRequestAuth, bool isProxyConnect, CancellationToken cancellationToken) 369public ValueTask<HttpResponseMessage> SendProxyConnectAsync(HttpRequestMessage request, Uri proxyUri, bool async, CancellationToken cancellationToken) 374public ValueTask<HttpResponseMessage> SendAsync(HttpRequestMessage request, bool async, bool doRequestAuth, CancellationToken cancellationToken) 427private async ValueTask<HttpResponseMessage> SendAsyncMultiProxy(HttpRequestMessage request, bool async, bool doRequestAuth, MultiProxy multiProxy, Uri? firstProxy, CancellationToken cancellationToken)

System\Net\Http\SocketsHttpHandler\HttpConnectionSettings.cs (2)

66internal Func<SocketsHttpConnectionContext, CancellationToken, ValueTask<Stream>>? _connectCallback; 67internal Func<SocketsHttpPlaintextStreamFilterContext, CancellationToken, ValueTask<Stream>>? _plaintextStreamFilter;

System\Net\Http\SocketsHttpHandler\HttpContentReadStream.cs (1)

42public virtual ValueTask<bool> DrainAsync(int maxDrainBytes)

System\Net\Http\SocketsHttpHandler\HttpContentWriteStream.cs (1)

36public sealed override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken) => throw new NotSupportedException();

System\Net\Http\SocketsHttpHandler\HttpMessageHandlerStage.cs (2)

14ValueTask<HttpResponseMessage> sendTask = SendAsync(request, async: false, cancellationToken); 23internal abstract ValueTask<HttpResponseMessage> SendAsync(HttpRequestMessage request, bool async, CancellationToken cancellationToken);

System\Net\Http\SocketsHttpHandler\RawConnectionStream.cs (2)

45public override async ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken) 56ValueTask<int> readTask = connection.ReadBufferedAsync(buffer);

System\Net\Http\SocketsHttpHandler\RedirectHandler.cs (1)

28internal override async ValueTask<HttpResponseMessage> SendAsync(HttpRequestMessage request, bool async, CancellationToken cancellationToken)

System\Net\Http\SocketsHttpHandler\SocketsHttpHandler.cs (2)

401public Func<SocketsHttpConnectionContext, CancellationToken, ValueTask<Stream>>? ConnectCallback 414public Func<SocketsHttpPlaintextStreamFilterContext, CancellationToken, ValueTask<Stream>>? PlaintextStreamFilter

System\Net\Http\Json\HttpClientJsonExtensions.cs (6)

37Func<Stream, TJsonOptions, CancellationToken, ValueTask<TValue?>> deserializeMethod, 75Func<Stream, TJsonOptions, CancellationToken, ValueTask<TValue?>> deserializeMethod, 112private static ValueTask<Stream> GetHttpResponseStreamAsync( 126ValueTask<Stream> task = HttpContentJsonExtensions.GetContentStreamAsync(response.Content, cancellationToken); 133private static async ValueTask<Stream> GetLengthLimitReadStreamAsync(HttpClient client, ValueTask<Stream> task)

System\Net\Http\Json\HttpContentJsonExtensions.cs (2)

132internal static ValueTask<Stream> GetContentStreamAsync(HttpContent content, CancellationToken cancellationToken) 141private static async ValueTask<Stream> GetTranscodingStreamAsync(Task<Stream> task, Encoding sourceEncoding)

System\Net\Http\Json\LengthLimitReadStream.cs (4)

44public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default) 46ValueTask<int> readTask = _innerStream.ReadAsync(buffer, cancellationToken); 62async ValueTask<int> Core(ValueTask<int> readTask)

System\Net\Base64Stream.cs (1)

197protected override async ValueTask<int> ReadAsyncInternal(Memory<byte> buffer, CancellationToken cancellationToken = default)

System\Net\BufferedReadStream.cs (2)

51protected override ValueTask<int> ReadAsyncInternal(Memory<byte> buffer, CancellationToken cancellationToken = default) 70private async ValueTask<int> ReadMoreAsync(int bytesAlreadyRead, Memory<byte> buffer, CancellationToken cancellationToken)

System\Net\CloseableStream.cs (1)

47protected override ValueTask<int> ReadAsyncInternal(Memory<byte> buffer, CancellationToken cancellationToken = default)

System\Net\DelegatedStream.cs (2)

106protected abstract ValueTask<int> ReadAsyncInternal(Memory<byte> buffer, CancellationToken cancellationToken); 121public sealed override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

System\Net\Mime\EightBitStream.cs (1)

57protected override ValueTask<int> ReadAsyncInternal(Memory<byte> buffer, CancellationToken cancellationToken = default)

System\Net\Mime\QEncodedStream.cs (1)

224protected override ValueTask<int> ReadAsyncInternal(Memory<byte> buffer, CancellationToken cancellationToken = default)

System\Net\Mime\QuotedPrintableStream.cs (1)

338protected override ValueTask<int> ReadAsyncInternal(Memory<byte> buffer, CancellationToken cancellationToken = default)

System\Net\NetworkInformation\Ping.cs (1)

706Func<TArg, CancellationToken, ValueTask<IPAddress>> getAddress,

src\libraries\Common\src\System\Net\StreamBuffer.cs (1)

238public async ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

System\Net\Quic\QuicConnection.cs (4)

61public static ValueTask<QuicConnection> ConnectAsync(QuicClientConnectionOptions options, CancellationToken cancellationToken = default) 72static async ValueTask<QuicConnection> StartConnectAsync(QuicClientConnectionOptions options, CancellationToken cancellationToken) 523public async ValueTask<QuicStream> OpenOutboundStreamAsync(QuicStreamType type, CancellationToken cancellationToken = default) 565public async ValueTask<QuicStream> AcceptInboundStreamAsync(CancellationToken cancellationToken = default)

System\Net\Quic\QuicListener.cs (3)

51public static ValueTask<QuicListener> ListenAsync(QuicListenerOptions options, CancellationToken cancellationToken = default) 94private readonly Func<QuicConnection, SslClientHelloInfo, CancellationToken, ValueTask<QuicServerConnectionOptions>> _connectionOptionsCallback; 176public async ValueTask<QuicConnection> AcceptConnectionAsync(CancellationToken cancellationToken = default)

System\Net\Quic\QuicListenerOptions.cs (1)

37public Func<QuicConnection, SslClientHelloInfo, CancellationToken, ValueTask<QuicServerConnectionOptions>> ConnectionOptionsCallback { get; set; } = null!;

System\Net\Quic\QuicStream.cs (1)

273public override async ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

System\Net\HttpWebResponse.cs (1)

413public override async ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

System\Net\NetworkStreamWrapper.cs (1)

193public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

System\Net\Security\NegotiateStream.cs (4)

309ValueTask<int> vt = ReadAsync<SyncReadWriteAdapter>(new Memory<byte>(buffer, offset, count), default(CancellationToken)); 327public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default) 338private async ValueTask<int> ReadAsync<TIOAdapter>(Memory<byte> buffer, CancellationToken cancellationToken) 447static async ValueTask<int> ReadAllAsync(Stream stream, Memory<byte> buffer, bool allowZeroRead, CancellationToken cancellationToken)

System\Net\Security\ReadWriteAdapter.cs (6)

12static abstract ValueTask<int> ReadAsync(Stream stream, Memory<byte> buffer, CancellationToken cancellationToken); 13static abstract ValueTask<int> ReadAtLeastAsync(Stream stream, Memory<byte> buffer, int minimumBytes, bool throwOnEndOfStream, CancellationToken cancellationToken); 21public static ValueTask<int> ReadAsync(Stream stream, Memory<byte> buffer, CancellationToken cancellationToken) => 24public static ValueTask<int> ReadAtLeastAsync(Stream stream, Memory<byte> buffer, int minimumBytes, bool throwOnEndOfStream, CancellationToken cancellationToken) => 37public static ValueTask<int> ReadAsync(Stream stream, Memory<byte> buffer, CancellationToken cancellationToken) => 40public static ValueTask<int> ReadAtLeastAsync(Stream stream, Memory<byte> buffer, int minimumBytes, bool throwOnEndOfStream, CancellationToken cancellationToken) =>

System\Net\Security\SslStream.cs (4)

40public delegate ValueTask<SslServerAuthenticationOptions> ServerOptionsSelectionCallback(SslStream stream, SslClientHelloInfo clientHelloInfo, object? state, CancellationToken cancellationToken); 789ValueTask<int> vt = ReadAsyncInternal<SyncReadWriteAdapter>(memoryManager.Memory, default(CancellationToken)); 804ValueTask<int> vt = ReadAsyncInternal<SyncReadWriteAdapter>(new Memory<byte>(buffer, offset, count), default(CancellationToken)); 888public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

System\Net\Security\SslStream.IO.cs (3)

409private async ValueTask<int> ReceiveHandshakeFrameAsync<TIOAdapter>(CancellationToken cancellationToken) 732private async ValueTask<int> EnsureFullTlsFrameAsync<TIOAdapter>(CancellationToken cancellationToken, int estimatedSize) 820private async ValueTask<int> ReadAsyncInternal<TIOAdapter>(Memory<byte> buffer, CancellationToken cancellationToken)

System\Net\Security\SslStreamCertificateContext.Linux.cs (4)

141ValueTask<byte[]?> task = GetOcspResponseAsync(); 163internal ValueTask<byte[]?> GetOcspResponseAsync() 200internal ValueTask<byte[]?> WaitForPendingOcspFetchAsync() 211private ValueTask<byte[]?> DownloadOcspAsync()

System\Net\StreamFramer.cs (1)

24public async ValueTask<byte[]?> ReadMessageAsync<TAdapter>(Stream stream, CancellationToken cancellationToken)

System\Net\ServerSentEvents\SseParser_1.cs (1)

498private async ValueTask<int> FillLineBufferAsync(CancellationToken cancellationToken)

System\Net\Sockets\NetworkStream.cs (1)

586public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

System\Net\Sockets\Socket.Tasks.cs (24)

System\Net\Sockets\SocketTaskExtensions.cs (2)

50public static ValueTask<int> ReceiveAsync(this Socket socket, Memory<byte> buffer, SocketFlags socketFlags, CancellationToken cancellationToken = default) => 66public static ValueTask<int> SendAsync(this Socket socket, ReadOnlyMemory<byte> buffer, SocketFlags socketFlags, CancellationToken cancellationToken = default) =>

System\Net\Sockets\TCPListener.cs (4)

226public ValueTask<Socket> AcceptSocketAsync(CancellationToken cancellationToken) 238public ValueTask<TcpClient> AcceptTcpClientAsync(CancellationToken cancellationToken) 242static async ValueTask<TcpClient> WaitAndWrap(ValueTask<Socket> task) =>

System\Net\Sockets\UDPClient.cs (10)

536/// <returns>A <see cref="ValueTask{T}"/> that represents the asynchronous send operation. The value of its Result property contains the number of bytes sent.</returns> 539public ValueTask<int> SendAsync(ReadOnlyMemory<byte> datagram, CancellationToken cancellationToken = default) => 560/// <returns>A <see cref="ValueTask{T}"/> that represents the asynchronous send operation. The value of its Result property contains the number of bytes sent.</returns> 564public ValueTask<int> SendAsync(ReadOnlyMemory<byte> datagram, string? hostname, int port, CancellationToken cancellationToken = default) => 594/// <returns>A <see cref="ValueTask{T}"/> that represents the asynchronous send operation. The value of its Result property contains the number of bytes sent.</returns> 598public ValueTask<int> SendAsync(ReadOnlyMemory<byte> datagram, IPEndPoint? endPoint, CancellationToken cancellationToken = default) 638/// <returns>A <see cref="ValueTask{TResult}"/> representing the asynchronous operation.</returns> 641public ValueTask<UdpReceiveResult> ReceiveAsync(CancellationToken cancellationToken) 650async ValueTask<UdpReceiveResult> WaitAndWrap(ValueTask<SocketReceiveFromResult> task)

src\libraries\Common\src\System\IO\DelegatingStream.cs (1)

110public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

System\Net\WebSockets\ManagedWebSocket.cs (4)

382public override ValueTask<ValueWebSocketReceiveResult> ReceiveAsync(Memory<byte> buffer, CancellationToken cancellationToken) 779private async ValueTask<TResult> ReceiveAsyncPrivate<TResult>(Memory<byte> payloadBuffer, CancellationToken cancellationToken) 1146ValueTask<int> finalReadTask = _stream.ReadAsync(_receiveBuffer, cancellationToken); 1463ValueTask<ValueWebSocketReceiveResult> receiveTask = default;

System\Net\WebSockets\WebSocket.cs (1)

35public virtual async ValueTask<ValueWebSocketReceiveResult> ReceiveAsync(Memory<byte> buffer, CancellationToken cancellationToken)

System\Net\WebSockets\ClientWebSocket.cs (1)

157public override ValueTask<ValueWebSocketReceiveResult> ReceiveAsync(Memory<byte> buffer, CancellationToken cancellationToken) =>

src\libraries\System.Private.CoreLib\src\Microsoft\Win32\SafeHandles\SafeFileHandle.ThreadPoolValueTaskSource.cs (2)

171public ValueTask<int> QueueRead(Memory<byte> buffer, long fileOffset, CancellationToken cancellationToken, OSFileStreamStrategy? strategy) 199public ValueTask<long> QueueReadScatter(IReadOnlyList<Memory<byte>> buffers, long fileOffset, CancellationToken cancellationToken)

src\libraries\System.Private.CoreLib\src\System\Collections\Generic\IAsyncEnumerator.cs (2)

17/// A <see cref="ValueTask{Boolean}"/> that will complete with a result of <c>true</c> if the enumerator 21ValueTask<bool> MoveNextAsync();

src\libraries\System.Private.CoreLib\src\System\IO\BufferedStream.cs (2)

628public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default) 671private async ValueTask<int> ReadFromUnderlyingStreamAsync(

src\libraries\System.Private.CoreLib\src\System\IO\FileStream.cs (2)

308public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default) 621internal ValueTask<int> BaseReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

src\libraries\System.Private.CoreLib\src\System\IO\MemoryStream.cs (1)

390public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

src\libraries\System.Private.CoreLib\src\System\IO\RandomAccess.cs (2)

113public static ValueTask<int> ReadAsync(SafeFileHandle handle, Memory<byte> buffer, long fileOffset, CancellationToken cancellationToken = default) 141public static ValueTask<long> ReadAsync(SafeFileHandle handle, IReadOnlyList<Memory<byte>> buffers, long fileOffset, CancellationToken cancellationToken = default)

src\libraries\System.Private.CoreLib\src\System\IO\RandomAccess.Unix.cs (2)

94internal static ValueTask<int> ReadAtOffsetAsync(SafeFileHandle handle, Memory<byte> buffer, long fileOffset, CancellationToken cancellationToken, OSFileStreamStrategy? strategy = null) 97private static ValueTask<long> ReadScatterAtOffsetAsync(SafeFileHandle handle, IReadOnlyList<Memory<byte>> buffers, long fileOffset, CancellationToken cancellationToken)

src\libraries\System.Private.CoreLib\src\System\IO\Strategies\BufferedFileStreamStrategy.cs (4)

285ValueTask<int> readResult = ReadAsync(new Memory<byte>(buffer, offset, count), cancellationToken); 292public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default) 350private async ValueTask<int> ReadFromNonSeekableAsync(Memory<byte> destination, CancellationToken cancellationToken) 391private async ValueTask<int> ReadAsyncSlowPath(Task semaphoreLockTask, Memory<byte> buffer, CancellationToken cancellationToken)

src\libraries\System.Private.CoreLib\src\System\IO\Strategies\DerivedFileStreamStrategy.cs (1)

91public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

src\libraries\System.Private.CoreLib\src\System\IO\Strategies\OSFileStreamStrategy.cs (1)

272public sealed override ValueTask<int> ReadAsync(Memory<byte> destination, CancellationToken cancellationToken)

src\libraries\System.Private.CoreLib\src\System\IO\Stream.cs (8)

308public virtual ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default) 318static async ValueTask<int> FinishReadAsync(Task<int> readTask, byte[] localBuffer, Memory<byte> localDestination) 348ValueTask<int> vt = ReadAtLeastAsyncCore(buffer, buffer.Length, throwOnEndOfStream: true, cancellationToken); 382ValueTask<int> vt = ReadAtLeastAsyncCore(buffer.AsMemory(offset, count), count, throwOnEndOfStream: true, cancellationToken); 401/// A task that represents the asynchronous read operation. The value of its <see cref="ValueTask{TResult}.Result"/> property contains the 417public ValueTask<int> ReadAtLeastAsync(Memory<byte> buffer, int minimumBytes, bool throwOnEndOfStream = true, CancellationToken cancellationToken = default) 426private async ValueTask<int> ReadAtLeastAsyncCore(Memory<byte> buffer, int minimumBytes, bool throwOnEndOfStream, CancellationToken cancellationToken) 1054public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken) =>

src\libraries\System.Private.CoreLib\src\System\IO\StreamReader.cs (10)

884public override ValueTask<string?> ReadLineAsync(CancellationToken cancellationToken) 1076public override ValueTask<int> ReadAsync(Memory<char> buffer, CancellationToken cancellationToken = default) 1095internal override async ValueTask<int> ReadAsyncInternal(Memory<char> buffer, CancellationToken cancellationToken) 1287public override ValueTask<int> ReadBlockAsync(Memory<char> buffer, CancellationToken cancellationToken = default) 1304ValueTask<int> vt = ReadBlockAsyncInternal(buffer, cancellationToken); 1315private async ValueTask<int> ReadBufferAsync(CancellationToken cancellationToken) 1429public override ValueTask<int> ReadAsync(Memory<char> buffer, CancellationToken cancellationToken) => 1438public override ValueTask<int> ReadBlockAsync(Memory<char> buffer, CancellationToken cancellationToken) => 1445public override ValueTask<string?> ReadLineAsync(CancellationToken cancellationToken) => 1455internal override ValueTask<int> ReadAsyncInternal(Memory<char> buffer, CancellationToken cancellationToken) =>

src\libraries\System.Private.CoreLib\src\System\IO\StringReader.cs (3)

247public override ValueTask<string?> ReadLineAsync(CancellationToken cancellationToken) => 301public override ValueTask<int> ReadBlockAsync(Memory<char> buffer, CancellationToken cancellationToken = default) => 319public override ValueTask<int> ReadAsync(Memory<char> buffer, CancellationToken cancellationToken = default) =>

src\libraries\System.Private.CoreLib\src\System\IO\TextReader.cs (6)

218public virtual ValueTask<string?> ReadLineAsync(CancellationToken cancellationToken) => 274public virtual ValueTask<int> ReadAsync(Memory<char> buffer, CancellationToken cancellationToken = default) => 283internal virtual ValueTask<int> ReadAsyncInternal(Memory<char> buffer, CancellationToken cancellationToken) => 304public virtual ValueTask<int> ReadBlockAsync(Memory<char> buffer, CancellationToken cancellationToken = default) => 313internal async ValueTask<int> ReadBlockAsyncInternal(Memory<char> buffer, CancellationToken cancellationToken) 379public override ValueTask<string?> ReadLineAsync(CancellationToken cancellationToken)

src\libraries\System.Private.CoreLib\src\System\IO\UnmanagedMemoryStream.cs (1)

445public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

src\libraries\System.Private.CoreLib\src\System\IO\UnmanagedMemoryStreamWrapper.cs (1)

164public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)

src\libraries\System.Private.CoreLib\src\System\Runtime\CompilerServices\AsyncHelpers.cs (1)

79public static T Await<T>(ValueTask<T> task)

src\libraries\System.Private.CoreLib\src\System\Runtime\CompilerServices\AsyncValueTaskMethodBuilderT.cs (2)

9/// <summary>Represents a builder for asynchronous methods that returns a <see cref="ValueTask{TResult}"/>.</summary> 64public ValueTask<TResult> Task

src\libraries\System.Private.CoreLib\src\System\Runtime\CompilerServices\ConfiguredValueTaskAwaitable.cs (7)

116/// <summary>Provides an awaitable type that enables configured awaits on a <see cref="ValueTask{TResult}"/>.</summary> 121/// <summary>The wrapped <see cref="ValueTask{TResult}"/>.</summary> 122private readonly ValueTask<TResult> _value; 125/// <param name="value">The wrapped <see cref="ValueTask{TResult}"/>.</param> 127internal ConfiguredValueTaskAwaitable(in ValueTask<TResult> value) => _value = value; 138private readonly ValueTask<TResult> _value; 143internal ConfiguredValueTaskAwaiter(in ValueTask<TResult> value) => _value = value;

src\libraries\System.Private.CoreLib\src\System\Runtime\CompilerServices\PoolingAsyncValueTaskMethodBuilderT.cs (2)

14/// <summary>Represents a builder for asynchronous methods that returns a <see cref="ValueTask{TResult}"/>.</summary> 79public ValueTask<TResult> Task

src\libraries\System.Private.CoreLib\src\System\Runtime\CompilerServices\ValueTaskAwaiter.cs (4)

106/// <summary>Provides an awaiter for a <see cref="ValueTask{TResult}"/>.</summary> 110private readonly ValueTask<TResult> _value; 115internal ValueTaskAwaiter(in ValueTask<TResult> value) => _value = value; 117/// <summary>Gets whether the <see cref="ValueTask{TResult}"/> has completed.</summary>

src\libraries\System.Private.CoreLib\src\System\Text\TranscodingStream.cs (2)

367public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken) 377async ValueTask<int> ReadAsyncCore(Memory<byte> buffer, CancellationToken cancellationToken)

src\libraries\System.Private.CoreLib\src\System\Threading\PeriodicTimer.cs (2)

134public ValueTask<bool> WaitForNextTickAsync(CancellationToken cancellationToken = default) => 188public ValueTask<bool> WaitForNextTickAsync(PeriodicTimer owner, CancellationToken cancellationToken)

src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\Sources\IValueTaskSource.cs (2)

7/// Flags passed from <see cref="ValueTask"/> and <see cref="ValueTask{TResult}"/> to 62/// <summary>Represents an object that can be wrapped by a <see cref="ValueTask{TResult}"/>.</summary>

src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\TaskAsyncEnumerableExtensions.ToBlockingEnumerable.cs (1)

42ValueTask<bool> moveNextTask = enumerator.MoveNextAsync();

src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\ValueTask.cs (42)

src\System\Runtime\CompilerServices\AsyncHelpers.CoreCLR.cs (1)

289private static async ValueTask<T?> FinalizeValueTaskReturningThunk<T>(Continuation continuation)

System\Xml\Core\XmlTextReaderImplAsync.cs (2)

2903ValueTask<(int, int, int, bool)> parseTextTask = ParseTextAsync(orChars).Preserve(); 3167private ValueTask<(int, int, int, bool)> ParseTextAsync(int outOrChars)

System\Xml\Linq\XContainer.cs (2)

955public async ValueTask<bool> ReadContentFromAsync(XContainer rootContainer, XmlReader r) 1125public async ValueTask<bool> ReadContentFromContainerAsync(XContainer rootContainer, XmlReader r)

artifacts\obj\System.Runtime\Debug\net10.0\System.Runtime.Forwards.cs (1)

834[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.Tasks.ValueTask<>))]

System\Security\Cryptography\CryptographicOperations.cs (5)

308public static ValueTask<int> HashDataAsync( 357public static ValueTask<byte[]> HashDataAsync( 654public static ValueTask<byte[]> HmacDataAsync( 699public static ValueTask<int> HmacDataAsync( 746public static ValueTask<byte[]> HmacDataAsync(

System\Security\Cryptography\CryptoStream.cs (4)

224public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default) 232private async ValueTask<int> ReadAsyncInternal(Memory<byte> buffer, CancellationToken cancellationToken = default) 295ValueTask<int> completedValueTask = ReadAsyncCore(buffer.AsMemory(offset, count), default(CancellationToken), useAsync: false); 308private async ValueTask<int> ReadAsyncCore(Memory<byte> buffer, CancellationToken cancellationToken, bool useAsync)

System\Security\Cryptography\HMACMD5.cs (3)

258public static ValueTask<byte[]> HashDataAsync(ReadOnlyMemory<byte> key, Stream source, CancellationToken cancellationToken = default) 285public static ValueTask<byte[]> HashDataAsync(byte[] key, Stream source, CancellationToken cancellationToken = default) 317public static ValueTask<int> HashDataAsync(

System\Security\Cryptography\HMACSHA1.cs (3)

256public static ValueTask<byte[]> HashDataAsync(ReadOnlyMemory<byte> key, Stream source, CancellationToken cancellationToken = default) 282public static ValueTask<byte[]> HashDataAsync(byte[] key, Stream source, CancellationToken cancellationToken = default) 313public static ValueTask<int> HashDataAsync(

System\Security\Cryptography\HMACSHA256.cs (3)

248public static ValueTask<byte[]> HashDataAsync(ReadOnlyMemory<byte> key, Stream source, CancellationToken cancellationToken = default) 274public static ValueTask<byte[]> HashDataAsync(byte[] key, Stream source, CancellationToken cancellationToken = default) 305public static ValueTask<int> HashDataAsync(

System\Security\Cryptography\HMACSHA3_256.cs (3)

288public static ValueTask<byte[]> HashDataAsync(ReadOnlyMemory<byte> key, Stream source, CancellationToken cancellationToken = default) 315public static ValueTask<byte[]> HashDataAsync(byte[] key, Stream source, CancellationToken cancellationToken = default) 346public static ValueTask<int> HashDataAsync(

System\Security\Cryptography\HMACSHA3_384.cs (3)

288public static ValueTask<byte[]> HashDataAsync(ReadOnlyMemory<byte> key, Stream source, CancellationToken cancellationToken = default) 315public static ValueTask<byte[]> HashDataAsync(byte[] key, Stream source, CancellationToken cancellationToken = default) 346public static ValueTask<int> HashDataAsync(

System\Security\Cryptography\HMACSHA3_512.cs (3)

288public static ValueTask<byte[]> HashDataAsync(ReadOnlyMemory<byte> key, Stream source, CancellationToken cancellationToken = default) 315public static ValueTask<byte[]> HashDataAsync(byte[] key, Stream source, CancellationToken cancellationToken = default) 346public static ValueTask<int> HashDataAsync(

System\Security\Cryptography\HMACSHA384.cs (3)

265public static ValueTask<byte[]> HashDataAsync(ReadOnlyMemory<byte> key, Stream source, CancellationToken cancellationToken = default) 291public static ValueTask<byte[]> HashDataAsync(byte[] key, Stream source, CancellationToken cancellationToken = default) 322public static ValueTask<int> HashDataAsync(

System\Security\Cryptography\HMACSHA512.cs (3)

262public static ValueTask<byte[]> HashDataAsync(ReadOnlyMemory<byte> key, Stream source, CancellationToken cancellationToken = default) 288public static ValueTask<byte[]> HashDataAsync(byte[] key, Stream source, CancellationToken cancellationToken = default) 319public static ValueTask<int> HashDataAsync(

System\Security\Cryptography\Kmac128.cs (4)

398/// A <see cref="ValueTask{TResult}" /> that completes with the computed hash. 417public static ValueTask<byte[]> HashDataAsync( 445/// A <see cref="ValueTask{TResult}" /> that completes with the computed hash. 464public static ValueTask<byte[]> HashDataAsync(

System\Security\Cryptography\Kmac256.cs (4)

398/// A <see cref="ValueTask{TResult}" /> that completes with the computed hash. 417public static ValueTask<byte[]> HashDataAsync( 445/// A <see cref="ValueTask{TResult}" /> that completes with the computed hash. 464public static ValueTask<byte[]> HashDataAsync(

System\Security\Cryptography\KmacXof128.cs (4)

398/// A <see cref="ValueTask{TResult}" /> that completes with the computed hash. 417public static ValueTask<byte[]> HashDataAsync( 445/// A <see cref="ValueTask{TResult}" /> that completes with the computed hash. 464public static ValueTask<byte[]> HashDataAsync(

System\Security\Cryptography\KmacXof256.cs (4)

398/// A <see cref="ValueTask{TResult}" /> that completes with the computed hash. 417public static ValueTask<byte[]> HashDataAsync( 445/// A <see cref="ValueTask{TResult}" /> that completes with the computed hash. 464public static ValueTask<byte[]> HashDataAsync(

System\Security\Cryptography\LiteHashProvider.cs (6)

28internal static ValueTask<int> HashStreamAsync( 43internal static ValueTask<byte[]> HashStreamAsync( 80internal static ValueTask<int> HmacStreamAsync( 96internal static ValueTask<byte[]> HmacStreamAsync( 139private static async ValueTask<int> ProcessStreamAsync<T>( 170private static async ValueTask<byte[]> ProcessStreamAsync<T>(

System\Security\Cryptography\LiteHashProvider.Xof.cs (2)

72internal static ValueTask<byte[]> XofStreamAsync( 105internal static ValueTask<byte[]> KmacStreamAsync(

System\Security\Cryptography\MD5.cs (2)

193public static ValueTask<byte[]> HashDataAsync(Stream source, CancellationToken cancellationToken = default) 227public static ValueTask<int> HashDataAsync(

System\Security\Cryptography\SHA1.cs (2)

185public static ValueTask<byte[]> HashDataAsync(Stream source, CancellationToken cancellationToken = default) 218public static ValueTask<int> HashDataAsync(

System\Security\Cryptography\SHA256.cs (2)

185public static ValueTask<byte[]> HashDataAsync(Stream source, CancellationToken cancellationToken = default) 218public static ValueTask<int> HashDataAsync(

System\Security\Cryptography\SHA3_256.cs (2)

229public static ValueTask<byte[]> HashDataAsync(Stream source, CancellationToken cancellationToken = default) 266public static ValueTask<int> HashDataAsync(

System\Security\Cryptography\SHA3_384.cs (2)

230public static ValueTask<byte[]> HashDataAsync(Stream source, CancellationToken cancellationToken = default) 267public static ValueTask<int> HashDataAsync(

System\Security\Cryptography\SHA3_512.cs (2)

229public static ValueTask<byte[]> HashDataAsync(Stream source, CancellationToken cancellationToken = default) 266public static ValueTask<int> HashDataAsync(

System\Security\Cryptography\SHA384.cs (2)

184public static ValueTask<byte[]> HashDataAsync(Stream source, CancellationToken cancellationToken = default) 217public static ValueTask<int> HashDataAsync(

System\Security\Cryptography\SHA512.cs (2)

184public static ValueTask<byte[]> HashDataAsync(Stream source, CancellationToken cancellationToken = default) 217public static ValueTask<int> HashDataAsync(

System\Security\Cryptography\Shake128.cs (2)

438/// A <see cref="ValueTask{TResult}" /> that completes with the computed hash. 456public static ValueTask<byte[]> HashDataAsync(Stream source, int outputLength, CancellationToken cancellationToken = default)

System\Security\Cryptography\Shake256.cs (2)

438/// A <see cref="ValueTask{TResult}" /> that completes with the computed hash. 456public static ValueTask<byte[]> HashDataAsync(Stream source, int outputLength, CancellationToken cancellationToken = default)

System\ServiceModel\Channels\BufferedConnection.cs (1)

253public async ValueTask<IConnection> ConnectAsync(Uri uri, TimeSpan timeout)

System\ServiceModel\Channels\Connection.cs (6)

17ValueTask<int> ReadAsync(Memory<byte> buffer, TimeSpan timeout); 25ValueTask<IConnection> ConnectAsync(Uri uri, TimeSpan timeout); 38public virtual ValueTask<int> ReadAsync(Memory<byte> buffer, TimeSpan timeout) => Connection.ReadAsync(buffer, timeout); 68public override ValueTask<int> ReadAsync(Memory<byte> buffer, TimeSpan timeout) 235public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default) 292public async ValueTask<int> ReadAsync(Memory<byte> buffer, TimeSpan timeout)

System\ServiceModel\Channels\ConnectionPool.cs (1)

52public async ValueTask<bool> CloseAsync(TimeSpan timeout)

System\ServiceModel\Channels\SingletonConnectionReader.cs (3)

311private async ValueTask<int> ReadCoreAsync(Memory<byte> buffer) 526public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default) 541static async ValueTask<int> FinishReadAsync(Task<int> readTask, byte[] localBuffer, Memory<byte> localDestination)

System\ServiceModel\Channels\TransportSecurityHelpers.cs (2)

26public static async ValueTask<(NetworkCredential credential, TokenImpersonationLevel impersonationLevel, bool allowNtlm)> GetSspiCredentialAsync(SecurityTokenProvider tokenProvider, TimeSpan timeout) 33public static async ValueTask<(NetworkCredential credential, bool extractGroupsForWindowsAccounts, TokenImpersonationLevel impersonationLevel, bool allowNtlm)> GetSspiCredentialCoreAsync(

System\ServiceModel\Channels\PipeConnection.cs (4)

114public async ValueTask<int> ReadAsync(Memory<byte> buffer, TimeSpan timeout) 248ValueTask<int> readValueTask = default; 420private ValueTask<int> StartReadZeroAsync(CancellationToken token) 440private async ValueTask WaitForReadZero(ValueTask<int> readTask, TimeSpan timeout, bool traceExceptionsAsErrors)

System\ServiceModel\Channels\PipeConnectionInitiator.cs (1)

37public async ValueTask<IConnection> ConnectAsync(Uri remoteUri, TimeSpan timeout)

System\ServiceModel\Channels\SocketAwaitableEventArgs.cs (1)

31public ValueTask<int> ReceiveAsync(Socket socket, Memory<byte> buffer)

System\ServiceModel\Channels\SocketConnection.cs (4)

156public ValueTask<int> ReadAsync(Memory<byte> buffer, TimeSpan timeout) 167private async ValueTask<int> ReadCoreAsync(Memory<byte> buffer, TimeSpan timeout, bool closing) 188var resultTask = _asyncReadEventArgs.ReceiveAsync(_socket, buffer); 842public async ValueTask<IConnection> ConnectAsync(Uri uri, TimeSpan timeout)

src\libraries\Common\src\System\Text\Json\PooledByteBufferWriter.cs (1)

76public override async ValueTask<FlushResult> FlushAsync(CancellationToken cancellationToken = default)

System\Text\Json\Document\JsonDocument.Parse.cs (1)

828ValueTask<ArraySegment<byte>>

System\Text\Json\Serialization\Converters\Collection\IAsyncEnumerableOfTConverter.cs (1)

50ValueTask<bool> moveNextTask;

System\Text\Json\Serialization\JsonSerializer.Read.Stream.cs (5)

44public static ValueTask<TValue?> DeserializeAsync<TValue>( 112public static ValueTask<object?> DeserializeAsync( 178public static ValueTask<TValue?> DeserializeAsync<TValue>( 207public static ValueTask<object?> DeserializeAsync( 298public static ValueTask<object?> DeserializeAsync(

System\Text\Json\Serialization\Metadata\JsonTypeInfo.cs (1)

1044internal abstract ValueTask<object?> DeserializeAsObjectAsync(Stream utf8Json, CancellationToken cancellationToken);

System\Text\Json\Serialization\Metadata\JsonTypeInfoOfT.ReadHelper.cs (2)

25internal async ValueTask<T?> DeserializeAsync(Stream utf8Json, CancellationToken cancellationToken) 102internal sealed override async ValueTask<object?> DeserializeAsObjectAsync(Stream utf8Json, CancellationToken cancellationToken)

System\Text\Json\Serialization\ReadBufferState.cs (1)

61public readonly async ValueTask<ReadBufferState> ReadFromStreamAsync(

System\Text\Json\Serialization\WriteStack.cs (1)

366static async ValueTask<Exception?> DisposeFrame(IEnumerator? collectionEnumerator, IAsyncDisposable? asyncDisposable, Exception? exception)

System\Threading\Channels\AsyncOperation.cs (2)

106/// <summary>Gets a <see cref="ValueTask{TResult}"/> backed by this instance and its current token.</summary> 107public ValueTask<TResult> ValueTaskOfT => new ValueTask<TResult>(this, _currentId);

System\Threading\Channels\BoundedChannel.cs (3)

137public override ValueTask<T> ReadAsync(CancellationToken cancellationToken) 187public override ValueTask<bool> WaitToReadAsync(CancellationToken cancellationToken) 476public override ValueTask<bool> WaitToWriteAsync(CancellationToken cancellationToken)

System\Threading\Channels\ChannelReader.cs (6)

47/// <summary>Returns a <see cref="ValueTask{Boolean}"/> that will complete when data is available to read.</summary> 50/// A <see cref="ValueTask{Boolean}"/> that will complete with a <c>true</c> result when data is available to read 53public abstract ValueTask<bool> WaitToReadAsync(CancellationToken cancellationToken = default); 57/// <returns>A <see cref="ValueTask{TResult}"/> that represents the asynchronous read operation.</returns> 58public virtual ValueTask<T> ReadAsync(CancellationToken cancellationToken = default) 79async ValueTask<T> ReadAsyncCore(CancellationToken ct)

System\Threading\Channels\ChannelUtilities.cs (1)

57internal static ValueTask<T> GetInvalidCompletionValueTask<T>(Exception error)

System\Threading\Channels\ChannelWriter.cs (3)

27/// <summary>Returns a <see cref="ValueTask{Boolean}"/> that will complete when space is available to write an item.</summary> 30/// A <see cref="ValueTask{Boolean}"/> that will complete with a <c>true</c> result when space is available to write an item 33public abstract ValueTask<bool> WaitToWriteAsync(CancellationToken cancellationToken = default);

System\Threading\Channels\SingleConsumerUnboundedChannel.cs (3)

70public override ValueTask<T> ReadAsync(CancellationToken cancellationToken) 140public override ValueTask<bool> WaitToReadAsync(CancellationToken cancellationToken) 340public override ValueTask<bool> WaitToWriteAsync(CancellationToken cancellationToken)

System\Threading\Channels\UnboundedChannel.cs (3)

63public override ValueTask<T> ReadAsync(CancellationToken cancellationToken) 140public override ValueTask<bool> WaitToReadAsync(CancellationToken cancellationToken) 301public override ValueTask<bool> WaitToWriteAsync(CancellationToken cancellationToken)

System\Threading\Channels\UnboundedPriorityChannel.cs (3)

69public override ValueTask<T> ReadAsync(CancellationToken cancellationToken) 150public override ValueTask<bool> WaitToReadAsync(CancellationToken cancellationToken) 306public override ValueTask<bool> WaitToWriteAsync(CancellationToken cancellationToken)

System\Threading\RateLimiting\ChainedPartitionedRateLimiter.cs (1)

90protected override async ValueTask<RateLimitLease> AcquireAsyncCore(TResource resource, int permitCount, CancellationToken cancellationToken)

System\Threading\RateLimiting\ChainedRateLimiter.cs (1)

111protected override async ValueTask<RateLimitLease> AcquireAsyncCore(int permitCount, CancellationToken cancellationToken)

System\Threading\RateLimiting\ConcurrencyLimiter.cs (1)

115protected override ValueTask<RateLimitLease> AcquireAsyncCore(int permitCount, CancellationToken cancellationToken = default)

System\Threading\RateLimiting\DefaultPartitionedRateLimiter.cs (1)

82protected override ValueTask<RateLimitLease> AcquireAsyncCore(TResource resource, int permitCount, CancellationToken cancellationToken)

System\Threading\RateLimiting\FixedWindowRateLimiter.cs (1)

133protected override ValueTask<RateLimitLease> AcquireAsyncCore(int permitCount, CancellationToken cancellationToken = default)

System\Threading\RateLimiting\NoopLimiter.cs (1)

36protected override ValueTask<RateLimitLease> AcquireAsyncCore(int permitCount, CancellationToken cancellationToken)

System\Threading\RateLimiting\PartitionedRateLimiter.T.cs (2)

59public ValueTask<RateLimitLease> AcquireAsync(TResource resource, int permitCount = 1, CancellationToken cancellationToken = default) 81protected abstract ValueTask<RateLimitLease> AcquireAsyncCore(TResource resource, int permitCount, CancellationToken cancellationToken);

System\Threading\RateLimiting\RateLimiter.cs (2)

96public ValueTask<RateLimitLease> AcquireAsync(int permitCount = 1, CancellationToken cancellationToken = default) 117protected abstract ValueTask<RateLimitLease> AcquireAsyncCore(int permitCount, CancellationToken cancellationToken);

System\Threading\RateLimiting\SlidingWindowRateLimiter.cs (1)

145protected override ValueTask<RateLimitLease> AcquireAsyncCore(int permitCount, CancellationToken cancellationToken = default)

System\Threading\RateLimiting\TokenBucketRateLimiter.cs (1)

138protected override ValueTask<RateLimitLease> AcquireAsyncCore(int tokenCount, CancellationToken cancellationToken = default)

System\Threading\RateLimiting\TranslatingLimiter.cs (1)

37protected override ValueTask<RateLimitLease> AcquireAsyncCore(TResource resource, int permitCount, CancellationToken cancellationToken)

System.Threading.Tasks.Extensions.cs (1)

16[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.Tasks.ValueTask<>))]

System\Windows\Forms\Control_InvokeAsync.cs (4)

27/// <see cref="InvokeAsync{T}(Func{CancellationToken, ValueTask{T}}, CancellationToken)"/>. 93/// <see cref="InvokeAsync{T}(Func{CancellationToken, ValueTask{T}}, CancellationToken)"/>. 204/// and returns a <see cref="ValueTask{T}"/>. 225public async Task<T> InvokeAsync<T>(Func<CancellationToken, ValueTask<T>> callback, CancellationToken cancellationToken = default)

src\RoslynAnalyzers\NuGet\PerformanceSensitiveAnalyzers\PerformanceSensitiveAttribute.cs (1)

94/// <see cref="System.Threading.Tasks.ValueTask{TResult}"/>.</para>

src\RoslynAnalyzers\Utilities\Workspaces\DocumentExtensions.cs (3)

16public static async ValueTask<SemanticModel> GetRequiredSemanticModelAsync(this Document document, CancellationToken cancellationToken) 25public static async ValueTask<SyntaxTree> GetRequiredSyntaxTreeAsync(this Document document, CancellationToken cancellationToken) 34public static async ValueTask<SyntaxNode> GetRequiredSyntaxRootAsync(this Document document, CancellationToken cancellationToken)

MyPrompt.cs (1)

10public static ValueTask<string> Show(IJSRuntime jsRuntime, string message)

src\RoslynAnalyzers\NuGet\PerformanceSensitiveAnalyzers\PerformanceSensitiveAttribute.cs (1)

94/// <see cref="System.Threading.Tasks.ValueTask{TResult}"/>.</para>

src\RoslynAnalyzers\Utilities\Workspaces\DocumentExtensions.cs (3)

16public static async ValueTask<SemanticModel> GetRequiredSemanticModelAsync(this Document document, CancellationToken cancellationToken) 25public static async ValueTask<SyntaxTree> GetRequiredSyntaxTreeAsync(this Document document, CancellationToken cancellationToken) 34public static async ValueTask<SyntaxNode> GetRequiredSyntaxRootAsync(this Document document, CancellationToken cancellationToken)

Extensions.cs (1)

41public static async ValueTask<T> TakeAsync<T>(this BlockingCollection<T> collection, TimeSpan? pollTimeSpan = null, CancellationToken cancellationToken = default)

Sdk\AssertHelper.cs (1)

738 static T WaitForValueTask<T>(ValueTask<T> valueTask)