124 instantiations of Memory
Microsoft.AspNetCore.Components.Web (1)
Forms\InputFile\BrowserFileStream.cs (1)
68=> ReadAsync(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();
Microsoft.AspNetCore.HttpLogging (1)
ResponseBufferingStream.cs (1)
116await WriteAsync(new Memory<byte>(buffer, offset, count), cancellationToken);
Microsoft.AspNetCore.Server.IIS (3)
Core\HttpRequestStream.cs (1)
48return ReadAsyncInternal(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();
src\aspnetcore\src\Shared\ServerInfrastructure\DuplexPipeStream.cs (2)
75ValueTask<int> vt = ReadAsyncInternal(new Memory<byte>(buffer, offset, count), default); 83return ReadAsyncInternal(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();
Microsoft.AspNetCore.Server.Kestrel.Core (3)
Internal\Http\HttpRequestStream.cs (1)
49return ReadAsyncWrapper(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();
src\aspnetcore\src\Shared\ServerInfrastructure\DuplexPipeStream.cs (2)
75ValueTask<int> vt = ReadAsyncInternal(new Memory<byte>(buffer, offset, count), default); 83return ReadAsyncInternal(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();
Microsoft.AspNetCore.WebUtilities (2)
HttpRequestStreamReader.cs (2)
224var memory = new Memory<char>(buffer, index, count); 297var source = new Memory<char>(_charBuffer, _charBufferIndex, charsRemaining);
Microsoft.Data.Analysis (1)
DataFrameBuffer.cs (1)
86var memory = new Memory<byte>(new byte[newCapacity]);
Microsoft.Data.Analysis.Tests (1)
ArrowStringColumnTests.cs (1)
42Memory<byte> dataMemory = new Memory<byte>(bytes);
Microsoft.Extensions.Logging.Console (2)
src\runtime\src\libraries\Common\src\System\Net\ArrayBuffer.cs (2)
91public Memory<byte> ActiveMemory => new Memory<byte>(_bytes, _activeStart, _availableStart - _activeStart); 96public Memory<byte> AvailableMemorySliced(int length) => new Memory<byte>(_bytes, _availableStart, length);
Microsoft.ML.Tokenizers (2)
Normalizer\SentencePieceNormalizer.cs (2)
357normalizedPrefix = new Memory<byte>(_replacementBytes, 0, 3); 377normalizedPrefix = new Memory<byte>(_normalized, longestValue, normalizedLength - longestValue);
Shared (2)
ServerSentEvents\ArrayBuffer.cs (2)
92public readonly Memory<byte> ActiveMemory => new Memory<byte>(_bytes, _activeStart, _availableStart - _activeStart); 97public readonly Memory<byte> AvailableMemorySliced(int length) => new Memory<byte>(_bytes, _availableStart, length);
System.Collections.Immutable (1)
System\Collections\Immutable\ImmutableArray_1.Builder.cs (1)
1102internal Memory<T> AsMemory() => new(_elements, 0, _count);
System.Diagnostics.Process (1)
System\Diagnostics\AsyncStreamReader.cs (1)
97int bytesRead = await _stream.ReadAsync(new Memory<byte>(_byteBuffer), _cts.Token).ConfigureAwait(false);
System.Formats.Tar (2)
src\runtime\src\libraries\Common\src\System\IO\SubReadStream.cs (1)
212return ReadAsync(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();
System\Formats\Tar\GnuSparseStream.cs (1)
196return ReadAsync(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();
System.IO.Compression (6)
src\runtime\src\libraries\Common\src\System\IO\SubReadStream.cs (1)
212return ReadAsync(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();
src\runtime\src\libraries\Common\src\System\Net\ArrayBuffer.cs (2)
91public Memory<byte> ActiveMemory => new Memory<byte>(_bytes, _activeStart, _availableStart - _activeStart); 96public Memory<byte> AvailableMemorySliced(int length) => new Memory<byte>(_bytes, _availableStart, length);
System\IO\Compression\DeflateZLib\DeflateStream.cs (2)
426return ReadAsyncMemory(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask(); 479int n = await _stream.ReadAsync(new Memory<byte>(_buffer, 0, _buffer.Length), cancellationToken).ConfigureAwait(false);
System\IO\Compression\Zstandard\ZstandardStream.Decompress.cs (1)
299return ReadAsync(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();
System.IO.Compression.Brotli (3)
System\IO\Compression\dec\BrotliStream.Decompress.cs (1)
132return ReadAsync(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();
System\IO\Compression\enc\BrotliStream.Compress.cs (2)
164Memory<byte> output = new Memory<byte>(_buffer); 237Memory<byte> output = new Memory<byte>(_buffer);
System.IO.Pipelines (1)
System\IO\Pipelines\PipeReaderStream.cs (1)
90return ReadAsyncInternal(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();
System.IO.Pipes (1)
System\IO\Pipes\PipeStream.Unix.cs (1)
79return ReadAsyncCore(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();
System.IO.Ports (1)
System\IO\Ports\SerialStream.Unix.cs (1)
449Memory<byte> buffer = new Memory<byte>(array, offset, count);
System.Memory (1)
System\Buffers\ArrayMemoryPool.ArrayMemoryPoolBuffer.cs (1)
24return new Memory<T>(array);
System.Net.Http (5)
src\runtime\src\libraries\Common\src\System\Net\ArrayBuffer.cs (2)
91public Memory<byte> ActiveMemory => new Memory<byte>(_bytes, _activeStart, _availableStart - _activeStart); 96public Memory<byte> AvailableMemorySliced(int length) => new Memory<byte>(_bytes, _availableStart, length);
src\runtime\src\libraries\Common\src\System\Net\MultiArrayBuffer.cs (1)
359return new Memory<byte>(_blocks[GetBlockIndex(_start) + blockIndex], (int)startInBlock, (int)(endInBlock - startInBlock));
System\Net\Http\HttpBaseStream.cs (1)
54return ReadAsync(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();
System\Net\Http\MultipartContent.cs (1)
513return ReadAsyncPrivate(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();
System.Net.Http.Json (1)
System\Net\Http\Json\LengthLimitReadStream.cs (1)
42ReadAsync(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();
System.Net.Primitives (1)
src\runtime\src\libraries\Common\src\System\Net\SocketAddress.cs (1)
136return new Memory<byte>(_buffer);
System.Net.Quic (5)
src\runtime\src\libraries\Common\src\System\Net\ArrayBuffer.cs (2)
91public Memory<byte> ActiveMemory => new Memory<byte>(_bytes, _activeStart, _availableStart - _activeStart); 96public Memory<byte> AvailableMemorySliced(int length) => new Memory<byte>(_bytes, _availableStart, length);
src\runtime\src\libraries\Common\src\System\Net\MultiArrayBuffer.cs (1)
359return new Memory<byte>(_blocks[GetBlockIndex(_start) + blockIndex], (int)startInBlock, (int)(endInBlock - startInBlock));
System\Net\Quic\QuicStream.Stream.cs (2)
126int readLength = ReadAsync(new Memory<byte>(rentedBuffer, 0, buffer.Length), cts?.Token ?? default).AsTask().GetAwaiter().GetResult(); 146return ReadAsync(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();
System.Net.Requests (1)
System\Net\HttpWebResponse.cs (1)
410return ReadAsync(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();
System.Net.Security (7)
src\runtime\src\libraries\Common\src\System\Net\ArrayBuffer.cs (2)
91public Memory<byte> ActiveMemory => new Memory<byte>(_bytes, _activeStart, _availableStart - _activeStart); 96public Memory<byte> AvailableMemorySliced(int length) => new Memory<byte>(_bytes, _availableStart, length);
System\Net\Security\NegotiateStream.cs (3)
306ValueTask<int> vt = ReadAsync<SyncReadWriteAdapter>(new Memory<byte>(buffer, offset, count), default(CancellationToken)); 321return ReadAsync<AsyncReadWriteAdapter>(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask(); 389readBytes = await ReadAllAsync(InnerStream, new Memory<byte>(_readBuffer, 0, readBytes), allowZeroRead: false, cancellationToken).ConfigureAwait(false);
System\Net\Security\SslStream.cs (2)
811ValueTask<int> vt = ReadAsyncInternal<SyncReadWriteAdapter>(new Memory<byte>(buffer, offset, count), default(CancellationToken)); 895return ReadAsyncInternal<AsyncReadWriteAdapter>(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();
System.Net.ServerSentEvents (2)
src\runtime\src\libraries\Common\src\System\Net\ArrayBuffer.cs (2)
91public Memory<byte> ActiveMemory => new Memory<byte>(_bytes, _activeStart, _availableStart - _activeStart); 96public Memory<byte> AvailableMemorySliced(int length) => new Memory<byte>(_bytes, _availableStart, length);
System.Net.Sockets (5)
System\Net\Sockets\NetworkStream.cs (1)
575new Memory<byte>(buffer, offset, count),
System\Net\Sockets\SocketAsyncEventArgs.Unix.cs (1)
62CompleteAcceptOperation(acceptedFd, new Memory<byte>(_acceptBuffer, 0, socketAddressLen), socketError);
System\Net\Sockets\SocketPal.Unix.cs (3)
1284return handle.AsyncContext.Receive(new Memory<byte>(buffer, offset, count), socketFlags, handle.ReceiveTimeout, out bytesTransferred); 1314errorCode = handle.AsyncContext.ReceiveMessageFrom(new Memory<byte>(buffer, offset, count), ref socketFlags, socketAddress.Buffer, out socketAddressLen, isIPv4, isIPv6, handle.ReceiveTimeout, out ipPacketInformation, out bytesTransferred); 1359return handle.AsyncContext.ReceiveFrom(new Memory<byte>(buffer, offset, count), ref socketFlags, socketAddress, out socketAddressLen, handle.ReceiveTimeout, out bytesTransferred);
System.Net.WebClient (2)
System\Net\WebClient.cs (2)
903int bytesRead = await readStream.ReadAsync(new Memory<byte>(copyBuffer)).ConfigureAwait(false); 1036int bytesRead = await readStream.ReadAsync(new Memory<byte>(buffer)).ConfigureAwait(false);
System.Net.WebSockets (1)
System\Net\WebSockets\ManagedWebSocket.cs (1)
1566await SendFrameAsync(MessageOpcode.Close, endOfMessage: true, disableCompression: true, new Memory<byte>(buffer, 0, count), cancellationToken).ConfigureAwait(false);
System.Net.WebSockets.Client (1)
System\Net\WebSockets\BrowserWebSockets\BrowserWebSocket.cs (1)
304Memory<int> responseMemory = new Memory<int>(responseStatus);
System.Private.CoreLib (32)
src\runtime\src\libraries\System.Private.CoreLib\src\System\Buffers\MemoryManager.cs (3)
16public virtual Memory<T> Memory => new Memory<T>(this, GetSpan().Length); 39protected Memory<T> CreateMemory(int length) => new Memory<T>(this, length); 47protected Memory<T> CreateMemory(int start, int length) => new Memory<T>(this, start, length);
src\runtime\src\libraries\System.Private.CoreLib\src\System\IO\BufferedStream.cs (2)
624new Memory<byte>(buffer, offset + bytesFromBuffer, count - bytesFromBuffer), 716_readLen = await _stream.ReadAsync(new Memory<byte>(_buffer, 0, _bufferSize), cancellationToken).ConfigureAwait(false);
src\runtime\src\libraries\System.Private.CoreLib\src\System\IO\File.cs (1)
1137int read = await sr.ReadAsync(new Memory<char>(buffer), cancellationToken).ConfigureAwait(false);
src\runtime\src\libraries\System.Private.CoreLib\src\System\IO\Strategies\BufferedFileStreamStrategy.cs (2)
285ValueTask<int> readResult = ReadAsync(new Memory<byte>(buffer, offset, count), cancellationToken); 446_readLen = await _strategy.ReadAsync(new Memory<byte>(_buffer, 0, _bufferSize), cancellationToken).ConfigureAwait(false);
src\runtime\src\libraries\System.Private.CoreLib\src\System\IO\Strategies\OSFileStreamStrategy.cs (1)
269ReadAsync(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();
src\runtime\src\libraries\System.Private.CoreLib\src\System\IO\Stream.cs (1)
106while ((bytesRead = await source.ReadAsync(new Memory<byte>(buffer), cancellationToken).ConfigureAwait(false)) != 0)
src\runtime\src\libraries\System.Private.CoreLib\src\System\IO\StreamReader.cs (5)
1100return ReadAsyncInternalWithGuard(new Memory<char>(buffer, index, count), CancellationToken.None); 1103Task<int> task = ReadAsyncInternal(new Memory<char>(buffer, index, count), CancellationToken.None).AsTask(); 1178int len = await tmpStream.ReadAsync(new Memory<byte>(tmpByteBuffer, tmpBytePos, tmpByteBuffer.Length - tmpBytePos), cancellationToken).ConfigureAwait(false); 1214_byteLen = await tmpStream.ReadAsync(new Memory<byte>(tmpByteBuffer), cancellationToken).ConfigureAwait(false); 1408_byteLen = await tmpStream.ReadAsync(new Memory<byte>(tmpByteBuffer), cancellationToken).ConfigureAwait(false);
src\runtime\src\libraries\System.Private.CoreLib\src\System\IO\TextReader.cs (2)
271return ReadAsyncInternal(new Memory<char>(buffer, index, count), default).AsTask(); 301return ReadBlockAsyncInternal(new Memory<char>(buffer, index, count), default).AsTask();
src\runtime\src\libraries\System.Private.CoreLib\src\System\Memory.cs (4)
176public static implicit operator Memory<T>(T[]? array) => new Memory<T>(array); 181public static implicit operator Memory<T>(ArraySegment<T> segment) => new Memory<T>(segment.Array, segment.Offset, segment.Count); 233return new Memory<T>(_object, _index + start, _length - start); 257return new Memory<T>(_object, _index + start, length);
src\runtime\src\libraries\System.Private.CoreLib\src\System\MemoryExtensions.cs (8)
3830public static Memory<T> AsMemory<T>(this T[]? array) => new Memory<T>(array); 3843public static Memory<T> AsMemory<T>(this T[]? array, int start) => new Memory<T>(array, start); 3860return new Memory<T>(array, actualIndex); 3875public static Memory<T> AsMemory<T>(this T[]? array, int start, int length) => new Memory<T>(array, start, length); 3894return new Memory<T>(array, start, length); 3900public static Memory<T> AsMemory<T>(this ArraySegment<T> segment) => new Memory<T>(segment.Array, segment.Offset, segment.Count); 3918return new Memory<T>(segment.Array, segment.Offset + start, segment.Count - start); 3940return new Memory<T>(segment.Array, segment.Offset + start, length);
src\runtime\src\libraries\System.Private.CoreLib\src\System\Runtime\InteropServices\MemoryMarshal.cs (2)
76new Memory<T>(memory._object, memory._index, memory._length); 657return new Memory<T>((object)array, start | (1 << 31), length);
src\runtime\src\libraries\System.Private.CoreLib\src\System\Text\TranscodingStream.cs (1)
364return ReadAsync(new Memory<byte>(buffer, offset, count), cancellationToken).AsTask();
System.Security.Cryptography (2)
System\Security\Cryptography\CryptoStream.cs (2)
351await _stream.ReadAsync(new Memory<byte>(tempInputBuffer, _inputBufferIndex, numWholeBlocksInBytes - _inputBufferIndex), cancellationToken).ConfigureAwait(false) : 428await _stream.ReadAsync(new Memory<byte>(_inputBuffer, _inputBufferIndex, _inputBlockSize - _inputBufferIndex), cancellationToken).ConfigureAwait(false) :
System.ServiceModel.NetFramingBase (20)
System\ServiceModel\Channels\Connection.cs (8)
193return Connection.WriteAsync(new Memory<byte>(buffer, offset, count), Immediate, TimeoutHelper.FromMilliseconds(WriteTimeout)).AsTask(); 198Connection.WriteAsync(new Memory<byte>(buffer, offset, count), Immediate, TimeoutHelper.FromMilliseconds(WriteTimeout)).GetAwaiter().GetResult(); 204Memory<byte> memBuffer = new Memory<byte>(sharedBuffer, 0, buffer.Length); 223return Connection.WriteAsync(new Memory<byte>(buffer, offset, count), Immediate, TimeoutHelper.FromMilliseconds(WriteTimeout)) 232return Connection.ReadAsync(new Memory<byte>(buffer, offset, count), TimeoutHelper.FromMilliseconds(ReadTimeout)).AsTask(); 243Memory<byte> memBuffer = new Memory<byte>(sharedBuffer, 0, buffer.Length); 260return Connection.ReadAsync(new Memory<byte>(buffer, offset, count), TimeoutHelper.FromMilliseconds(ReadTimeout)).GetAwaiter().GetResult(); 265return Connection.ReadAsync(new Memory<byte>(buffer, offset, count), timeout).GetAwaiter().GetResult();
System\ServiceModel\Channels\FramingChannels.cs (2)
381int size = await connection.ReadAsync(new Memory<byte>(faultBuffer,0, 407size = await connection.ReadAsync(new Memory<byte>(faultBuffer, 0,
System\ServiceModel\Channels\FramingEncoders.cs (2)
235IntEncoder.Encode(messageFrame.Count, new Memory<byte>(buffer, offset, spaceNeeded - 1)); 319IntEncoder.Encode(messageFrame.Count, new Memory<byte>(buffer, offset, spaceNeeded));
System\ServiceModel\Channels\SessionConnectionReader.cs (2)
115bytesRead = await _connection.ReadAsync(new Memory<byte>(EnvelopeBuffer, EnvelopeOffset, _connection.ConnectionBufferSize), timeoutHelper.RemainingTime()); 122bytesRead = await _connection.ReadAsync(new Memory<byte>(_buffer, 0, _connection.ConnectionBufferSize), timeoutHelper.RemainingTime());
System\ServiceModel\Channels\SingletonConnectionReader.cs (6)
155size = await Connection.ReadAsync(new Memory<byte>(buffer, 0, Connection.ConnectionBufferSize), timeoutHelper.RemainingTime()); 484int bytesRead = await ReadCoreAsync(new Memory<byte>(buffer, offset, bytesToRead)); 518int bytesRead = await ReadCoreAsync(new Memory<byte>(buffer, offset, IntEncoder.MaxEncodedSize)); 593envelopeStartBytes.CopyTo(new Memory<byte>(messageData.Array, messageData.Offset - envelopeStartBytes.Length, envelopeStartBytes.Length)); 594await connection.WriteAsync(new Memory<byte>(messageData.Array, messageData.Offset - envelopeStartBytes.Length, 659WriteAsync(new Memory<byte>(buffer, offset, count)).GetAwaiter().GetResult();
System.ServiceModel.Primitives (2)
System\ServiceModel\Channels\TimeoutStream.cs (2)
79return await ReadAsync(new Memory<byte>(buffer, offset, count), cancellationToken); 122await WriteAsync(new Memory<byte>(buffer, offset, count), cancellationToken);
System.Text.Json (2)
src\runtime\src\libraries\Common\src\System\Net\ArrayBuffer.cs (2)
91public Memory<byte> ActiveMemory => new Memory<byte>(_bytes, _activeStart, _availableStart - _activeStart); 96public Memory<byte> AvailableMemorySliced(int length) => new Memory<byte>(_bytes, _availableStart, length);
1205 references to Memory
Aspire.Dashboard (2)
Otlp\Model\OtlpInstrument.cs (2)
61var comparableAttributes = tempAttributes.AsMemory(0, copyCount); 78private DimensionScope CreateDimensionScope(Memory<KeyValuePair<string, string>> comparableAttributes)
Aspire.Hosting.Browsers.Tests (1)
BrowserLogsCdpConnectionTests.cs (1)
599public override async ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)
Aspire.Hosting.Tests (1)
Dcp\GatedReadStream.cs (1)
57public override async ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)
dotnet (2)
Commands\Test\MTP\IPC\NamedPipeServer.cs (2)
103Memory<byte> remainingBytesToProcess = _readBuffer.AsMemory(0, currentReadBytes); 130remainingBytesToProcess = Memory<byte>.Empty;
GenerateDocumentationAndConfigFiles (36)
src\roslyn\src\Dependencies\Collections\Segmented\SegmentedArray.cs (36)
27foreach (var memory in array.GetSegments(index, length)) 67foreach (var memory in sourceArray.GetSegments(0, length)) 162foreach (var memory in sourceArray.GetSegments(sourceIndex, length)) 229foreach (var memory in array.GetSegments(startIndex, count)) 462private (Memory<T> first, Memory<T> second) _current; 473_current = (Memory<T>.Empty, Memory<T>.Empty); 476public readonly (Memory<T> first, Memory<T> second) Current => _current; 482_current = (Memory<T>.Empty, Memory<T>.Empty); 567private (Memory<T> first, Memory<T> second) _current; 578_current = (Memory<T>.Empty, Memory<T>.Empty); 581public readonly (Memory<T> first, Memory<T> second) Current => _current; 587_current = (Memory<T>.Empty, Memory<T>.Empty); 615private (Memory<T> first, Memory<T> second) _current; 626_current = (Memory<T>.Empty, Memory<T>.Empty); 629public readonly (Memory<T> first, Memory<T> second) Current => _current; 635_current = (Memory<T>.Empty, Memory<T>.Empty); 709private Memory<T> _current; 718_current = Memory<T>.Empty; 721public readonly Memory<T> Current => _current; 727_current = Memory<T>.Empty; 758private Memory<T> _current; 767_current = Memory<T>.Empty; 770public readonly Memory<T> Current => _current; 776_current = Memory<T>.Empty;
Microsoft.AspNetCore.Antiforgery (1)
src\aspnetcore\src\Shared\Buffers\RefPooledArrayBufferWriter.cs (1)
67public Memory<T> GetMemory(int sizeHint = 0)
Microsoft.AspNetCore.Components (1)
src\aspnetcore\src\Shared\PooledArrayBufferWriter.cs (1)
154public Memory<T> GetMemory(int sizeHint = 0)
Microsoft.AspNetCore.Components.Endpoints (6)
FormMapping\FormDataReader.cs (5)
19private readonly Memory<char> _prefixBuffer; 20private Memory<char> _currentPrefixBuffer; 30public FormDataReader(IReadOnlyDictionary<FormKey, StringValues> formCollection, CultureInfo culture, Memory<char> buffer) 37public FormDataReader(IReadOnlyDictionary<FormKey, StringValues> formCollection, CultureInfo culture, Memory<char> buffer, IFormFileCollection formFileCollection) 114var prefix = _currentPrefixBuffer;
src\aspnetcore\src\Shared\Buffers\RefPooledArrayBufferWriter.cs (1)
67public Memory<T> GetMemory(int sizeHint = 0)
Microsoft.AspNetCore.Components.Server (12)
BlazorPack\SequenceOfT.cs (3)
177public Memory<T> GetMemory(int sizeHint) => this.GetSegment(sizeHint).RemainingMemory; 320internal Memory<T> RemainingMemory => this.AvailableMemory.Slice(this.End); 336internal Memory<T> AvailableMemory => this.array ?? this.MemoryOwner?.Memory ?? default;
Circuits\RemoteJSDataStream.cs (1)
188public override async ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)
src\aspnetcore\src\Components\Shared\src\ArrayBuilderMemoryStream.cs (1)
56public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken)
src\aspnetcore\src\Shared\PooledArrayBufferWriter.cs (1)
154public Memory<T> GetMemory(int sizeHint = 0)
src\aspnetcore\src\SignalR\common\Shared\MemoryBufferWriter.cs (1)
109public Memory<byte> GetMemory(int sizeHint = 0)
src\aspnetcore\src\submodules\MessagePack-CSharp\src\MessagePack.UnityClient\Assets\Scripts\MessagePack\BufferWriter.cs (2)
64var memory = _output.GetMemoryCheckResult(); 219var memory = _output.GetMemoryCheckResult(count);
src\aspnetcore\src\submodules\MessagePack-CSharp\src\MessagePack.UnityClient\Assets\Scripts\MessagePack\ExtensionResult.cs (1)
16public ExtensionResult(sbyte typeCode, Memory<byte> data)
src\aspnetcore\src\submodules\MessagePack-CSharp\src\MessagePack.UnityClient\Assets\Scripts\MessagePack\Utilities.cs (2)
34internal static Memory<byte> GetMemoryCheckResult(this IBufferWriter<byte> bufferWriter, int size = 0) 36var memory = bufferWriter.GetMemory(size);
Microsoft.AspNetCore.Components.Web (2)
Forms\InputFile\BrowserFileStream.cs (2)
70public override async ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default) 101private async ValueTask<int> CopyFileDataIntoBuffer(Memory<byte> destination, CancellationToken cancellationToken)
Microsoft.AspNetCore.Components.WebAssembly (2)
src\aspnetcore\src\Components\Shared\src\ArrayBuilderMemoryStream.cs (1)
56public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken)
src\aspnetcore\src\Components\Shared\src\PullFromJSDataStream.cs (1)
79public override async ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)
Microsoft.AspNetCore.Components.WebView (2)
src\aspnetcore\src\Components\Shared\src\ArrayBuilderMemoryStream.cs (1)
56public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken)
src\aspnetcore\src\Components\Shared\src\PullFromJSDataStream.cs (1)
79public override async ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)
Microsoft.AspNetCore.DataProtection (2)
src\aspnetcore\src\Shared\Buffers\RefPooledArrayBufferWriter.cs (1)
67public Memory<T> GetMemory(int sizeHint = 0)
src\aspnetcore\src\Shared\PooledArrayBufferWriter.cs (1)
154public Memory<T> GetMemory(int sizeHint = 0)
Microsoft.AspNetCore.DataProtection.MicroBenchmarks (2)
src\aspnetcore\src\Shared\Buffers\RefPooledArrayBufferWriter.cs (1)
67public Memory<T> GetMemory(int sizeHint = 0)
src\aspnetcore\src\Shared\PooledArrayBufferWriter.cs (1)
154public Memory<T> GetMemory(int sizeHint = 0)
Microsoft.AspNetCore.Diagnostics.Middleware (4)
parent\parent\parent\eng\MSBuild\parent\parent\src\Shared\BufferWriterPool\BufferWriter.cs (4)
110/// Notifies <see cref="IBufferWriter{T}"/> that <paramref name="count"/> amount of data was written to the output <see cref="Span{T}"/>/<see cref="Memory{T}"/>. 127/// Returns a <see cref="Memory{T}"/> to write to that is at least the requested length (specified by <paramref name="sizeHint"/>). 133/// This will never return an empty <see cref="Memory{T}"/>. 139public Memory<T> GetMemory(int sizeHint = 0)
Microsoft.AspNetCore.Http (1)
Internal\ReferenceReadStream.cs (1)
104public override async ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken)
Microsoft.AspNetCore.Http.Connections (3)
Internal\Transports\WebSocketsServerTransport.cs (2)
140var result = await socket.ReceiveAsync(Memory<byte>.Empty, token); 148var memory = _application.Output.GetMemory();
src\aspnetcore\src\SignalR\common\Shared\MemoryBufferWriter.cs (1)
109public Memory<byte> GetMemory(int sizeHint = 0)
Microsoft.AspNetCore.Http.Connections.Client (2)
Internal\WebSocketsTransport.cs (2)
443var result = await socket.ReceiveAsync(Memory<byte>.Empty, _stopCts.Token).ConfigureAwait(false); 458var memory = _application.Output.GetMemory();
Microsoft.AspNetCore.Http.Connections.Common (2)
src\aspnetcore\src\SignalR\common\Shared\Utf8BufferTextWriter.cs (2)
24private Memory<byte> _memory; 71writer._memory = Memory<byte>.Empty;
Microsoft.AspNetCore.Http.Extensions (7)
RequestDelegateFactory.cs (2)
122private static readonly ConstructorInfo FormDataReaderConstructor = typeof(FormDataReader).GetConstructor(new[] { typeof(IReadOnlyDictionary<FormKey, StringValues>), typeof(CultureInfo), typeof(Memory<char>), typeof(IFormFileCollection) })!; 125private static readonly MethodInfo AsMemoryMethod = new Func<char[]?, int, int, Memory<char>>(MemoryExtensions.AsMemory).Method;
src\aspnetcore\src\Components\Endpoints\src\FormMapping\FormDataReader.cs (5)
19private readonly Memory<char> _prefixBuffer; 20private Memory<char> _currentPrefixBuffer; 30public FormDataReader(IReadOnlyDictionary<FormKey, StringValues> formCollection, CultureInfo culture, Memory<char> buffer) 37public FormDataReader(IReadOnlyDictionary<FormKey, StringValues> formCollection, CultureInfo culture, Memory<char> buffer, IFormFileCollection formFileCollection) 114var prefix = _currentPrefixBuffer;
Microsoft.AspNetCore.HttpLogging (6)
BufferingStream.cs (3)
19protected Memory<byte> _tailMemory; // remainder of tail memory 118public Memory<byte> GetMemory(int sizeHint = 0) 293public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)
RequestBufferingStream.cs (1)
30public override async ValueTask<int> ReadAsync(Memory<byte> destination, CancellationToken cancellationToken = default)
src\aspnetcore\src\Shared\Buffers\BufferSegment.cs (1)
90public Memory<byte> AvailableMemory { get; private set; }
src\aspnetcore\src\Shared\Buffers\RefPooledArrayBufferWriter.cs (1)
67public Memory<T> GetMemory(int sizeHint = 0)
Microsoft.AspNetCore.Mvc.Core (1)
Infrastructure\NonDisposableStream.cs (1)
82public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken)
Microsoft.AspNetCore.Mvc.ViewFeatures (1)
src\aspnetcore\src\Shared\PooledArrayBufferWriter.cs (1)
154public Memory<T> GetMemory(int sizeHint = 0)
Microsoft.AspNetCore.OpenApi (3)
src\aspnetcore\src\SignalR\common\Shared\MemoryBufferWriter.cs (1)
109public Memory<byte> GetMemory(int sizeHint = 0)
src\aspnetcore\src\SignalR\common\Shared\Utf8BufferTextWriter.cs (2)
24private Memory<byte> _memory; 71writer._memory = Memory<byte>.Empty;
Microsoft.AspNetCore.OutputCaching (1)
RecyclableArrayBufferWriter.cs (1)
63public Memory<T> GetMemory(int sizeHint = 0)
Microsoft.AspNetCore.Razor.Utilities.Shared (9)
ArrayExtensions.cs (2)
119public static Memory<T> AsMemory<T>(this T[]? array, Index startIndex) 163public static Memory<T> AsMemory<T>(this T[]? array, Range range)
PooledArrayBufferWriter`1.cs (1)
143public Memory<T> GetMemory(int sizeHint = 0)
src\roslyn\src\Razor\src\Shared\Microsoft.AspNetCore.Razor.SharedUtilities\MemoryBuilder`1.cs (5)
15/// Temporary builder that uses <see cref="ArrayPool{T}"/> to back a <see cref="Memory{T}"/>. 19private Memory<T> _memory; 75public readonly Memory<T> AsMemory() 82var memory = _memory; 99var memory = _memory;
src\roslyn\src\Razor\src\Shared\Microsoft.AspNetCore.Razor.SharedUtilities\MemoryBuilderExtensions.cs (1)
46var chunks = builder.AsMemory();
Microsoft.AspNetCore.RequestDecompression (1)
src\aspnetcore\src\Shared\SizeLimitedStream.cs (1)
87public override async ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)
Microsoft.AspNetCore.Server.HttpSys (6)
RequestProcessing\OpaqueStream.cs (1)
103public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)
src\aspnetcore\src\Shared\Buffers.MemoryPool\DiagnosticMemoryPool.cs (1)
165public bool ContainsMemory(Memory<byte> memory)
src\aspnetcore\src\Shared\Buffers.MemoryPool\DiagnosticPoolBlock.cs (2)
25private readonly Memory<byte> _memory; 41public override Memory<byte> Memory
src\aspnetcore\src\Shared\Buffers.MemoryPool\MemoryPoolBlock.cs (1)
28public Memory<byte> Memory { get; }
src\aspnetcore\src\Shared\HttpSys\RequestProcessing\NativeRequestContext.cs (1)
771var memory = PermanentlyPinned
Microsoft.AspNetCore.Server.IIS (23)
Core\DuplexStream.cs (1)
58public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)
Core\HttpRequestStream.cs (2)
51public override ValueTask<int> ReadAsync(Memory<byte> destination, CancellationToken cancellationToken = default) 58private async ValueTask<int> ReadAsyncInternal(Memory<byte> buffer, CancellationToken cancellationToken)
Core\HttpUpgradeStream.cs (1)
143public override ValueTask<int> ReadAsync(Memory<byte> destination, CancellationToken cancellationToken = default)
Core\IISHttpContext.IO.cs (2)
21internal async ValueTask<int> ReadAsync(Memory<byte> memory, CancellationToken cancellationToken) 103var memory = _bodyInputPipe!.Writer.GetMemory();
Core\IO\AsyncIOEngine.cs (1)
31public ValueTask<int> ReadAsync(Memory<byte> memory)
Core\IO\AsyncIOEngine.Read.cs (2)
19private Memory<byte> _memory; 26public void Initialize(NativeSafeHandle requestHandler, Memory<byte> memory)
Core\IO\IAsyncIOEngine.cs (1)
10ValueTask<int> ReadAsync(Memory<byte> memory);
Core\IO\WebSocketsAsyncIOEngine.cs (1)
29public ValueTask<int> ReadAsync(Memory<byte> memory)
Core\IO\WebSocketsAsyncIOEngine.Read.cs (2)
32private Memory<byte> _memory; 58public void Initialize(NativeSafeHandle requestHandler, Memory<byte> memory)
Core\WrappingStream.cs (1)
63public override ValueTask<int> ReadAsync(Memory<byte> destination, CancellationToken cancellationToken = default)
Core\WriteOnlyStreamInternal.cs (1)
49public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken)
src\aspnetcore\src\Shared\Buffers.MemoryPool\DiagnosticMemoryPool.cs (1)
165public bool ContainsMemory(Memory<byte> memory)
src\aspnetcore\src\Shared\Buffers.MemoryPool\DiagnosticPoolBlock.cs (2)
25private readonly Memory<byte> _memory; 41public override Memory<byte> Memory
src\aspnetcore\src\Shared\Buffers.MemoryPool\MemoryPoolBlock.cs (1)
28public Memory<byte> Memory { get; }
src\aspnetcore\src\Shared\HttpSys\RequestProcessing\NativeRequestContext.cs (1)
771var memory = PermanentlyPinned
src\aspnetcore\src\Shared\ServerInfrastructure\BufferExtensions.cs (1)
52public static ArraySegment<byte> GetArray(this Memory<byte> buffer)
src\aspnetcore\src\Shared\ServerInfrastructure\DuplexPipeStream.cs (2)
86public override ValueTask<int> ReadAsync(Memory<byte> destination, CancellationToken cancellationToken = default) 118private async ValueTask<int> ReadAsyncInternal(Memory<byte> destination, CancellationToken cancellationToken)
Microsoft.AspNetCore.Server.Kestrel.Core (42)
Internal\Http\Http1OutputProducer.cs (10)
59private Memory<byte> _currentChunkMemory; 66private Memory<byte> _currentSegment; 192public Memory<byte> GetMemory(int sizeHint = 0) 397var segment = _currentSegment.Slice(0, _position); 606private Memory<byte> GetChunkedMemory(int sizeHint) 628var actualMemory = _currentChunkMemory.Slice( 669internal Memory<byte> GetFakeMemory(int minSize) 713private Memory<byte> LeasedMemory(int sizeHint) 800public Memory<byte> Buffer { get; } 805public CompletedBuffer(IMemoryOwner<byte>? owner, Memory<byte> buffer, int length)
Internal\Http\HttpProtocol.cs (1)
1524public Memory<byte> GetMemory(int sizeHint = 0)
Internal\Http\HttpRequestStream.cs (3)
42public override ValueTask<int> ReadAsync(Memory<byte> destination, CancellationToken cancellationToken = default) 101private ValueTask<int> ReadAsyncWrapper(Memory<byte> destination, CancellationToken cancellationToken) 115private async ValueTask<int> ReadAsyncInternal(Memory<byte> destination, CancellationToken cancellationToken)
Internal\Http\HttpResponsePipeWriter.cs (1)
52public override Memory<byte> GetMemory(int sizeHint = 0)
Internal\Http\HttpResponseStream.cs (1)
46public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken)
Internal\Http\HttpUpgradeStream.cs (1)
143public override ValueTask<int> ReadAsync(Memory<byte> destination, CancellationToken cancellationToken = default)
Internal\Http\IHttpOutputProducer.cs (1)
25Memory<byte> GetMemory(int sizeHint = 0);
Internal\Http\IHttpResponseControl.cs (1)
11Memory<byte> GetMemory(int sizeHint = 0);
Internal\Http\IHttpResponsePipeWriterControl.cs (1)
11Memory<byte> GetMemory(int sizeHint = 0);
Internal\Http2\Http2Connection.cs (1)
1905var outputBuffer = writer.GetMemory(_minAllocBufferSize);
Internal\Http2\Http2OutputProducer.cs (2)
493public Memory<byte> GetMemory(int sizeHint = 0) 659internal Memory<byte> GetFakeMemory(int minSize)
Internal\Http3\Http3OutputProducer.cs (2)
196public Memory<byte> GetMemory(int sizeHint = 0) 226internal Memory<byte> GetFakeMemory(int minSize)
Internal\Infrastructure\PipeWriterHelpers\ConcurrentPipeWriter.cs (2)
31private Memory<byte> _tailMemory; 68public override Memory<byte> GetMemory(int sizeHint = 0)
Internal\Infrastructure\StatusCheckPipeWriter.cs (1)
64public override Memory<byte> GetMemory(int sizeHint = 0)
Internal\Infrastructure\ThrowingPipeWriter.cs (1)
25public override Memory<byte> GetMemory(int sizeHint = 0) => throw new InvalidOperationException(_message);
Internal\Infrastructure\WrappingPipeWriter.cs (1)
46public override Memory<byte> GetMemory(int sizeHint = 0)
Internal\Infrastructure\WrappingStream.cs (1)
62public override ValueTask<int> ReadAsync(Memory<byte> destination, CancellationToken cancellationToken = default)
Internal\Infrastructure\WriteOnlyStream.cs (1)
24public override ValueTask<int> ReadAsync(Memory<byte> memory, CancellationToken cancellationToken)
Middleware\Internal\LoggingStream.cs (1)
106public override async ValueTask<int> ReadAsync(Memory<byte> destination, CancellationToken cancellationToken = default)
src\aspnetcore\src\Shared\Buffers.MemoryPool\DiagnosticMemoryPool.cs (1)
165public bool ContainsMemory(Memory<byte> memory)
src\aspnetcore\src\Shared\Buffers.MemoryPool\DiagnosticPoolBlock.cs (2)
25private readonly Memory<byte> _memory; 41public override Memory<byte> Memory
src\aspnetcore\src\Shared\Buffers.MemoryPool\MemoryPoolBlock.cs (1)
28public Memory<byte> Memory { get; }
src\aspnetcore\src\Shared\Buffers\BufferSegment.cs (1)
90public Memory<byte> AvailableMemory { get; private set; }
src\aspnetcore\src\Shared\Buffers\RefPooledArrayBufferWriter.cs (1)
67public Memory<T> GetMemory(int sizeHint = 0)
src\aspnetcore\src\Shared\ServerInfrastructure\BufferExtensions.cs (1)
52public static ArraySegment<byte> GetArray(this Memory<byte> buffer)
src\aspnetcore\src\Shared\ServerInfrastructure\DuplexPipeStream.cs (2)
86public override ValueTask<int> ReadAsync(Memory<byte> destination, CancellationToken cancellationToken = default) 118private async ValueTask<int> ReadAsyncInternal(Memory<byte> destination, CancellationToken cancellationToken)
Microsoft.AspNetCore.Server.Kestrel.Transport.DirectTls (3)
Connection\DirectTlsConnection.cs (1)
234var memory = Application.Output.GetMemory(MinAllocBufferSize);
ConnectionIoState.cs (2)
77private Memory<byte> _readBuffer; 226public ValueTask<int> ReadAsync(Memory<byte> buffer)
Microsoft.AspNetCore.Server.Kestrel.Transport.NamedPipes (5)
Internal\NamedPipeConnection.cs (1)
87var buffer = input.GetMemory(MinAllocBufferSize);
src\aspnetcore\src\Shared\Buffers.MemoryPool\DiagnosticMemoryPool.cs (1)
165public bool ContainsMemory(Memory<byte> memory)
src\aspnetcore\src\Shared\Buffers.MemoryPool\DiagnosticPoolBlock.cs (2)
25private readonly Memory<byte> _memory; 41public override Memory<byte> Memory
src\aspnetcore\src\Shared\Buffers.MemoryPool\MemoryPoolBlock.cs (1)
28public Memory<byte> Memory { get; }
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic (6)
Internal\QuicStreamContext.cs (1)
215var buffer = input.GetMemory(MinAllocBufferSize);
src\aspnetcore\src\Servers\Kestrel\shared\CompletionPipeWriter.cs (1)
57public override Memory<byte> GetMemory(int sizeHint = 0)
src\aspnetcore\src\Shared\Buffers.MemoryPool\DiagnosticMemoryPool.cs (1)
165public bool ContainsMemory(Memory<byte> memory)
src\aspnetcore\src\Shared\Buffers.MemoryPool\DiagnosticPoolBlock.cs (2)
25private readonly Memory<byte> _memory; 41public override Memory<byte> Memory
src\aspnetcore\src\Shared\Buffers.MemoryPool\MemoryPoolBlock.cs (1)
28public Memory<byte> Memory { get; }
Microsoft.AspNetCore.Server.Kestrel.Transport.Sockets (4)
Internal\BufferExtensions.cs (1)
10public static ArraySegment<byte> GetArray(this Memory<byte> memory)
Internal\SocketConnection.cs (1)
153var buffer = Input.GetMemory(MinAllocBufferSize);
Internal\SocketReceiver.cs (2)
17SetBuffer(Memory<byte>.Empty); 32public ValueTask<SocketOperationResult> ReceiveAsync(Socket socket, Memory<byte> buffer)
Microsoft.AspNetCore.SignalR.Common (3)
src\aspnetcore\src\SignalR\common\Shared\MemoryBufferWriter.cs (1)
109public Memory<byte> GetMemory(int sizeHint = 0)
src\aspnetcore\src\SignalR\common\Shared\Utf8BufferTextWriter.cs (2)
24private Memory<byte> _memory; 71writer._memory = Memory<byte>.Empty;
Microsoft.AspNetCore.SignalR.Protocols.Json (2)
src\aspnetcore\src\SignalR\common\Shared\Utf8BufferTextWriter.cs (2)
24private Memory<byte> _memory; 71writer._memory = Memory<byte>.Empty;
Microsoft.AspNetCore.SignalR.Protocols.MessagePack (1)
src\aspnetcore\src\SignalR\common\Shared\MemoryBufferWriter.cs (1)
109public Memory<byte> GetMemory(int sizeHint = 0)
Microsoft.AspNetCore.SignalR.Protocols.NewtonsoftJson (3)
src\aspnetcore\src\SignalR\common\Shared\MemoryBufferWriter.cs (1)
109public Memory<byte> GetMemory(int sizeHint = 0)
src\aspnetcore\src\SignalR\common\Shared\Utf8BufferTextWriter.cs (2)
24private Memory<byte> _memory; 71writer._memory = Memory<byte>.Empty;
Microsoft.AspNetCore.SignalR.Specification.Tests (1)
src\aspnetcore\src\SignalR\common\Shared\MemoryBufferWriter.cs (1)
109public Memory<byte> GetMemory(int sizeHint = 0)
Microsoft.AspNetCore.SignalR.StackExchangeRedis (1)
src\aspnetcore\src\SignalR\common\Shared\MemoryBufferWriter.cs (1)
109public Memory<byte> GetMemory(int sizeHint = 0)
Microsoft.AspNetCore.TestHost (3)
AsyncStreamWrapper.cs (1)
57public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)
ResponseBodyPipeWriter.cs (1)
87public override Memory<byte> GetMemory(int sizeHint = 0)
ResponseBodyReaderStream.cs (1)
77public override async ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)
Microsoft.AspNetCore.Watch.BrowserRefresh (2)
src\sdk\src\Dotnet.Watch\Web.Middleware\ResponseStreamWrapper.cs (1)
154public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)
src\sdk\src\Dotnet.Watch\Web.Middleware\ScriptInjectingStream.cs (1)
306public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)
Microsoft.AspNetCore.WebSockets (1)
AbortStream.cs (1)
55public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)
Microsoft.AspNetCore.WebUtilities (9)
BufferedReadStream.cs (1)
226public override async ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken)
FileBufferingReadStream.cs (1)
334public override async ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)
FileBufferingWriteStream.cs (1)
103public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken)
HttpRequestStreamReader.cs (3)
224var memory = new Memory<char>(buffer, index, count); 230public override async ValueTask<int> ReadAsync(Memory<char> buffer, CancellationToken cancellationToken = default) 297var source = new Memory<char>(_charBuffer, _charBufferIndex, charsRemaining);
MultipartReaderStream.cs (3)
250public override async ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken) 271var slice = buffer[..Math.Min(buffer.Length, index)]; 294var slice = buffer[..Math.Min(buffer.Length, matchOffset - bufferedData.Offset)];
Microsoft.Build (38)
Logging\BinaryLogger\Postprocessing\SubStream.cs (1)
93public override async ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)
Logging\BinaryLogger\Postprocessing\TransparentReadStream.cs (1)
143public override async ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)
src\msbuild\artifacts\.packages\microsoft.codeanalysis.collections\5.0.0-1.25277.114\contentFiles\cs\net9.0\Segmented\SegmentedArray.cs (36)
27foreach (var memory in array.GetSegments(index, length)) 67foreach (var memory in sourceArray.GetSegments(0, length)) 162foreach (var memory in sourceArray.GetSegments(sourceIndex, length)) 229foreach (var memory in array.GetSegments(startIndex, count)) 462private (Memory<T> first, Memory<T> second) _current; 473_current = (Memory<T>.Empty, Memory<T>.Empty); 476public readonly (Memory<T> first, Memory<T> second) Current => _current; 482_current = (Memory<T>.Empty, Memory<T>.Empty); 567private (Memory<T> first, Memory<T> second) _current; 578_current = (Memory<T>.Empty, Memory<T>.Empty); 581public readonly (Memory<T> first, Memory<T> second) Current => _current; 587_current = (Memory<T>.Empty, Memory<T>.Empty); 615private (Memory<T> first, Memory<T> second) _current; 626_current = (Memory<T>.Empty, Memory<T>.Empty); 629public readonly (Memory<T> first, Memory<T> second) Current => _current; 635_current = (Memory<T>.Empty, Memory<T>.Empty); 709private Memory<T> _current; 718_current = Memory<T>.Empty; 721public readonly Memory<T> Current => _current; 727_current = Memory<T>.Empty; 758private Memory<T> _current; 767_current = Memory<T>.Empty; 770public readonly Memory<T> Current => _current; 776_current = Memory<T>.Empty;
Microsoft.CodeAnalysis (36)
src\roslyn\src\Dependencies\Collections\Segmented\SegmentedArray.cs (36)
27foreach (var memory in array.GetSegments(index, length)) 67foreach (var memory in sourceArray.GetSegments(0, length)) 162foreach (var memory in sourceArray.GetSegments(sourceIndex, length)) 229foreach (var memory in array.GetSegments(startIndex, count)) 462private (Memory<T> first, Memory<T> second) _current; 473_current = (Memory<T>.Empty, Memory<T>.Empty); 476public readonly (Memory<T> first, Memory<T> second) Current => _current; 482_current = (Memory<T>.Empty, Memory<T>.Empty); 567private (Memory<T> first, Memory<T> second) _current; 578_current = (Memory<T>.Empty, Memory<T>.Empty); 581public readonly (Memory<T> first, Memory<T> second) Current => _current; 587_current = (Memory<T>.Empty, Memory<T>.Empty); 615private (Memory<T> first, Memory<T> second) _current; 626_current = (Memory<T>.Empty, Memory<T>.Empty); 629public readonly (Memory<T> first, Memory<T> second) Current => _current; 635_current = (Memory<T>.Empty, Memory<T>.Empty); 709private Memory<T> _current; 718_current = Memory<T>.Empty; 721public readonly Memory<T> Current => _current; 727_current = Memory<T>.Empty; 758private Memory<T> _current; 767_current = Memory<T>.Empty; 770public readonly Memory<T> Current => _current; 776_current = Memory<T>.Empty;
Microsoft.CodeAnalysis.Analyzers (36)
src\roslyn\src\Dependencies\Collections\Segmented\SegmentedArray.cs (36)
27foreach (var memory in array.GetSegments(index, length)) 67foreach (var memory in sourceArray.GetSegments(0, length)) 162foreach (var memory in sourceArray.GetSegments(sourceIndex, length)) 229foreach (var memory in array.GetSegments(startIndex, count)) 462private (Memory<T> first, Memory<T> second) _current; 473_current = (Memory<T>.Empty, Memory<T>.Empty); 476public readonly (Memory<T> first, Memory<T> second) Current => _current; 482_current = (Memory<T>.Empty, Memory<T>.Empty); 567private (Memory<T> first, Memory<T> second) _current; 578_current = (Memory<T>.Empty, Memory<T>.Empty); 581public readonly (Memory<T> first, Memory<T> second) Current => _current; 587_current = (Memory<T>.Empty, Memory<T>.Empty); 615private (Memory<T> first, Memory<T> second) _current; 626_current = (Memory<T>.Empty, Memory<T>.Empty); 629public readonly (Memory<T> first, Memory<T> second) Current => _current; 635_current = (Memory<T>.Empty, Memory<T>.Empty); 709private Memory<T> _current; 718_current = Memory<T>.Empty; 721public readonly Memory<T> Current => _current; 727_current = Memory<T>.Empty; 758private Memory<T> _current; 767_current = Memory<T>.Empty; 770public readonly Memory<T> Current => _current; 776_current = Memory<T>.Empty;
Microsoft.CodeAnalysis.AnalyzerUtilities (36)
src\roslyn\src\Dependencies\Collections\Segmented\SegmentedArray.cs (36)
27foreach (var memory in array.GetSegments(index, length)) 67foreach (var memory in sourceArray.GetSegments(0, length)) 162foreach (var memory in sourceArray.GetSegments(sourceIndex, length)) 229foreach (var memory in array.GetSegments(startIndex, count)) 462private (Memory<T> first, Memory<T> second) _current; 473_current = (Memory<T>.Empty, Memory<T>.Empty); 476public readonly (Memory<T> first, Memory<T> second) Current => _current; 482_current = (Memory<T>.Empty, Memory<T>.Empty); 567private (Memory<T> first, Memory<T> second) _current; 578_current = (Memory<T>.Empty, Memory<T>.Empty); 581public readonly (Memory<T> first, Memory<T> second) Current => _current; 587_current = (Memory<T>.Empty, Memory<T>.Empty); 615private (Memory<T> first, Memory<T> second) _current; 626_current = (Memory<T>.Empty, Memory<T>.Empty); 629public readonly (Memory<T> first, Memory<T> second) Current => _current; 635_current = (Memory<T>.Empty, Memory<T>.Empty); 709private Memory<T> _current; 718_current = Memory<T>.Empty; 721public readonly Memory<T> Current => _current; 727_current = Memory<T>.Empty; 758private Memory<T> _current; 767_current = Memory<T>.Empty; 770public readonly Memory<T> Current => _current; 776_current = Memory<T>.Empty;
Microsoft.CodeAnalysis.CodeStyle (36)
src\roslyn\src\Dependencies\Collections\Segmented\SegmentedArray.cs (36)
27foreach (var memory in array.GetSegments(index, length)) 67foreach (var memory in sourceArray.GetSegments(0, length)) 162foreach (var memory in sourceArray.GetSegments(sourceIndex, length)) 229foreach (var memory in array.GetSegments(startIndex, count)) 462private (Memory<T> first, Memory<T> second) _current; 473_current = (Memory<T>.Empty, Memory<T>.Empty); 476public readonly (Memory<T> first, Memory<T> second) Current => _current; 482_current = (Memory<T>.Empty, Memory<T>.Empty); 567private (Memory<T> first, Memory<T> second) _current; 578_current = (Memory<T>.Empty, Memory<T>.Empty); 581public readonly (Memory<T> first, Memory<T> second) Current => _current; 587_current = (Memory<T>.Empty, Memory<T>.Empty); 615private (Memory<T> first, Memory<T> second) _current; 626_current = (Memory<T>.Empty, Memory<T>.Empty); 629public readonly (Memory<T> first, Memory<T> second) Current => _current; 635_current = (Memory<T>.Empty, Memory<T>.Empty); 709private Memory<T> _current; 718_current = Memory<T>.Empty; 721public readonly Memory<T> Current => _current; 727_current = Memory<T>.Empty; 758private Memory<T> _current; 767_current = Memory<T>.Empty; 770public readonly Memory<T> Current => _current; 776_current = Memory<T>.Empty;
Microsoft.CodeAnalysis.CSharp (2)
Lowering\LocalRewriter\LocalRewriter_IndexerAccess.cs (1)
1154nameof(Memory<>) => tryGetWellKnownSliceStartOverload(WellKnownMember.System_Memory_T__Slice_Int_Int, WellKnownMember.System_Memory_T__Slice_Int, originalDefinition, syntax),
Utilities\InterceptableLocation.cs (1)
149var hash = bytes.AsMemory(start: hashIndex, length: hashSize);
Microsoft.CodeAnalysis.Extensions.Package (36)
src\roslyn\src\Dependencies\Collections\Segmented\SegmentedArray.cs (36)
27foreach (var memory in array.GetSegments(index, length)) 67foreach (var memory in sourceArray.GetSegments(0, length)) 162foreach (var memory in sourceArray.GetSegments(sourceIndex, length)) 229foreach (var memory in array.GetSegments(startIndex, count)) 462private (Memory<T> first, Memory<T> second) _current; 473_current = (Memory<T>.Empty, Memory<T>.Empty); 476public readonly (Memory<T> first, Memory<T> second) Current => _current; 482_current = (Memory<T>.Empty, Memory<T>.Empty); 567private (Memory<T> first, Memory<T> second) _current; 578_current = (Memory<T>.Empty, Memory<T>.Empty); 581public readonly (Memory<T> first, Memory<T> second) Current => _current; 587_current = (Memory<T>.Empty, Memory<T>.Empty); 615private (Memory<T> first, Memory<T> second) _current; 626_current = (Memory<T>.Empty, Memory<T>.Empty); 629public readonly (Memory<T> first, Memory<T> second) Current => _current; 635_current = (Memory<T>.Empty, Memory<T>.Empty); 709private Memory<T> _current; 718_current = Memory<T>.Empty; 721public readonly Memory<T> Current => _current; 727_current = Memory<T>.Empty; 758private Memory<T> _current; 767_current = Memory<T>.Empty; 770public readonly Memory<T> Current => _current; 776_current = Memory<T>.Empty;
Microsoft.CodeAnalysis.ResxSourceGenerator (36)
src\roslyn\src\Dependencies\Collections\Segmented\SegmentedArray.cs (36)
27foreach (var memory in array.GetSegments(index, length)) 67foreach (var memory in sourceArray.GetSegments(0, length)) 162foreach (var memory in sourceArray.GetSegments(sourceIndex, length)) 229foreach (var memory in array.GetSegments(startIndex, count)) 462private (Memory<T> first, Memory<T> second) _current; 473_current = (Memory<T>.Empty, Memory<T>.Empty); 476public readonly (Memory<T> first, Memory<T> second) Current => _current; 482_current = (Memory<T>.Empty, Memory<T>.Empty); 567private (Memory<T> first, Memory<T> second) _current; 578_current = (Memory<T>.Empty, Memory<T>.Empty); 581public readonly (Memory<T> first, Memory<T> second) Current => _current; 587_current = (Memory<T>.Empty, Memory<T>.Empty); 615private (Memory<T> first, Memory<T> second) _current; 626_current = (Memory<T>.Empty, Memory<T>.Empty); 629public readonly (Memory<T> first, Memory<T> second) Current => _current; 635_current = (Memory<T>.Empty, Memory<T>.Empty); 709private Memory<T> _current; 718_current = Memory<T>.Empty; 721public readonly Memory<T> Current => _current; 727_current = Memory<T>.Empty; 758private Memory<T> _current; 767_current = Memory<T>.Empty; 770public readonly Memory<T> Current => _current; 776_current = Memory<T>.Empty;
Microsoft.CodeAnalysis.Workspaces (36)
src\roslyn\src\Dependencies\Collections\Segmented\SegmentedArray.cs (36)
27foreach (var memory in array.GetSegments(index, length)) 67foreach (var memory in sourceArray.GetSegments(0, length)) 162foreach (var memory in sourceArray.GetSegments(sourceIndex, length)) 229foreach (var memory in array.GetSegments(startIndex, count)) 462private (Memory<T> first, Memory<T> second) _current; 473_current = (Memory<T>.Empty, Memory<T>.Empty); 476public readonly (Memory<T> first, Memory<T> second) Current => _current; 482_current = (Memory<T>.Empty, Memory<T>.Empty); 567private (Memory<T> first, Memory<T> second) _current; 578_current = (Memory<T>.Empty, Memory<T>.Empty); 581public readonly (Memory<T> first, Memory<T> second) Current => _current; 587_current = (Memory<T>.Empty, Memory<T>.Empty); 615private (Memory<T> first, Memory<T> second) _current; 626_current = (Memory<T>.Empty, Memory<T>.Empty); 629public readonly (Memory<T> first, Memory<T> second) Current => _current; 635_current = (Memory<T>.Empty, Memory<T>.Empty); 709private Memory<T> _current; 718_current = Memory<T>.Empty; 721public readonly Memory<T> Current => _current; 727_current = Memory<T>.Empty; 758private Memory<T> _current; 767_current = Memory<T>.Empty; 770public readonly Memory<T> Current => _current; 776_current = Memory<T>.Empty;
Microsoft.Data.Analysis (3)
DataFrameBuffer.cs (3)
20private Memory<byte> _memory; 24public Memory<byte> Buffer 86var memory = new Memory<byte>(new byte[newCapacity]);
Microsoft.Data.Analysis.Tests (9)
ArrowStringColumnTests.cs (9)
27Memory<byte> dataMemory = new byte[] { 102, 111, 111, 98, 97, 114 }; 28Memory<byte> nullMemory = new byte[] { 0, 0, 0, 0 }; 29Memory<byte> offsetMemory = new byte[] { 0, 0, 0, 0, 3, 0, 0, 0, 6, 0, 0, 0 }; 42Memory<byte> dataMemory = new Memory<byte>(bytes); 43Memory<byte> nullMemory = new byte[] { 0b1101 }; 44Memory<byte> offsetMemory = new byte[] { 0, 0, 0, 0, 3, 0, 0, 0, 3, 0, 0, 0, 7, 0, 0, 0, 7, 0, 0, 0 }; 64Memory<byte> dataMemory = new byte[] { 102, 111, 111, 98, 97, 114 }; 65Memory<byte> nullMemory = new byte[] { 0, 0, 0, 0 }; 66Memory<byte> offsetMemory = new byte[] { 0, 0, 0, 0, 3, 0, 0, 0, 6, 0, 0, 0 };
Microsoft.DotNet.HotReload.Watch (1)
src\sdk\src\Dotnet.Watch\HotReloadClient\Web\BrowserConnection.cs (1)
65var data = writer.GetMemory();
Microsoft.Extensions.AI.Abstractions.Tests (11)
Generated\Basic.CompilerLog.Util\Basic.CompilerLog.Util.Impl.BasicGeneratedFilesAnalyzerReference\TestTypesContext.GetJsonTypeInfo.g.cs (1)
320if (type == typeof(global::System.Memory<byte>))
Generated\Basic.CompilerLog.Util\Basic.CompilerLog.Util.Impl.BasicGeneratedFilesAnalyzerReference\TestTypesContext.MemoryByte.g.cs (8)
15private global::System.Text.Json.Serialization.Metadata.JsonTypeInfo<global::System.Memory<byte>>? _MemoryByte; 21public global::System.Text.Json.Serialization.Metadata.JsonTypeInfo<global::System.Memory<byte>> MemoryByte 24get => _MemoryByte ??= (global::System.Text.Json.Serialization.Metadata.JsonTypeInfo<global::System.Memory<byte>>)Options.GetTypeInfo(typeof(global::System.Memory<byte>)); 27private global::System.Text.Json.Serialization.Metadata.JsonTypeInfo<global::System.Memory<byte>> Create_MemoryByte(global::System.Text.Json.JsonSerializerOptions options) 29if (!TryGetTypeInfoForRuntimeCustomConverter<global::System.Memory<byte>>(options, out global::System.Text.Json.Serialization.Metadata.JsonTypeInfo<global::System.Memory<byte>> jsonTypeInfo)) 31jsonTypeInfo = global::System.Text.Json.Serialization.Metadata.JsonMetadataServices.CreateValueInfo<global::System.Memory<byte>>(options, global::System.Text.Json.Serialization.Metadata.JsonMetadataServices.MemoryByteConverter);
parent\parent\Shared\JsonSchemaExporter\TestTypes.cs (2)
77yield return new TestData<Memory<byte>>(new byte[] { 1, 2, 3 }, """{"type":"string"}"""); 1233[JsonSerializable(typeof(Memory<byte>))]
Microsoft.Extensions.AI.OpenAI (1)
OpenAIFileDownloadStream.cs (1)
120public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default) =>
Microsoft.Extensions.Caching.Hybrid (1)
Internal\RecyclableArrayBufferWriter.cs (1)
117public Memory<T> GetMemory(int sizeHint = 0)
Microsoft.Extensions.Caching.Hybrid.Tests (1)
DistributedCacheTests.cs (1)
294var mem = new CustomMemory(size, rand).Memory;
Microsoft.Extensions.Caching.SqlServer (1)
DatabaseOperations.cs (1)
324var memory = destination.GetMemory(DefaultPageSize); // start from the page size
Microsoft.Extensions.Diagnostics.ResourceMonitoring (4)
parent\parent\parent\eng\MSBuild\parent\parent\src\Shared\BufferWriterPool\BufferWriter.cs (4)
110/// Notifies <see cref="IBufferWriter{T}"/> that <paramref name="count"/> amount of data was written to the output <see cref="Span{T}"/>/<see cref="Memory{T}"/>. 127/// Returns a <see cref="Memory{T}"/> to write to that is at least the requested length (specified by <paramref name="sizeHint"/>). 133/// This will never return an empty <see cref="Memory{T}"/>. 139public Memory<T> GetMemory(int sizeHint = 0)
Microsoft.Extensions.Http.Diagnostics (6)
Logging\Internal\HttpResponseBodyReader.cs (2)
184Memory<byte> memory = writer.GetMemory(chunkSize).Slice(0, chunkSize); 213Memory<byte> memory = writer.GetMemory(ChunkSize).Slice(0, ChunkSize);
parent\parent\parent\eng\MSBuild\parent\parent\src\Shared\BufferWriterPool\BufferWriter.cs (4)
110/// Notifies <see cref="IBufferWriter{T}"/> that <paramref name="count"/> amount of data was written to the output <see cref="Span{T}"/>/<see cref="Memory{T}"/>. 127/// Returns a <see cref="Memory{T}"/> to write to that is at least the requested length (specified by <paramref name="sizeHint"/>). 133/// This will never return an empty <see cref="Memory{T}"/>. 139public Memory<T> GetMemory(int sizeHint = 0)
Microsoft.Extensions.Http.Diagnostics.PerformanceTests (1)
NotSeekableStream.cs (1)
34public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default) => _innerStream.ReadAsync(buffer, cancellationToken);
Microsoft.Extensions.Http.Diagnostics.Tests (4)
Logging\HttpRequestBodyReaderTest.cs (1)
178streamMock.Setup(x => x.ReadAsync(It.IsAny<Memory<byte>>(), It.IsAny<CancellationToken>())).Throws<OperationCanceledException>();
Logging\HttpResponseBodyReaderTest.cs (2)
216streamMock.Setup(x => x.ReadAsync(It.IsAny<Memory<byte>>(), It.IsAny<CancellationToken>())).Throws<OperationCanceledException>(); 245streamMock.Setup(x => x.ReadAsync(It.IsAny<Memory<byte>>(), It.IsAny<CancellationToken>())).Throws(exception);
Logging\Internal\NotSeekableStream.cs (1)
34public override ValueTask<int> ReadAsync(System.Memory<byte> buffer, CancellationToken cancellationToken = default) => _innerStream.ReadAsync(buffer, cancellationToken);
Microsoft.Extensions.Logging.Console (4)
src\runtime\src\libraries\Common\src\System\Net\ArrayBuffer.cs (3)
91public Memory<byte> ActiveMemory => new Memory<byte>(_bytes, _activeStart, _availableStart - _activeStart); 95public Memory<byte> AvailableMemory => _bytes.AsMemory(_availableStart); 96public Memory<byte> AvailableMemorySliced(int length) => new Memory<byte>(_bytes, _availableStart, length);
src\runtime\src\libraries\Common\src\System\Text\Json\PooledByteBufferWriter.cs (1)
54public override Memory<byte> GetMemory(int sizeHint = MinimumBufferSize)
Microsoft.Extensions.ServiceDiscovery.Dns (7)
DnsResolverOptions.cs (1)
32internal Func<Memory<byte>, int, int>? _transportOverride;
Resolver\DnsDataWriter.cs (2)
11private readonly Memory<byte> _buffer; 14internal DnsDataWriter(Memory<byte> buffer)
Resolver\DnsResolver.cs (4)
702internal static (DnsDataReader reader, DnsMessageHeader header, SendQueryError sendError) SendDnsQueryCustomTransport(Func<Memory<byte>, int, int> callback, EncodedDomainName dnsSafeName, QueryType queryType) 737Memory<byte> memory = buffer; 845private static (ushort id, int length) EncodeQuestion(Memory<byte> buffer, EncodedDomainName dnsSafeName, QueryType queryType) 919Memory<byte> memory = buffer.AsMemory();
Microsoft.Extensions.ServiceDiscovery.Dns.Tests (8)
Resolver\DnsPrimitivesTests.cs (6)
105Memory<byte> data = "padding\x0007example\x0003com\x0000\x0003www\x00\x07"u8.ToArray(); 117Memory<byte> data = "padding\x0007example\x0003com\x0000\x0003www\x00\x07"u8.ToArray(); 130Memory<byte> data = "\x03www\x00\x000dpadding\x0007example\x0003com\x00"u8.ToArray(); 140Memory<byte> data = "\x0003www\0\0"u8.ToArray(); 150Memory<byte> data = "\x0003com\0\x0007example\0\0\x0008example2\0\0"u8.ToArray(); 162Memory<byte> data = "\x0003www\x00c0"u8.ToArray();
Resolver\LoopbackDnsServer.cs (2)
32private static async Task<int> ProcessRequestCore(IPEndPoint remoteEndPoint, ArraySegment<byte> message, Func<LoopbackDnsResponseBuilder, IPEndPoint, Task> action, Memory<byte> responseBuffer) 149public int Write(Memory<byte> responseBuffer)
Microsoft.ML.Tokenizers (3)
Normalizer\SentencePieceNormalizer.cs (3)
321private int NormalizePrefix(ReadOnlySpan<byte> input, out Memory<byte> normalizedPrefix) 430int p = NormalizePrefix(input, out Memory<byte> normalizedPrefix); 469int p = NormalizePrefix(input, out Memory<byte> normalizedPrefix);
mscorlib (1)
mscorlib.cs (1)
26[assembly:System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Memory<>))]
netstandard (1)
netstandard.cs (1)
1052[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Memory<>))]
Roslyn.Diagnostics.Analyzers (36)
src\roslyn\src\Dependencies\Collections\Segmented\SegmentedArray.cs (36)
27foreach (var memory in array.GetSegments(index, length)) 67foreach (var memory in sourceArray.GetSegments(0, length)) 162foreach (var memory in sourceArray.GetSegments(sourceIndex, length)) 229foreach (var memory in array.GetSegments(startIndex, count)) 462private (Memory<T> first, Memory<T> second) _current; 473_current = (Memory<T>.Empty, Memory<T>.Empty); 476public readonly (Memory<T> first, Memory<T> second) Current => _current; 482_current = (Memory<T>.Empty, Memory<T>.Empty); 567private (Memory<T> first, Memory<T> second) _current; 578_current = (Memory<T>.Empty, Memory<T>.Empty); 581public readonly (Memory<T> first, Memory<T> second) Current => _current; 587_current = (Memory<T>.Empty, Memory<T>.Empty); 615private (Memory<T> first, Memory<T> second) _current; 626_current = (Memory<T>.Empty, Memory<T>.Empty); 629public readonly (Memory<T> first, Memory<T> second) Current => _current; 635_current = (Memory<T>.Empty, Memory<T>.Empty); 709private Memory<T> _current; 718_current = Memory<T>.Empty; 721public readonly Memory<T> Current => _current; 727_current = Memory<T>.Empty; 758private Memory<T> _current; 767_current = Memory<T>.Empty; 770public readonly Memory<T> Current => _current; 776_current = Memory<T>.Empty;
Shared (8)
BufferWriterPool\BufferWriter.cs (4)
110/// Notifies <see cref="IBufferWriter{T}"/> that <paramref name="count"/> amount of data was written to the output <see cref="Span{T}"/>/<see cref="Memory{T}"/>. 127/// Returns a <see cref="Memory{T}"/> to write to that is at least the requested length (specified by <paramref name="sizeHint"/>). 133/// This will never return an empty <see cref="Memory{T}"/>. 139public Memory<T> GetMemory(int sizeHint = 0)
ServerSentEvents\ArrayBuffer.cs (3)
92public readonly Memory<byte> ActiveMemory => new Memory<byte>(_bytes, _activeStart, _availableStart - _activeStart); 96public readonly Memory<byte> AvailableMemory => _bytes.AsMemory(_availableStart); 97public readonly Memory<byte> AvailableMemorySliced(int length) => new Memory<byte>(_bytes, _availableStart, length);
ServerSentEvents\PooledByteBufferWriter.cs (1)
18public Memory<byte> GetMemory(int sizeHint = 0)
Shared.Tests (11)
Generated\Basic.CompilerLog.Util\Basic.CompilerLog.Util.Impl.BasicGeneratedFilesAnalyzerReference\TestTypesContext.GetJsonTypeInfo.g.cs (1)
332if (type == typeof(global::System.Memory<byte>))
Generated\Basic.CompilerLog.Util\Basic.CompilerLog.Util.Impl.BasicGeneratedFilesAnalyzerReference\TestTypesContext.MemoryByte.g.cs (8)
15private global::System.Text.Json.Serialization.Metadata.JsonTypeInfo<global::System.Memory<byte>>? _MemoryByte; 21public global::System.Text.Json.Serialization.Metadata.JsonTypeInfo<global::System.Memory<byte>> MemoryByte 24get => _MemoryByte ??= (global::System.Text.Json.Serialization.Metadata.JsonTypeInfo<global::System.Memory<byte>>)Options.GetTypeInfo(typeof(global::System.Memory<byte>)); 27private global::System.Text.Json.Serialization.Metadata.JsonTypeInfo<global::System.Memory<byte>> Create_MemoryByte(global::System.Text.Json.JsonSerializerOptions options) 29if (!TryGetTypeInfoForRuntimeCustomConverter<global::System.Memory<byte>>(options, out global::System.Text.Json.Serialization.Metadata.JsonTypeInfo<global::System.Memory<byte>> jsonTypeInfo)) 31jsonTypeInfo = global::System.Text.Json.Serialization.Metadata.JsonMetadataServices.CreateValueInfo<global::System.Memory<byte>>(options, global::System.Text.Json.Serialization.Metadata.JsonMetadataServices.MemoryByteConverter);
JsonSchemaExporter\TestTypes.cs (2)
77yield return new TestData<Memory<byte>>(new byte[] { 1, 2, 3 }, """{"type":"string"}"""); 1233[JsonSerializable(typeof(Memory<byte>))]
System.Collections.Immutable (5)
System\Collections\Immutable\ImmutableArray_1.Builder.cs (2)
1101/// <summary>Gets a <see cref="Memory{T}"/> for the filled portion of the backing array.</summary> 1102internal Memory<T> AsMemory() => new(_elements, 0, _count);
System\Runtime.InteropServices\ImmutableCollectionsMarshal.cs (3)
60/// Gets a <see cref="Memory{T}"/> for the <typeparamref name="T"/> array underlying an input <see cref="ImmutableArray{T}.Builder"/>. 65/// A <see cref="Memory{T}"/> for the filled portion of <typeparamref name="T"/> array underlying 68public static Memory<T> AsMemory<T>(ImmutableArray<T>.Builder? builder)
System.Formats.Tar (27)
src\runtime\src\libraries\Common\src\System\IO\SubReadStream.cs (2)
215public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default) 223private async ValueTask<int> ReadAsyncCore(Memory<byte> buffer, CancellationToken cancellationToken)
src\runtime\src\libraries\Common\src\System\ReadWriteAdapter.cs (9)
20static abstract ValueTask<int> ReadAsync(Stream stream, Memory<byte> buffer, CancellationToken cancellationToken); 21static abstract ValueTask<int> ReadAtLeastAsync(Stream stream, Memory<byte> buffer, int minimumBytes, bool throwOnEndOfStream, CancellationToken cancellationToken); 22static abstract ValueTask ReadExactlyAsync(Stream stream, Memory<byte> buffer, CancellationToken cancellationToken); 34public static ValueTask<int> ReadAsync(Stream stream, Memory<byte> buffer, CancellationToken cancellationToken) => 37public static ValueTask<int> ReadAtLeastAsync(Stream stream, Memory<byte> buffer, int minimumBytes, bool throwOnEndOfStream, CancellationToken cancellationToken) => 40public static ValueTask ReadExactlyAsync(Stream stream, Memory<byte> buffer, CancellationToken cancellationToken) => 60public static ValueTask<int> ReadAsync(Stream stream, Memory<byte> buffer, CancellationToken cancellationToken) => 63public static ValueTask<int> ReadAtLeastAsync(Stream stream, Memory<byte> buffer, int minimumBytes, bool throwOnEndOfStream, CancellationToken cancellationToken) => 66public static ValueTask ReadExactlyAsync(Stream stream, Memory<byte> buffer, CancellationToken cancellationToken)
System\Formats\Tar\GnuSparseStream.cs (3)
199public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default) 213private async ValueTask<int> ReadCoreAsync<TAdapter>(Memory<byte> buffer, CancellationToken cancellationToken) 335private async ValueTask<int> ReadFromPackedDataCoreAsync<TAdapter>(Memory<byte> destination, long packedOffset, CancellationToken cancellationToken)
System\Formats\Tar\TarHeader.Read.cs (3)
27Memory<byte> buffer = rented.AsMemory(0, TarHelpers.RecordSize); // minimumLength means the array could've been larger 666Memory<byte> memory = buffer.AsMemory(0, (int)_size); 718Memory<byte> memory = buffer.AsMemory(0, (int)_size);
System\Formats\Tar\TarHeader.Write.cs (8)
52private async ValueTask WriteWithSeekableDataStreamCoreAsync<TAdapter>(TarEntryFormat format, Stream archiveStream, Memory<byte> buffer, CancellationToken cancellationToken) 107private async ValueTask WriteWithUnseekableDataStreamCoreAsync<TAdapter>(TarEntryFormat format, Stream destinationStream, Memory<byte> buffer, bool shouldAdvanceToEnd, CancellationToken cancellationToken) 189internal ValueTask WriteAsPaxGlobalExtendedAttributesCoreAsync<TAdapter>(Stream archiveStream, Memory<byte> buffer, int globalExtendedAttributesEntryNumber, CancellationToken cancellationToken) 217internal ValueTask WriteAsV7CoreAsync<TAdapter>(Stream archiveStream, Memory<byte> buffer, CancellationToken cancellationToken) 245internal ValueTask WriteAsUstarCoreAsync<TAdapter>(Stream archiveStream, Memory<byte> buffer, CancellationToken cancellationToken) 292internal async ValueTask WriteAsPaxCoreAsync<TAdapter>(Stream archiveStream, Memory<byte> buffer, CancellationToken cancellationToken) 373internal async ValueTask WriteAsGnuCoreAsync<TAdapter>(Stream archiveStream, Memory<byte> buffer, CancellationToken cancellationToken) 468private ValueTask WriteAsPaxExtendedAttributesCoreAsync<TAdapter>(Stream archiveStream, Memory<byte> buffer, Dictionary<string, string> extendedAttributes, bool isGea, int globalExtendedAttributesEntryNumber, CancellationToken cancellationToken)
System\Formats\Tar\TarHelpers.cs (1)
92Memory<byte> memory = buffer.AsMemory(0, currentLengthToRead);
System\Formats\Tar\TarWriter.cs (1)
345Memory<byte> buffer = rented.AsMemory(0, TarHelpers.RecordSize); // minimumLength means the array could've been larger
System.IO.Compression (32)
src\runtime\src\libraries\Common\src\System\IO\SubReadStream.cs (2)
215public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default) 223private async ValueTask<int> ReadAsyncCore(Memory<byte> buffer, CancellationToken cancellationToken)
src\runtime\src\libraries\Common\src\System\Net\ArrayBuffer.cs (3)
91public Memory<byte> ActiveMemory => new Memory<byte>(_bytes, _activeStart, _availableStart - _activeStart); 95public Memory<byte> AvailableMemory => _bytes.AsMemory(_availableStart); 96public Memory<byte> AvailableMemorySliced(int length) => new Memory<byte>(_bytes, _availableStart, length);
System\IO\Compression\DeflateManaged\DeflateManagedStream.cs (3)
160private ValueTask<int> ReadAsyncInternal(Memory<byte> buffer, CancellationToken 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\DeflateManaged\InflaterManaged.cs (1)
95public void SetInput(Memory<byte> inputBytes) => _input.SetInput(inputBytes);
System\IO\Compression\DeflateManaged\InputBuffer.cs (3)
20private Memory<byte> _buffer; // memory to store input 129public int CopyTo(Memory<byte> output) 185public void SetInput(Memory<byte> buffer)
System\IO\Compression\DeflateZLib\DeflateStream.cs (3)
429public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default) 443internal ValueTask<int> ReadAsyncMemory(Memory<byte> buffer, CancellationToken cancellationToken) 459async ValueTask<int> Core(Memory<byte> buffer, CancellationToken cancellationToken)
System\IO\Compression\GZipStream.cs (1)
217public 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\WinZipAesStream.cs (1)
438public override async ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)
System\IO\Compression\ZipArchive.Async.cs (1)
220Memory<byte> fileBuffer = arrayPoolArray;
System\IO\Compression\ZipArchiveEntry.cs (1)
2293public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)
System\IO\Compression\ZipBlocks.Async.cs (2)
145Memory<byte> extraFieldBuffer = arrayPoolBuffer.AsMemory(0, extraFieldLength); 214Memory<byte> collatedHeader = arrayPoolBuffer.AsMemory(0, dynamicHeaderSize);
System\IO\Compression\ZipCryptoStream.cs (1)
394public override async ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)
System\IO\Compression\ZipCustomStreams.cs (3)
129public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default) 347public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default) 600public override async ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)
System\IO\Compression\ZipHelper.Async.cs (2)
32Memory<byte> bufferMemory = buffer.AsMemory(0, BackwardsSeekingBufferSize); 91private static async Task<int> SeekBackwardsAndReadAsync(Stream stream, Memory<byte> buffer, int overlap, CancellationToken cancellationToken)
System\IO\Compression\ZLibStream.cs (1)
169public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)
System\IO\Compression\Zstandard\ZstandardStream.Compress.cs (2)
175Memory<byte> output = _buffer.AvailableMemory; 350await WriteCoreAsync(Memory<byte>.Empty, cancellationToken, flush: true).ConfigureAwait(false);
System\IO\Compression\Zstandard\ZstandardStream.Decompress.cs (1)
310public override async ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)
System.IO.Compression.Brotli (6)
System\IO\Compression\dec\BrotliStream.Decompress.cs (2)
142public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default(CancellationToken)) 156async ValueTask<int> Core(Memory<byte> buffer, CancellationToken cancellationToken)
System\IO\Compression\enc\BrotliEncoder.cs (2)
123internal OperationStatus Flush(Memory<byte> destination, out int bytesWritten) => Flush(destination.Span, out bytesWritten); 131internal OperationStatus Compress(ReadOnlyMemory<byte> source, Memory<byte> destination, out int bytesConsumed, out int bytesWritten, bool isFinalBlock) => Compress(source.Span, destination.Span, out bytesConsumed, out bytesWritten, isFinalBlock);
System\IO\Compression\enc\BrotliStream.Compress.cs (2)
164Memory<byte> output = new Memory<byte>(_buffer); 237Memory<byte> output = new Memory<byte>(_buffer);
System.IO.IsolatedStorage (1)
System\IO\IsolatedStorage\IsolatedStorageFileStream.cs (1)
261public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken)
System.IO.Pipelines (19)
System\IO\Pipelines\BufferSegment.cs (1)
97public Memory<byte> AvailableMemory { get; private set; }
System\IO\Pipelines\Pipe.cs (2)
88private Memory<byte> _writingHeadMemory; 134internal Memory<byte> GetMemory(int sizeHint)
System\IO\Pipelines\Pipe.DefaultPipeWriter.cs (1)
36public override Memory<byte> GetMemory(int sizeHint = 0) => _pipe.GetMemory(sizeHint);
System\IO\Pipelines\PipeReaderStream.cs (2)
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 (7)
61/// <summary>Notifies the <see cref="System.IO.Pipelines.PipeWriter" /> that <paramref name="bytes" /> bytes were written to the output <see cref="System.Span{T}" /> or <see cref="System.Memory{T}" />. You must request a new buffer after calling <see cref="System.IO.Pipelines.PipeWriter.Advance(int)" /> to continue writing more data; you cannot write to a previously acquired buffer.</summary> 62/// <param name="bytes">The number of bytes written to the <see cref="System.Span{T}" /> or <see cref="System.Memory{T}" />.</param> 65/// <summary>Returns a <see cref="System.Memory{T}" /> to write to that is at least the requested size, as specified by the <paramref name="sizeHint" /> parameter.</summary> 66/// <param name="sizeHint">The minimum length of the returned <see cref="System.Memory{T}" />. If 0, a non-empty memory buffer of arbitrary size is returned.</param> 69/// This method never returns <see cref="System.Memory{T}.Empty" />, but it throws an <see cref="System.OutOfMemoryException" /> if the requested buffer size is not available. 72public abstract Memory<byte> GetMemory(int sizeHint = 0); 127Memory<byte> buffer = GetMemory();
System\IO\Pipelines\StreamPipeReader.cs (2)
260await reader.InnerStream.ReadAsync(Memory<byte>.Empty, tokenSource.Token).ConfigureAwait(false); 267Memory<byte> buffer = reader._readTail!.AvailableMemory.Slice(reader._readTail.End);
System\IO\Pipelines\StreamPipeWriter.cs (4)
21private Memory<byte> _tailMemory; 84public override Memory<byte> GetMemory(int sizeHint = 0) 248await FlushAsyncInternal(writeToStream: exception == null, data: Memory<byte>.Empty).ConfigureAwait(false); 273return FlushAsyncInternal(writeToStream: true, data: Memory<byte>.Empty, cancellationToken);
System.IO.Pipes (2)
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 (4)
System\IO\Ports\SerialStream.Unix.cs (4)
449Memory<byte> buffer = new Memory<byte>(array, offset, count); 462public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default) 1110public Memory<byte> Buffer { get; } 1112public SerialStreamReadRequest(SerialStream parent, CancellationToken ct, Memory<byte> buffer)
System.Memory (13)
src\runtime\artifacts\obj\System.Memory\Release\net11.0\System.Memory.Forwards.cs (1)
13[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Memory<>))]
src\runtime\src\libraries\Common\src\System\Buffers\ArrayBufferWriter.cs (6)
115/// Notifies <see cref="IBufferWriter{T}"/> that <paramref name="count"/> amount of data was written to the output <see cref="Span{T}"/>/<see cref="Memory{T}"/> 138/// Returns a <see cref="Memory{T}"/> to write to that is at least the requested length (specified by <paramref name="sizeHint"/>). 146/// This will never return an empty <see cref="Memory{T}"/>. 155/// If you reset the writer using the <see cref="ResetWrittenCount"/> method, this method may return a non-cleared <see cref="Memory{T}"/>. 158/// If you clear the writer using the <see cref="Clear"/> method, this method will return a <see cref="Memory{T}"/> with its content zeroed. 161public Memory<T> GetMemory(int sizeHint = 0)
System\Buffers\ArrayMemoryPool.ArrayMemoryPoolBuffer.cs (1)
17public Memory<T> Memory
System\Buffers\IBufferWriter.cs (4)
12/// Notifies <see cref="IBufferWriter{T}"/> that <paramref name="count"/> amount of data was written to the output <see cref="Span{T}"/>/<see cref="Memory{T}"/> 20/// Returns a <see cref="Memory{T}"/> to write to that is at least the requested length (specified by <paramref name="sizeHint"/>). 24/// This must never return an empty <see cref="Memory{T}"/> but it can throw 33Memory<T> GetMemory(int sizeHint = 0);
System\Buffers\ReadOnlySequenceStream.cs (1)
118public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)
System.Net.Http (42)
src\runtime\src\libraries\Common\src\System\IO\DelegatingStream.cs (1)
110public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)
src\runtime\src\libraries\Common\src\System\Net\ArrayBuffer.cs (3)
91public Memory<byte> ActiveMemory => new Memory<byte>(_bytes, _activeStart, _availableStart - _activeStart); 95public Memory<byte> AvailableMemory => _bytes.AsMemory(_availableStart); 96public Memory<byte> AvailableMemorySliced(int length) => new Memory<byte>(_bytes, _availableStart, length);
src\runtime\src\libraries\Common\src\System\Net\MultiArrayBuffer.cs (3)
342public Memory<byte> GetBlock(int blockIndex) 395Memory<byte> block = GetBlock(blockIndex); 411Memory<byte> block = GetBlock(blockIndex);
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\MultipartContent.cs (2)
516public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default) => 525public async ValueTask<int> ReadAsyncPrivate(Memory<byte> buffer, CancellationToken cancellationToken)
System\Net\Http\SocketsHttpHandler\ChunkedEncodingReadStream.cs (2)
119public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken) 162private async ValueTask<int> ReadAsyncCore(Memory<byte> buffer, CancellationToken cancellationToken)
System\Net\Http\SocketsHttpHandler\ConnectionCloseReadStream.cs (1)
38public override async ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken)
System\Net\Http\SocketsHttpHandler\ContentLengthReadStream.cs (1)
57public override async ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken)
System\Net\Http\SocketsHttpHandler\DecompressionHandler.cs (3)
291public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken) 297static async ValueTask<int> CreateAndReadAsync(ZLibOrDeflateStream thisRef, Memory<byte> buffer, CancellationToken cancellationToken) 402public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken)
System\Net\Http\SocketsHttpHandler\Http2Connection.cs (9)
426await _stream.ReadAsync(Memory<byte>.Empty).ConfigureAwait(false); 473await _stream.ReadAsync(Memory<byte>.Empty).ConfigureAwait(false); 547ValueTask<int> zeroByteReadTask = _stream.ReadAsync(Memory<byte>.Empty); 1185public abstract bool InvokeWriteAction(Memory<byte> writeBuffer); 1191private readonly Func<T, Memory<byte>, bool> _writeAction; 1193public WriteQueueEntry(int writeBytes, T state, Func<T, Memory<byte>, bool> writeAction, CancellationToken cancellationToken) 1200public override bool InvokeWriteAction(Memory<byte> writeBuffer) 1206private Task PerformWriteAsync<T>(int writeBytes, T state, Func<T, Memory<byte>, bool> writeAction, CancellationToken cancellationToken = default) 1406(buffer, Memory<byte>.Empty);
System\Net\Http\SocketsHttpHandler\Http2Stream.cs (3)
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>(ExceptionDispatchInfo.SetCurrentStackTrace(new NotSupportedException(SR.net_http_content_writeonly_stream))); 1605public override ValueTask<int> ReadAsync(Memory<byte> destination, CancellationToken cancellationToken)
System\Net\Http\SocketsHttpHandler\Http3RequestStream.cs (3)
1265private async ValueTask<int> ReadResponseContentAsync(HttpResponseMessage response, Memory<byte> buffer, CancellationToken cancellationToken) 1514public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken) 1560public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken)
System\Net\Http\SocketsHttpHandler\HttpConnection.cs (5)
256await _stream.ReadAsync(Memory<byte>.Empty).ConfigureAwait(false); 1800private ValueTask<int> ReadAsync(Memory<byte> destination) 1818async ValueTask<int> ReadAndLogBytesReadAsync(Memory<byte> destination) 1851private ValueTask<int> ReadBufferedAsync(Memory<byte> destination) 1865private async ValueTask<int> ReadBufferedAsyncCore(Memory<byte> destination)
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\RawConnectionStream.cs (1)
46public override async ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken)
System\Net\Http\SocketsHttpHandler\SocksHelper.cs (2)
342private static ValueTask WriteAsync(Stream stream, Memory<byte> buffer, bool async) 355private static async ValueTask ReadToFillAsync(Stream stream, Memory<byte> buffer, bool async)
System.Net.Http.Json (1)
System\Net\Http\Json\LengthLimitReadStream.cs (1)
44public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)
System.Net.Mail (18)
src\runtime\src\libraries\Common\src\System\ReadWriteAdapter.cs (9)
20static abstract ValueTask<int> ReadAsync(Stream stream, Memory<byte> buffer, CancellationToken cancellationToken); 21static abstract ValueTask<int> ReadAtLeastAsync(Stream stream, Memory<byte> buffer, int minimumBytes, bool throwOnEndOfStream, CancellationToken cancellationToken); 22static abstract ValueTask ReadExactlyAsync(Stream stream, Memory<byte> buffer, CancellationToken cancellationToken); 34public static ValueTask<int> ReadAsync(Stream stream, Memory<byte> buffer, CancellationToken cancellationToken) => 37public static ValueTask<int> ReadAtLeastAsync(Stream stream, Memory<byte> buffer, int minimumBytes, bool throwOnEndOfStream, CancellationToken cancellationToken) => 40public static ValueTask ReadExactlyAsync(Stream stream, Memory<byte> buffer, CancellationToken cancellationToken) => 60public static ValueTask<int> ReadAsync(Stream stream, Memory<byte> buffer, CancellationToken cancellationToken) => 63public static ValueTask<int> ReadAtLeastAsync(Stream stream, Memory<byte> buffer, int minimumBytes, bool throwOnEndOfStream, CancellationToken cancellationToken) => 66public static ValueTask ReadExactlyAsync(Stream stream, Memory<byte> buffer, CancellationToken cancellationToken)
System\Net\Base64Stream.cs (1)
191protected 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)
56protected override ValueTask<int> ReadAsyncInternal(Memory<byte> buffer, CancellationToken cancellationToken = default)
System\Net\Mime\QEncodedStream.cs (1)
223protected override ValueTask<int> ReadAsyncInternal(Memory<byte> buffer, CancellationToken cancellationToken = default)
System\Net\Mime\QuotedPrintableStream.cs (1)
337protected override ValueTask<int> ReadAsyncInternal(Memory<byte> buffer, CancellationToken cancellationToken = default)
System.Net.NameResolution (5)
System\Net\DnsResolverPal.Managed.cs (1)
764private static async Task ReceiveExactAsync(DnsSocket socket, Memory<byte> buffer, CancellationToken cancellationToken)
System\Net\DnsSocket.cs (4)
55private readonly Func<Memory<byte>, CancellationToken, ValueTask<int>> _receiveAsync; 82ReceiveAsyncMethod = socketType.GetMethod("ReceiveAsync", new[] { typeof(Memory<byte>), typeof(CancellationToken) })!, 115_receiveAsync = reflection.ReceiveAsyncMethod.CreateDelegate<Func<Memory<byte>, CancellationToken, ValueTask<int>>>(socket); 136public ValueTask<int> ReceiveAsync(Memory<byte> buffer, CancellationToken cancellationToken) =>
System.Net.Primitives (1)
src\runtime\src\libraries\Common\src\System\Net\SocketAddress.cs (1)
132public Memory<byte> Buffer
System.Net.Quic (13)
src\runtime\src\libraries\Common\src\System\Net\ArrayBuffer.cs (3)
91public Memory<byte> ActiveMemory => new Memory<byte>(_bytes, _activeStart, _availableStart - _activeStart); 95public Memory<byte> AvailableMemory => _bytes.AsMemory(_availableStart); 96public Memory<byte> AvailableMemorySliced(int length) => new Memory<byte>(_bytes, _availableStart, length);
src\runtime\src\libraries\Common\src\System\Net\MultiArrayBuffer.cs (3)
342public Memory<byte> GetBlock(int blockIndex) 395Memory<byte> block = GetBlock(blockIndex); 411Memory<byte> block = GetBlock(blockIndex);
src\runtime\src\libraries\Common\src\System\Net\StreamBuffer.cs (1)
238public async ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)
System\Net\Quic\Internal\ReceiveBuffers.cs (1)
69public int CopyTo(Memory<byte> buffer, out bool completed, out bool empty)
System\Net\Quic\QuicConnection.SslConnectionOptions.cs (2)
79Memory<byte> certData = default; 81Memory<byte> chainData = default;
System\Net\Quic\QuicStream.cs (3)
172/// Which might be by reading till end of stream (<see cref="ReadAsync(System.Memory{byte},System.Threading.CancellationToken)"/> will return <c>0</c>), 303public override async ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default) 748/// If the read side is not fully consumed, i.e.: <see cref="ReadsClosed"/> is not completed and/or <see cref="ReadAsync(Memory{byte}, CancellationToken)"/> hasn't returned <c>0</c>,
System.Net.Requests (2)
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 (20)
src\runtime\src\libraries\Common\src\System\Net\ArrayBuffer.cs (3)
91public Memory<byte> ActiveMemory => new Memory<byte>(_bytes, _activeStart, _availableStart - _activeStart); 95public Memory<byte> AvailableMemory => _bytes.AsMemory(_availableStart); 96public Memory<byte> AvailableMemorySliced(int length) => new Memory<byte>(_bytes, _availableStart, length);
src\runtime\src\libraries\Common\src\System\ReadWriteAdapter.cs (9)
20static abstract ValueTask<int> ReadAsync(Stream stream, Memory<byte> buffer, CancellationToken cancellationToken); 21static abstract ValueTask<int> ReadAtLeastAsync(Stream stream, Memory<byte> buffer, int minimumBytes, bool throwOnEndOfStream, CancellationToken cancellationToken); 22static abstract ValueTask ReadExactlyAsync(Stream stream, Memory<byte> buffer, CancellationToken cancellationToken); 34public static ValueTask<int> ReadAsync(Stream stream, Memory<byte> buffer, CancellationToken cancellationToken) => 37public static ValueTask<int> ReadAtLeastAsync(Stream stream, Memory<byte> buffer, int minimumBytes, bool throwOnEndOfStream, CancellationToken cancellationToken) => 40public static ValueTask ReadExactlyAsync(Stream stream, Memory<byte> buffer, CancellationToken cancellationToken) => 60public static ValueTask<int> ReadAsync(Stream stream, Memory<byte> buffer, CancellationToken cancellationToken) => 63public static ValueTask<int> ReadAtLeastAsync(Stream stream, Memory<byte> buffer, int minimumBytes, bool throwOnEndOfStream, CancellationToken cancellationToken) => 66public static ValueTask ReadExactlyAsync(Stream stream, Memory<byte> buffer, CancellationToken cancellationToken)
System\Net\Security\NegotiateStream.cs (3)
324public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default) 335private async ValueTask<int> ReadAsync<TIOAdapter>(Memory<byte> buffer, CancellationToken cancellationToken) 452static async ValueTask<int> ReadAllAsync(Stream stream, Memory<byte> buffer, bool allowZeroRead, CancellationToken cancellationToken)
System\Net\Security\SslStream.cs (2)
102public Memory<byte> AvailableMemory => _buffer.AvailableMemory; 898public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)
System\Net\Security\SslStream.IO.cs (3)
840await TIOAdapter.ReadAsync(InnerStream, Memory<byte>.Empty, cancellationToken).ConfigureAwait(false); 881private async ValueTask<int> ReadAsyncInternal<TIOAdapter>(Memory<byte> buffer, CancellationToken cancellationToken) 1090private int CopyDecryptedData(Memory<byte> buffer)
System.Net.ServerSentEvents (4)
src\runtime\src\libraries\Common\src\System\Net\ArrayBuffer.cs (3)
91public Memory<byte> ActiveMemory => new Memory<byte>(_bytes, _activeStart, _availableStart - _activeStart); 95public Memory<byte> AvailableMemory => _bytes.AsMemory(_availableStart); 96public Memory<byte> AvailableMemorySliced(int length) => new Memory<byte>(_bytes, _availableStart, length);
System\Net\ServerSentEvents\PooledByteBufferWriter.cs (1)
16public Memory<byte> GetMemory(int sizeHint = 0)
System.Net.Sockets (101)
System\Net\Sockets\NetEventSource.Sockets.cs (1)
57public static void DumpBuffer(object thisOrContextObject, Memory<byte> buffer, int offset, int count, [CallerMemberName] string? memberName = null) =>
System\Net\Sockets\NetworkStream.cs (1)
586public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)
System\Net\Sockets\Socket.Tasks.cs (8)
277public ValueTask<int> ReceiveAsync(Memory<byte> buffer, CancellationToken cancellationToken = default) => 287public ValueTask<int> ReceiveAsync(Memory<byte> buffer, SocketFlags socketFlags, CancellationToken cancellationToken = default) => 290internal ValueTask<int> ReceiveAsync(Memory<byte> buffer, SocketFlags socketFlags, bool fromNetworkStream, CancellationToken cancellationToken) 367public ValueTask<SocketReceiveFromResult> ReceiveFromAsync(Memory<byte> buffer, EndPoint remoteEndPoint, CancellationToken cancellationToken = default) => 378public ValueTask<SocketReceiveFromResult> ReceiveFromAsync(Memory<byte> buffer, SocketFlags socketFlags, EndPoint remoteEndPoint, CancellationToken cancellationToken = default) 412public ValueTask<int> ReceiveFromAsync(Memory<byte> buffer, SocketFlags socketFlags, SocketAddress receivedAddress, CancellationToken cancellationToken = default) 469public ValueTask<SocketReceiveMessageFromResult> ReceiveMessageFromAsync(Memory<byte> buffer, EndPoint remoteEndPoint, CancellationToken cancellationToken = default) => 480public ValueTask<SocketReceiveMessageFromResult> ReceiveMessageFromAsync(Memory<byte> buffer, SocketFlags socketFlags, EndPoint remoteEndPoint, CancellationToken cancellationToken = default)
System\Net\Sockets\SocketAsyncContext.Unix.cs (67)
131public Memory<byte> SocketAddress; 359public Action<int, Memory<byte>, SocketFlags, SocketError>? Callback { get; set; } 367public Memory<byte> Buffer; 381Memory<byte> sa = SocketAddress; 409Memory<byte> sa = SocketAddress; 443public Action<int, Memory<byte>, SocketFlags, SocketError>? Callback { get; set; } 451public Memory<byte> Buffer; 492Memory<byte> sa = SocketAddress; 525Memory<byte> sa = SocketAddress; 558public Memory<byte> Buffer; 570public Action<int, Memory<byte>, SocketFlags, IPPacketInformation, SocketError>? Callback { get; set; } 600public Action<int, Memory<byte>, SocketFlags, IPPacketInformation, SocketError>? Callback { get; set; } 622public Action<IntPtr, Memory<byte>, SocketError>? Callback { get; set; } 639Memory<byte> sa = SocketAddress; 662SocketError error = context.SendToAsync(Buffer, 0, Buffer.Length, SocketFlags.None, Memory<byte>.Empty, ref BytesTransferred, Callback!, default); 675Memory<byte> sa = SocketAddress; 677Memory<byte> buffer = Buffer; 1470public SocketError Accept(Memory<byte> socketAddress, out int socketAddressLen, out IntPtr acceptedFd) 1495public SocketError AcceptAsync(Memory<byte> socketAddress, out int socketAddressLen, out IntPtr acceptedFd, Action<IntPtr, Memory<byte>, SocketError> callback, CancellationToken cancellationToken) 1531public SocketError Connect(Memory<byte> socketAddress) 1560public SocketError ConnectAsync(Memory<byte> socketAddress, Action<int, Memory<byte>, SocketFlags, SocketError> callback, Memory<byte> buffer, out int sentBytes, CancellationToken cancellationToken) 1585errorCode = SendToAsync(buffer.Slice(sentBytes), 0, remains, SocketFlags.None, Memory<byte>.Empty, ref sentBytes, callback!, default); 1621public SocketError Receive(Memory<byte> buffer, SocketFlags flags, int timeout, out int bytesReceived) 1623return ReceiveFrom(buffer, ref flags, Memory<byte>.Empty, out int _, timeout, out bytesReceived); 1628return ReceiveFrom(buffer, ref flags, Memory<byte>.Empty, out int _, timeout, out bytesReceived); 1631public SocketError ReceiveAsync(Memory<byte> buffer, SocketFlags flags, out int bytesReceived, out SocketFlags receivedFlags, Action<int, Memory<byte>, SocketFlags, SocketError> callback, CancellationToken cancellationToken) 1633return ReceiveFromAsync(buffer, flags, Memory<byte>.Empty, out int _, out bytesReceived, out receivedFlags, callback, cancellationToken); 1636public SocketError ReceiveFrom(Memory<byte> buffer, ref SocketFlags flags, Memory<byte> socketAddress, out int socketAddressLen, int timeout, out int bytesReceived) 1669public unsafe SocketError ReceiveFrom(Span<byte> buffer, ref SocketFlags flags, Memory<byte> socketAddress, out int socketAddressLen, int timeout, out int bytesReceived) 1703public SocketError ReceiveAsync(Memory<byte> buffer, SocketFlags flags, out int bytesReceived, Action<int, Memory<byte>, SocketFlags, SocketError> callback, CancellationToken cancellationToken = default) 1735public SocketError ReceiveFromAsync(Memory<byte> buffer, SocketFlags flags, Memory<byte> socketAddress, out int socketAddressLen, out int bytesReceived, out SocketFlags receivedFlags, Action<int, Memory<byte>, SocketFlags, SocketError> callback, CancellationToken cancellationToken = default) 1773return ReceiveFrom(buffers, ref flags, Memory<byte>.Empty, out int _, timeout, out bytesReceived); 1776public SocketError ReceiveAsync(IList<ArraySegment<byte>> buffers, SocketFlags flags, out int bytesReceived, out SocketFlags receivedFlags, Action<int, Memory<byte>, SocketFlags, SocketError> callback) 1778return ReceiveFromAsync(buffers, flags, Memory<byte>.Empty, out int _, out bytesReceived, out receivedFlags, callback); 1781public SocketError ReceiveFrom(IList<ArraySegment<byte>> buffers, ref SocketFlags flags, Memory<byte> socketAddress, out int socketAddressLen, int timeout, out int bytesReceived) 1813public SocketError ReceiveFromAsync(IList<ArraySegment<byte>> buffers, SocketFlags flags, Memory<byte> socketAddress, out int socketAddressLen, out int bytesReceived, out SocketFlags receivedFlags, Action<int, Memory<byte>, SocketFlags, SocketError> callback) 1850Memory<byte> buffer, ref SocketFlags flags, Memory<byte> socketAddress, out int socketAddressLen, bool isIPv4, bool isIPv6, int timeout, out IPPacketInformation ipPacketInformation, out int bytesReceived) 1887Span<byte> buffer, ref SocketFlags flags, Memory<byte> socketAddress, out int socketAddressLen, bool isIPv4, bool isIPv6, int timeout, out IPPacketInformation ipPacketInformation, out int bytesReceived) 1926public SocketError ReceiveMessageFromAsync(Memory<byte> buffer, IList<ArraySegment<byte>>? buffers, SocketFlags flags, Memory<byte> socketAddress, out int socketAddressLen, bool isIPv4, bool isIPv6, out int bytesReceived, out SocketFlags receivedFlags, out IPPacketInformation ipPacketInformation, Action<int, Memory<byte>, SocketFlags, IPPacketInformation, SocketError> callback, CancellationToken cancellationToken = default) 1966SendTo(buffer, flags, Memory<byte>.Empty, timeout, out bytesSent); 1970return SendTo(buffer, offset, count, flags, Memory<byte>.Empty, timeout, out bytesSent); 1973public SocketError SendAsync(Memory<byte> buffer, int offset, int count, SocketFlags flags, out int bytesSent, Action<int, Memory<byte>, SocketFlags, SocketError> callback, CancellationToken cancellationToken) 1976return SendToAsync(buffer, offset, count, flags, Memory<byte>.Empty, ref bytesSent, callback, cancellationToken); 1979public SocketError SendTo(byte[] buffer, int offset, int count, SocketFlags flags, Memory<byte> socketAddress, int timeout, out int bytesSent) 2011public unsafe SocketError SendTo(ReadOnlySpan<byte> buffer, SocketFlags flags, Memory<byte> socketAddress, int timeout, out int bytesSent) 2047public SocketError SendToAsync(Memory<byte> buffer, int offset, int count, SocketFlags flags, Memory<byte> socketAddress, ref int bytesSent, Action<int, Memory<byte>, SocketFlags, SocketError> callback, CancellationToken cancellationToken = default) 2082return SendTo(buffers, flags, Memory<byte>.Empty, timeout, out bytesSent); 2085public SocketError SendAsync(IList<ArraySegment<byte>> buffers, SocketFlags flags, out int bytesSent, Action<int, Memory<byte>, SocketFlags, SocketError> callback) 2087return SendToAsync(buffers, flags, Memory<byte>.Empty, out bytesSent, callback); 2090public SocketError SendTo(IList<ArraySegment<byte>> buffers, SocketFlags flags, Memory<byte> socketAddress, int timeout, out int bytesSent) 2124public SocketError SendToAsync(IList<ArraySegment<byte>> buffers, SocketFlags flags, Memory<byte> socketAddress, out int bytesSent, Action<int, Memory<byte>, SocketFlags, SocketError> callback)
System\Net\Sockets\SocketAsyncEventArgs.cs (3)
21private Memory<byte> _buffer; 132public Memory<byte> MemoryBuffer => _buffer; 408public void SetBuffer(Memory<byte> buffer)
System\Net\Sockets\SocketAsyncEventArgs.Unix.cs (10)
16private Action<int, Memory<byte>, SocketFlags, SocketError>? _transferCompletionCallback; 26private void AcceptCompletionCallback(IntPtr acceptedFileDescriptor, Memory<byte> socketAddress, SocketError socketError) 33private void CompleteAcceptOperation(IntPtr acceptedFileDescriptor, Memory<byte> socketAddress, SocketError socketError) 69private void ConnectCompletionCallback(int bytesTransferred, Memory<byte> socketAddress, SocketFlags receivedFlags, SocketError socketError) 86SocketError socketError = handle.AsyncContext.ConnectAsync(_socketAddress!.Buffer, ConnectCompletionCallback, Memory<byte>.Empty, out int _, cancellationToken); 101private Action<int, Memory<byte>, SocketFlags, SocketError> TransferCompletionCallback => 104private void TransferCompletionCallbackCore(int bytesTransferred, Memory<byte> socketAddress, SocketFlags receivedFlags, SocketError socketError) 111private void CompleteTransferOperation(Memory<byte> _, int socketAddressSize, SocketFlags receivedFlags) 180private void ReceiveMessageFromCompletionCallback(int bytesTransferred, Memory<byte> socketAddress, SocketFlags receivedFlags, IPPacketInformation ipPacketInformation, SocketError errorCode) 187private void CompleteReceiveMessageFromOperation(Memory<byte> socketAddress, int socketAddressSize, SocketFlags receivedFlags, IPPacketInformation ipPacketInformation)
System\Net\Sockets\SocketPal.Unix.cs (10)
626public static unsafe bool TryCompleteAccept(SafeSocketHandle socket, Memory<byte> socketAddress, out int socketAddressLen, out IntPtr acceptedFd, out SocketError errorCode) 669public static bool TryStartConnect(SafeSocketHandle socket, Memory<byte> socketAddress, out SocketError errorCode) => TryStartConnect(socket, socketAddress, out errorCode, Span<byte>.Empty, false, out int _ ); 671public static unsafe bool TryStartConnect(SafeSocketHandle socket, Memory<byte> socketAddress, out SocketError errorCode, Span<byte> data, bool tfo, out int sent) 903public static bool TryCompleteReceiveMessageFrom(SafeSocketHandle socket, Span<byte> buffer, IList<ArraySegment<byte>>? buffers, SocketFlags flags, Memory<byte> socketAddress, out int receivedSocketAddressLength, bool isIPv4, bool isIPv6, out int bytesReceived, out SocketFlags receivedFlags, out IPPacketInformation ipPacketInformation, out SocketError errorCode) 1133public static SocketError Accept(SafeSocketHandle listenSocket, Memory<byte> socketAddress, out int socketAddressLen, out SafeSocketHandle socket) 1158public static SocketError Connect(SafeSocketHandle handle, Memory<byte> socketAddress) 1236public static SocketError SendTo(SafeSocketHandle handle, byte[] buffer, int offset, int count, SocketFlags socketFlags, Memory<byte> socketAddress, out int bytesTransferred) 1249public static SocketError SendTo(SafeSocketHandle handle, ReadOnlySpan<byte> buffer, SocketFlags socketFlags, Memory<byte> socketAddress, out int bytesTransferred) 1355public static SocketError ReceiveFrom(SafeSocketHandle handle, byte[] buffer, int offset, int count, SocketFlags socketFlags, Memory<byte> socketAddress, out int socketAddressLen, out int bytesTransferred) 1367public static SocketError ReceiveFrom(SafeSocketHandle handle, Span<byte> buffer, SocketFlags socketFlags, Memory<byte> socketAddress, out int socketAddressLen, out int bytesTransferred)
System\Net\Sockets\SocketTaskExtensions.cs (1)
50public static ValueTask<int> ReceiveAsync(this Socket socket, Memory<byte> buffer, SocketFlags socketFlags, CancellationToken cancellationToken = default) =>
System.Net.WebClient (1)
src\runtime\src\libraries\Common\src\System\IO\DelegatingStream.cs (1)
110public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)
System.Net.WebSockets (11)
System\Net\WebSockets\Compression\WebSocketInflater.cs (1)
55public Memory<byte> Memory => _buffer.AsMemory(_position + _available);
System\Net\WebSockets\ManagedWebSocket.cs (5)
56private readonly Memory<byte> _receiveBuffer; 370public override ValueTask<ValueWebSocketReceiveResult> ReceiveAsync(Memory<byte> buffer, CancellationToken cancellationToken) 775private async ValueTask<TResult> ReceiveAsyncPrivate<TResult>(Memory<byte> payloadBuffer, CancellationToken cancellationToken) 828await _stream.ReadAsync(Memory<byte>.Empty, cancellationToken).ConfigureAwait(false); 935Memory<byte> readBuffer = header.Compressed ?
System\Net\WebSockets\ValueWebSocketReceiveResult.cs (1)
8/// <summary>Represents the result of performing a single <see cref="WebSocket.ReceiveAsync(Memory{byte}, System.Threading.CancellationToken)"/> operation on a <see cref="WebSocket"/>.</summary>
System\Net\WebSockets\WebSocket.cs (1)
35public virtual async ValueTask<ValueWebSocketReceiveResult> ReceiveAsync(Memory<byte> buffer, CancellationToken cancellationToken)
System\Net\WebSockets\WebSocketStream.cs (3)
133public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default) => 216public override async ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default) 339public override async ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)
System.Net.WebSockets.Client (4)
System\Net\WebSockets\BrowserWebSockets\BrowserWebSocket.cs (3)
304Memory<int> responseMemory = new Memory<int>(responseStatus); 394Memory<byte> bufferMemory = buffer.AsMemory(); 438Memory<byte> bufferMemory = buffer.AsMemory();
System\Net\WebSockets\ClientWebSocket.cs (1)
153public override ValueTask<ValueWebSocketReceiveResult> ReceiveAsync(Memory<byte> buffer, CancellationToken cancellationToken) =>
System.Private.CoreLib (120)
src\runtime\src\libraries\System.Private.CoreLib\src\Microsoft\Win32\SafeHandles\SafeFileHandle.ThreadPoolValueTaskSource.cs (4)
44private IReadOnlyList<Memory<byte>>? _readScatterBuffers; 98Memory<byte> writableSingleSegment = MemoryMarshal.AsMemory(_singleSegment); 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\runtime\src\libraries\System.Private.CoreLib\src\System\Buffers\IMemoryOwner.cs (1)
14Memory<T> Memory { get; }
src\runtime\src\libraries\System.Private.CoreLib\src\System\Buffers\MemoryManager.cs (7)
9/// Manager of <see cref="Memory{T}"/> that provides the implementation. 14/// Returns a <see cref="Memory{T}"/>. 16public virtual Memory<T> Memory => new Memory<T>(this, GetSpan().Length); 35/// Returns a <see cref="Memory{T}"/> for the current <see cref="MemoryManager{T}"/>. 39protected Memory<T> CreateMemory(int length) => new Memory<T>(this, length); 42/// Returns a <see cref="Memory{T}"/> for the current <see cref="MemoryManager{T}"/>. 47protected Memory<T> CreateMemory(int start, int length) => new Memory<T>(this, start, length);
src\runtime\src\libraries\System.Private.CoreLib\src\System\IO\BufferedStream.cs (2)
628public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default) 672Memory<byte> buffer, CancellationToken cancellationToken, int bytesAlreadySatisfied, Task semaphoreLockTask)
src\runtime\src\libraries\System.Private.CoreLib\src\System\IO\FileStream.cs (2)
294public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default) 607internal ValueTask<int> BaseReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)
src\runtime\src\libraries\System.Private.CoreLib\src\System\IO\MemoryStream.cs (1)
388public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)
src\runtime\src\libraries\System.Private.CoreLib\src\System\IO\RandomAccess.cs (3)
89public static long Read(SafeFileHandle handle, IReadOnlyList<Memory<byte>> buffers, long fileOffset) 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\runtime\src\libraries\System.Private.CoreLib\src\System\IO\RandomAccess.Unix.cs (4)
58internal static unsafe long ReadScatterAtOffset(SafeFileHandle handle, IReadOnlyList<Memory<byte>> buffers, long fileOffset) 69Memory<byte> buffer = buffers[i]; 104internal static ValueTask<int> ReadAtOffsetAsync(SafeFileHandle handle, Memory<byte> buffer, long fileOffset, CancellationToken cancellationToken, OSFileStreamStrategy? strategy = null) 107private static ValueTask<long> ReadScatterAtOffsetAsync(SafeFileHandle handle, IReadOnlyList<Memory<byte>> buffers, long fileOffset, CancellationToken cancellationToken)
src\runtime\src\libraries\System.Private.CoreLib\src\System\IO\ReadOnlyMemoryStream.cs (1)
142public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)
src\runtime\src\libraries\System.Private.CoreLib\src\System\IO\Strategies\BufferedFileStreamStrategy.cs (3)
292public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default) 350private async ValueTask<int> ReadFromNonSeekableAsync(Memory<byte> destination, CancellationToken cancellationToken) 392private async ValueTask<int> ReadAsyncSlowPath(Task semaphoreLockTask, Memory<byte> buffer, CancellationToken cancellationToken)
src\runtime\src\libraries\System.Private.CoreLib\src\System\IO\Strategies\DerivedFileStreamStrategy.cs (1)
91public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)
src\runtime\src\libraries\System.Private.CoreLib\src\System\IO\Strategies\OSFileStreamStrategy.cs (1)
271public sealed override ValueTask<int> ReadAsync(Memory<byte> destination, CancellationToken cancellationToken)
src\runtime\src\libraries\System.Private.CoreLib\src\System\IO\Stream.cs (6)
309public virtual ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default) 319static async ValueTask<int> FinishReadAsync(Task<int> readTask, byte[] localBuffer, Memory<byte> localDestination) 347public ValueTask ReadExactlyAsync(Memory<byte> buffer, CancellationToken cancellationToken = default) 418public ValueTask<int> ReadAtLeastAsync(Memory<byte> buffer, int minimumBytes, bool throwOnEndOfStream = true, CancellationToken cancellationToken = default) 428private async ValueTask<int> ReadAtLeastAsyncCore(Memory<byte> buffer, int minimumBytes, bool throwOnEndOfStream, CancellationToken cancellationToken) 1057public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken) =>
src\runtime\src\libraries\System.Private.CoreLib\src\System\IO\StreamReader.cs (8)
1107async Task<int> ReadAsyncInternalWithGuard(Memory<char> buffer, CancellationToken cancellationToken) 1114public override ValueTask<int> ReadAsync(Memory<char> buffer, CancellationToken cancellationToken = default) 1133internal override async ValueTask<int> ReadAsyncInternal(Memory<char> buffer, CancellationToken cancellationToken) 1335public override ValueTask<int> ReadBlockAsync(Memory<char> buffer, CancellationToken cancellationToken = default) 1367async ValueTask<int> ReadBlockAsyncInternalWithGuard(Memory<char> buffer, CancellationToken token) 1488public override ValueTask<int> ReadAsync(Memory<char> buffer, CancellationToken cancellationToken) => 1497public override ValueTask<int> ReadBlockAsync(Memory<char> buffer, CancellationToken cancellationToken) => 1514internal override ValueTask<int> ReadAsyncInternal(Memory<char> buffer, CancellationToken cancellationToken) =>
src\runtime\src\libraries\System.Private.CoreLib\src\System\IO\StringReader.cs (2)
301public override ValueTask<int> ReadBlockAsync(Memory<char> buffer, CancellationToken cancellationToken = default) => 319public override ValueTask<int> ReadAsync(Memory<char> buffer, CancellationToken cancellationToken = default) =>
src\runtime\src\libraries\System.Private.CoreLib\src\System\IO\StringStream.cs (1)
263public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)
src\runtime\src\libraries\System.Private.CoreLib\src\System\IO\TextReader.cs (10)
274public virtual ValueTask<int> ReadAsync(Memory<char> buffer, CancellationToken cancellationToken = default) => 279var t = (TupleSlim<TextReader, Memory<char>>)state!; 281}, new TupleSlim<TextReader, Memory<char>>(this, buffer), cancellationToken, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default)); 283internal virtual ValueTask<int> ReadAsyncInternal(Memory<char> buffer, CancellationToken cancellationToken) => 286var t = (TupleSlim<TextReader, Memory<char>>)state!; 288}, new TupleSlim<TextReader, Memory<char>>(this, buffer), cancellationToken, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default)); 304public virtual ValueTask<int> ReadBlockAsync(Memory<char> buffer, CancellationToken cancellationToken = default) => 309var t = (TupleSlim<TextReader, Memory<char>>)state!; 311}, new TupleSlim<TextReader, Memory<char>>(this, buffer), cancellationToken, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default)); 313internal async ValueTask<int> ReadBlockAsyncInternal(Memory<char> buffer, CancellationToken cancellationToken)
src\runtime\src\libraries\System.Private.CoreLib\src\System\IO\UnmanagedMemoryStream.cs (1)
446public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)
src\runtime\src\libraries\System.Private.CoreLib\src\System\IO\UnmanagedMemoryStreamWrapper.cs (1)
164public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)
src\runtime\src\libraries\System.Private.CoreLib\src\System\IO\WritableMemoryStream.cs (5)
10/// Provides a seekable <see cref="Stream"/> for reading from and writing to a <see cref="Memory{Byte}"/>. 14private Memory<byte> _memory; 21/// Initializes a new instance of the <see cref="WritableMemoryStream"/> class over the specified <see cref="Memory{Byte}"/>. 28public WritableMemoryStream(Memory<byte> buffer) 144public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)
src\runtime\src\libraries\System.Private.CoreLib\src\System\Memory.cs (16)
21public readonly struct Memory<T> : IEquatable<Memory<T>> 174/// Defines an implicit conversion of an array to a <see cref="Memory{T}"/> 176public static implicit operator Memory<T>(T[]? array) => new Memory<T>(array); 179/// Defines an implicit conversion of a <see cref="ArraySegment{T}"/> to a <see cref="Memory{T}"/> 181public static implicit operator Memory<T>(ArraySegment<T> segment) => new Memory<T>(segment.Array, segment.Offset, segment.Count); 184/// Defines an implicit conversion of a <see cref="Memory{T}"/> to a <see cref="ReadOnlyMemory{T}"/> 186public static implicit operator ReadOnlyMemory<T>(Memory<T> memory) => 190/// Returns an empty <see cref="Memory{T}"/> 192public static Memory<T> Empty => default; 205/// For <see cref="Memory{Char}"/>, returns a new instance of string that represents the characters pointed to by the memory. 225public Memory<T> Slice(int start) 245public Memory<T> Slice(int start, int length) 362public void CopyTo(Memory<T> destination) => Span.CopyTo(destination.Span); 372public bool TryCopyTo(Memory<T> destination) => Span.TryCopyTo(destination.Span); 453else if (obj is Memory<T> memory) 467public bool Equals(Memory<T> other)
src\runtime\src\libraries\System.Private.CoreLib\src\System\MemoryDebugView.cs (1)
12public MemoryDebugView(Memory<T> memory)
src\runtime\src\libraries\System.Private.CoreLib\src\System\MemoryExtensions.cs (9)
3830public static Memory<T> AsMemory<T>(this T[]? array) => new Memory<T>(array); 3843public static Memory<T> AsMemory<T>(this T[]? array, int start) => new Memory<T>(array, start); 3849public static Memory<T> AsMemory<T>(this T[]? array, Index startIndex) 3875public static Memory<T> AsMemory<T>(this T[]? array, int start, int length) => new Memory<T>(array, start, length); 3881public static Memory<T> AsMemory<T>(this T[]? array, Range range) 3900public static Memory<T> AsMemory<T>(this ArraySegment<T> segment) => new Memory<T>(segment.Array, segment.Offset, segment.Count); 3913public static Memory<T> AsMemory<T>(this ArraySegment<T> segment, int start) 3933public static Memory<T> AsMemory<T>(this ArraySegment<T> segment, int start, int length) 3970public static void CopyTo<T>(this T[]? source, Memory<T> destination)
src\runtime\src\libraries\System.Private.CoreLib\src\System\MemoryExtensions.Trim.cs (18)
16public static Memory<T> Trim<T>(this Memory<T> memory, T trimElement) where T : IEquatable<T>? 29public static Memory<T> TrimStart<T>(this Memory<T> memory, T trimElement) where T : IEquatable<T>? 37public static Memory<T> TrimEnd<T>(this Memory<T> memory, T trimElement) where T : IEquatable<T>? 202public static Memory<T> Trim<T>(this Memory<T> memory, ReadOnlySpan<T> trimElements) where T : IEquatable<T>? 227public static Memory<T> TrimStart<T>(this Memory<T> memory, ReadOnlySpan<T> trimElements) where T : IEquatable<T>? 249public static Memory<T> TrimEnd<T>(this Memory<T> memory, ReadOnlySpan<T> trimElements) where T : IEquatable<T>? 517public static Memory<char> Trim(this Memory<char> memory) 529public static Memory<char> TrimStart(this Memory<char> memory) 536public static Memory<char> TrimEnd(this Memory<char> memory)
src\runtime\src\libraries\System.Private.CoreLib\src\System\ReadOnlyMemory.cs (3)
284public void CopyTo(Memory<T> destination) => Span.CopyTo(destination.Span); 294public bool TryCopyTo(Memory<T> destination) => Span.TryCopyTo(destination.Span); 365else if (obj is Memory<T> memory)
src\runtime\src\libraries\System.Private.CoreLib\src\System\Runtime\InteropServices\MemoryMarshal.cs (7)
14/// Provides a collection of methods for interoperating with <see cref="Memory{T}"/>, <see cref="ReadOnlyMemory{T}"/>, 66/// <summary>Creates a <see cref="Memory{T}"/> from a <see cref="ReadOnlyMemory{T}"/>.</summary> 68/// <returns>A <see cref="Memory{T}"/> representing the same memory as the <see cref="ReadOnlyMemory{T}"/>, but writable.</returns> 71/// to represent immutable data and other memory that is not meant to be written to; <see cref="Memory{T}"/> instances created 73/// as <see cref="Memory{T}"/> but only used for reading to store a <see cref="ReadOnlyMemory{T}"/>. 75public static Memory<T> AsMemory<T>(ReadOnlyMemory<T> memory) => 643public static Memory<T> CreateFromPinnedArray<T>(T[]? array, int start, int length)
src\runtime\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)
System.Runtime (1)
src\runtime\artifacts\obj\System.Runtime\Release\net11.0\System.Runtime.Forwards.cs (1)
355[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Memory<>))]
System.Security.Cryptography (40)
src\runtime\src\libraries\Common\src\System\Security\Cryptography\KeyFormatHelper.Encrypted.cs (1)
149Memory<byte> decryptedMemory = decrypted;
src\runtime\src\libraries\Common\src\System\Security\Cryptography\MLKem.cs (1)
1639Memory<byte> encapsulationKey = encapsulationKeyBuffer.AsMemory(0, encapsulationKeySize);
src\runtime\src\libraries\Common\src\System\Security\Cryptography\Pkcs\Pkcs8PrivateKeyInfo.cs (2)
183Memory<byte> decryptedMemory = decrypted; 214Memory<byte> decryptedMemory = decrypted;
System\Security\Cryptography\CryptographicOperations.cs (2)
349Memory<byte> destination, 741Memory<byte> destination,
System\Security\Cryptography\CryptoStream.cs (3)
224public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default) 232private async ValueTask<int> ReadAsyncInternal(Memory<byte> buffer, CancellationToken cancellationToken = default) 308private async ValueTask<int> ReadAsyncCore(Memory<byte> buffer, CancellationToken cancellationToken, bool useAsync)
System\Security\Cryptography\HashAlgorithm.cs (1)
134Memory<byte> buffer = rented;
System\Security\Cryptography\HashStatic.cs (1)
103Memory<byte> destination,
System\Security\Cryptography\HMACMD5.cs (1)
286Memory<byte> destination,
System\Security\Cryptography\HMACSHA1.cs (1)
279Memory<byte> destination,
System\Security\Cryptography\HMACSHA256.cs (1)
271Memory<byte> destination,
System\Security\Cryptography\HMACSHA3_256.cs (1)
307Memory<byte> destination,
System\Security\Cryptography\HMACSHA3_384.cs (1)
307Memory<byte> destination,
System\Security\Cryptography\HMACSHA3_512.cs (1)
307Memory<byte> destination,
System\Security\Cryptography\HMACSHA384.cs (1)
288Memory<byte> destination,
System\Security\Cryptography\HMACSHA512.cs (1)
285Memory<byte> destination,
System\Security\Cryptography\HMACStatic.cs (1)
141Memory<byte> destination,
System\Security\Cryptography\Kmac128.cs (1)
591Memory<byte> destination,
System\Security\Cryptography\Kmac256.cs (1)
591Memory<byte> destination,
System\Security\Cryptography\KmacXof128.cs (1)
591Memory<byte> destination,
System\Security\Cryptography\KmacXof256.cs (1)
591Memory<byte> destination,
System\Security\Cryptography\LiteHashProvider.cs (3)
31Memory<byte> destination, 84Memory<byte> destination, 142Memory<byte> destination,
System\Security\Cryptography\LiteHashProvider.Xof.cs (3)
60Memory<byte> destination, 92Memory<byte> destination, 127Memory<byte> destination,
System\Security\Cryptography\MD5.cs (1)
193Memory<byte> destination,
System\Security\Cryptography\SHA1.cs (1)
181Memory<byte> destination,
System\Security\Cryptography\SHA256.cs (1)
181Memory<byte> destination,
System\Security\Cryptography\SHA3_256.cs (1)
224Memory<byte> destination,
System\Security\Cryptography\SHA3_384.cs (1)
225Memory<byte> destination,
System\Security\Cryptography\SHA3_512.cs (1)
224Memory<byte> destination,
System\Security\Cryptography\SHA384.cs (1)
180Memory<byte> destination,
System\Security\Cryptography\SHA512.cs (1)
180Memory<byte> destination,
System\Security\Cryptography\Shake128.cs (1)
415public static ValueTask HashDataAsync(Stream source, Memory<byte> destination, CancellationToken cancellationToken = default)
System\Security\Cryptography\Shake256.cs (1)
415public static ValueTask HashDataAsync(Stream source, Memory<byte> destination, CancellationToken cancellationToken = default)
System.Security.Cryptography.Pkcs (4)
src\runtime\src\libraries\Common\src\System\Security\Cryptography\KeyFormatHelper.Encrypted.cs (1)
149Memory<byte> decryptedMemory = decrypted;
src\runtime\src\libraries\Common\src\System\Security\Cryptography\Pkcs\Pkcs8PrivateKeyInfo.cs (2)
183Memory<byte> decryptedMemory = decrypted; 214Memory<byte> decryptedMemory = decrypted;
System\Security\Cryptography\Pkcs\SignedCms.cs (1)
25private Memory<byte> _heldData;
System.ServiceModel.NetFramingBase (35)
System\ServiceModel\Channels\BufferedConnection.cs (1)
12private Memory<byte> _writeBuffer;
System\ServiceModel\Channels\Connection.cs (11)
17ValueTask<int> ReadAsync(Memory<byte> buffer, TimeSpan timeout); 38public virtual ValueTask<int> ReadAsync(Memory<byte> buffer, TimeSpan timeout) => Connection.ReadAsync(buffer, timeout); 45private Memory<byte> _preReadData; 47public PreReadConnection(IConnection innerConnection, Memory<byte> initialData) 53public void AddPreReadData(Memory<byte> initialData) 57Memory<byte> tempBuffer = _preReadData; 68public override ValueTask<int> ReadAsync(Memory<byte> buffer, TimeSpan timeout) 204Memory<byte> memBuffer = new Memory<byte>(sharedBuffer, 0, buffer.Length); 235public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default) 243Memory<byte> memBuffer = new Memory<byte>(sharedBuffer, 0, buffer.Length); 292public async ValueTask<int> ReadAsync(Memory<byte> buffer, TimeSpan timeout)
System\ServiceModel\Channels\FramingChannels.cs (4)
162private Memory<byte> CreatePreamble() 176Memory<byte> startBytes = Fx.AllocateByteArray(startSize); 209private async Task<IConnection> SendPreambleAsync(IConnection connection, Memory<byte> preamble, TimeSpan timeout) 348private Memory<byte> _preamble;
System\ServiceModel\Channels\FramingEncoders.cs (12)
15public static int Encode(int value, Memory<byte> bytes) 66public Memory<byte> EncodedBytes { get; private set; } 68protected void SetEncodedBytes(Memory<byte> encodedBytes) 102Memory<byte> otherBytes = other.EncodedBytes; 217public static void EncodeStart(Memory<byte> buffer, EncodedVia via, EncodedContentType contentType) 296public static Memory<byte> EnvelopeStartBytes = new byte[] { 299public static Memory<byte> EnvelopeEndBytes = new byte[] { 302public static Memory<byte> EnvelopeEndFramingEndBytes = new byte[] { 305public static Memory<byte> EndBytes = new byte[] { 335public static Memory<byte> PreambleEndBytes = new byte[] { 339public static Memory<byte> ModeBytes = new byte[] { 351public static void EncodeStart(Memory<byte> buffer, EncodedVia via, EncodedContentType contentType)
System\ServiceModel\Channels\SingletonConnectionReader.cs (6)
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) 563Memory<byte> endBytes = default; 567Memory<byte> envelopeStartBytes = SingletonEncoder.EnvelopeStartBytes; 613private Memory<byte> _encodedSize;
System\ServiceModel\Channels\StreamedFramingRequestChannel.cs (1)
34private Memory<byte> Preamble { get; set; }
System.ServiceModel.NetNamedPipe (1)
System\ServiceModel\Channels\PipeConnection.cs (1)
114public async ValueTask<int> ReadAsync(Memory<byte> buffer, TimeSpan timeout)
System.ServiceModel.NetTcp (3)
System\ServiceModel\Channels\SocketAwaitableEventArgs.cs (1)
31public ValueTask<int> ReceiveAsync(Socket socket, Memory<byte> buffer)
System\ServiceModel\Channels\SocketConnection.cs (2)
174public ValueTask<int> ReadAsync(Memory<byte> buffer, TimeSpan timeout) 185private async ValueTask<int> ReadCoreAsync(Memory<byte> buffer, TimeSpan timeout, bool closing)
System.ServiceModel.Primitives (4)
System\ServiceModel\Channels\DelegatingStream.cs (1)
92public override ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default) => BaseStream.ReadAsync(buffer, cancellationToken);
System\ServiceModel\Channels\DetectEofStream.cs (1)
36public override async ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)
System\ServiceModel\Channels\MaxMessageSizeStream.cs (1)
31public override async ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)
System\ServiceModel\Channels\TimeoutStream.cs (1)
64public override async ValueTask<int> ReadAsync(Memory<byte> buffer, CancellationToken cancellationToken = default)
System.ServiceModel.UnixDomainSocket (3)
System\ServiceModel\Channels\SocketAwaitableEventArgs.cs (1)
31public ValueTask<int> ReceiveAsync(Socket socket, Memory<byte> buffer)
System\ServiceModel\Channels\SocketConnection.cs (2)
156public ValueTask<int> ReadAsync(Memory<byte> buffer, TimeSpan timeout) 167private async ValueTask<int> ReadCoreAsync(Memory<byte> buffer, TimeSpan timeout, bool closing)
System.Text.Json (19)
src\runtime\src\libraries\Common\src\System\Net\ArrayBuffer.cs (3)
91public Memory<byte> ActiveMemory => new Memory<byte>(_bytes, _activeStart, _availableStart - _activeStart); 95public Memory<byte> AvailableMemory => _bytes.AsMemory(_availableStart); 96public Memory<byte> AvailableMemorySliced(int length) => new Memory<byte>(_bytes, _availableStart, length);
src\runtime\src\libraries\Common\src\System\Text\Json\PooledByteBufferWriter.cs (1)
54public override Memory<byte> GetMemory(int sizeHint = MinimumBufferSize)
System\Text\Json\Serialization\Converters\Collection\MemoryConverter.cs (4)
9internal sealed class MemoryConverter<T> : JsonCollectionConverter<Memory<T>, T> 19out Memory<T> value) 43Memory<T> memory = ((List<T>)state.Current.ReturnValue!).ToArray().AsMemory(); 47protected override bool OnWriteResume(Utf8JsonWriter writer, Memory<T> value, JsonSerializerOptions options, ref WriteStack state)
System\Text\Json\Serialization\Converters\Collection\MemoryConverterFactory.cs (2)
21return typeDef == typeof(Memory<>) || typeDef == typeof(ReadOnlyMemory<>); 28Type converterType = typeToConvert.GetGenericTypeDefinition() == typeof(Memory<>) ?
System\Text\Json\Serialization\Converters\Value\MemoryByteConverter.cs (3)
9internal sealed class MemoryByteConverter : JsonConverter<Memory<byte>> 13public override Memory<byte> Read(ref Utf8JsonReader reader, Type typeToConvert, JsonSerializerOptions options) 18public override void Write(Utf8JsonWriter writer, Memory<byte> value, JsonSerializerOptions options)
System\Text\Json\Serialization\Metadata\JsonMetadataServices.Collections.cs (3)
447/// Creates serialization metadata for <see cref="Memory{T}"/>. 454public static JsonTypeInfo<Memory<TElement>> CreateMemoryInfo<TElement>(JsonSerializerOptions options, JsonCollectionInfoValues<Memory<TElement>> collectionInfo)
System\Text\Json\Serialization\Metadata\JsonMetadataServices.Converters.cs (2)
153/// Returns a <see cref="JsonConverter{T}"/> instance that converts <see cref="Memory{Byte}"/> values. 156public static JsonConverter<Memory<byte>> MemoryByteConverter => field ??= new MemoryByteConverter();
System\Text\Json\Writer\Utf8JsonWriter.cs (1)
42private Memory<byte> _memory;
System.Text.Json.SourceGeneration (1)
Helpers\KnownTypeSymbols.cs (1)
310public INamedTypeSymbol? MemoryType => GetOrResolveType(typeof(Memory<>), ref _MemoryType);