ReadOnlySequence

PersistentState\PersistentValueProviderComponentSubscription.cs (1)

144var sequence = new ReadOnlySequence<byte>(data!);

src\aspnetcore\src\Components\Shared\src\ExpressionFormatting\ReverseStringBuilder.cs (1)

153var sequence = new ReadOnlySequence<char>(this, startIndex, tail, tail.Memory.Length);

BlazorPack\SequenceOfT.cs (1)

109? new ReadOnlySequence<T>(sequence.first, sequence.first.Start, sequence.last, sequence.last.End)

src\aspnetcore\src\submodules\MessagePack-CSharp\src\MessagePack.UnityClient\Assets\Scripts\MessagePack\ExtensionResult.cs (1)

19this.Data = new ReadOnlySequence<byte>(data);

src\aspnetcore\src\submodules\MessagePack-CSharp\src\MessagePack.UnityClient\Assets\Scripts\MessagePack\SequenceReader.cs (1)

116this.sequence = new ReadOnlySequence<T>(this.memory);

src\aspnetcore\src\Components\Shared\src\ExpressionFormatting\ReverseStringBuilder.cs (1)

153var sequence = new ReadOnlySequence<char>(this, startIndex, tail, tail.Memory.Length);

BufferingStream.cs (1)

64var ros = new ReadOnlySequence<byte>(_head, 0, _tail, _tailBytesBuffered);

OutputCacheEntryFormatter.cs (4)

49await bufferStore.SetAsync(key, new(buffer.GetCommittedMemory()), CopyToLeasedMemory(tags, out var lease), duration, cancellationToken); 319result.SetBody(new ReadOnlySequence<byte>(ReadSegment(ref reader)), recycleBuffers: false); // we're reusing the live payload buffers 329result.SetBody(new ReadOnlySequence<byte>(first, 0, last, last.Length), recycleBuffers: false); // we're reusing the live payload buffers 369result.SetBody(new(reader.ReadBytesMemory(payloadLength)), recycleBuffers: false); // we're reusing the live payload buffers

RecyclableReadOnlySequenceSegment.cs (2)

91return new(segments[0]); 98return new(first, 0, last, last.Length);

RecyclableSequenceBuilder.cs (2)

44return new(memory); 48var payload = new ReadOnlySequence<byte>(_firstSegment, 0, _currentSegment!, _currentSegmentIndex);

Internal\Http\Http1ContentLengthMessageBody.cs (1)

222_readResult = new ReadResult(new ReadOnlySequence<byte>(), isCanceled: false, isCompleted: true);

Internal\Http2\Http2KeepAlive.cs (1)

24internal static readonly ReadOnlySequence<byte> PingPayload = new ReadOnlySequence<byte>(new byte[8]);

Protocol\RawResult.cs (1)

30RawSerializedData = new ReadOnlySequence<byte>(rawBytes.ToArray());

Protocol\NewtonsoftJsonHubProtocol.cs (1)

947return new RawResult(new ReadOnlySequence<byte>(strm.ToArray()));

Internal\RedisProtocol.cs (1)

272return new RedisCompletion(protocolName, ros ?? new ReadOnlySequence<byte>());

Internal\BufferChunk.cs (1)

92internal ReadOnlySequence<byte> AsSequence() => Length == 0 ? default : new ReadOnlySequence<byte>(OversizedArray!, Offset, Length);

Internal\DefaultHybridCache.StampedeStateT.cs (1)

449immutable.SetValue(serializer.Deserialize(new(value.OversizedArray!, value.Offset, value.Length)), value.Length);

Internal\RecyclableArrayBufferWriter.cs (1)

134public ReadOnlySequence<T> AsSequence() => new(_buffer, 0, _index);

DistributedCacheTests.cs (4)

286payload = new(arr); 291payload = new(arr, 5, arr.Length - 10); 295payload = new(mem); 312payload = new(first, 7, third, 4);

SerializerTests.cs (1)

316var result = new ReadOnlySequence<byte>(first, 0, second, chunk.Length - 1);

RedisCache.cs (2)

156=> SetImpl(key, new(value), options); 203=> SetImplAsync(key, new(value), options, token);

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

973var readOnlySequence = new ReadOnlySequence<byte>(head, _readHeadIndex, _readTail, _readTailIndex);

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

486return _readHead is null ? default : new ReadOnlySequence<byte>(_readHead, _readIndex, _readTail!, _readTail!.End);

System\Buffers\ReadOnlySequence.cs (1)

26public static readonly ReadOnlySequence<T> Empty = new ReadOnlySequence<T>(Array.Empty<T>());

System\Buffers\ReadOnlySequence.Helpers.cs (2)

473return new ReadOnlySequence<T>( 488return new ReadOnlySequence<T>(

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

55public readonly ReadOnlySequence<byte> Bytes => new(_buffer.AsMemory(_offset, _count));

Otlp\Http\OtlpHttpEndpointsBuilder.cs (1)

250Func<ReadOnlySequence<byte>, T> exporter)

Dcp\DcpHost.cs (1)

387void LogLines(in ReadOnlySequence<byte> buffer, out SequencePosition position)

IPersistentComponentStateSerializer.cs (1)

11object Restore(Type type, ReadOnlySequence<byte> data);

PersistentState\PersistentComponentStateSerializer.cs (2)

27public abstract T Restore(ReadOnlySequence<byte> data); 38object IPersistentComponentStateSerializer.Restore(Type type, ReadOnlySequence<byte> data)

PersistentState\PersistentValueProviderComponentSubscription.cs (1)

144var sequence = new ReadOnlySequence<byte>(data!);

src\aspnetcore\src\Components\Shared\src\ExpressionFormatting\ReverseStringBuilder.cs (1)

153var sequence = new ReadOnlySequence<char>(this, startIndex, tail, tail.Memory.Length);

BlazorPack\BlazorPackHubProtocol.cs (1)

39public bool TryParseMessage(ref ReadOnlySequence<byte> input, IInvocationBinder binder, out HubMessage message)

BlazorPack\SequenceOfT.cs (9)

14/// Manages a sequence of elements, readily castable as a <see cref="ReadOnlySequence{T}"/>. 87/// Gets this sequence expressed as a <see cref="ReadOnlySequence{T}"/>. 90public ReadOnlySequence<T> AsReadOnlySequence => this; 103/// Expresses this sequence as a <see cref="ReadOnlySequence{T}"/>. 106public static implicit operator ReadOnlySequence<T>(Sequence<T> sequence) 110: ReadOnlySequence<T>.Empty; 119/// This is typically <see cref="ReadOnlySequence{T}.End"/> after reading all elements from that instance. 189/// This invalidates any <see cref="ReadOnlySequence{T}"/> previously produced by this instance. 196/// This invalidates any <see cref="ReadOnlySequence{T}"/> previously produced by this instance.

src\aspnetcore\src\SignalR\common\Protocols.MessagePack\src\Protocol\MessagePackHubProtocolWorker.cs (2)

28public bool TryParseMessage(ref ReadOnlySequence<byte> input, IInvocationBinder binder, [NotNullWhen(true)] out HubMessage? message) 30if (!BinaryMessageParser.TryParseMessage(ref input, out var payload))

src\aspnetcore\src\SignalR\common\Shared\BinaryMessageParser.cs (4)

13public static bool TryParseMessage(ref ReadOnlySequence<byte> buffer, out ReadOnlySequence<byte> payload) 36var lengthPrefixBuffer = buffer.Slice(0, Math.Min(MaxLengthPrefixSize, buffer.Length)); 75private static ReadOnlySpan<byte> GetSpan(in ReadOnlySequence<byte> lengthPrefixBuffer)

src\aspnetcore\src\submodules\MessagePack-CSharp\src\MessagePack.UnityClient\Assets\Scripts\MessagePack\ExtensionResult.cs (2)

22public ExtensionResult(sbyte typeCode, ReadOnlySequence<byte> data) 30public ReadOnlySequence<byte> Data { get; private set; }

src\aspnetcore\src\submodules\MessagePack-CSharp\src\MessagePack.UnityClient\Assets\Scripts\MessagePack\MessagePackReader.cs (13)

src\aspnetcore\src\submodules\MessagePack-CSharp\src\MessagePack.UnityClient\Assets\Scripts\MessagePack\MessagePackWriter.cs (7)

104public void WriteRaw(in ReadOnlySequence<byte> rawMessagePackBlock) 761public void Write(in ReadOnlySequence<byte> src) 779/// The caller should use <see cref="WriteRaw(in ReadOnlySequence{byte})"/> or <see cref="WriteRaw(ReadOnlySpan{byte})"/> 781/// Alternatively a single call to <see cref="Write(ReadOnlySpan{byte})"/> or <see cref="Write(in ReadOnlySequence{byte})"/> will take care of the header and content in one call. 837public void WriteString(in ReadOnlySequence<byte> utf8stringBytes) 872/// The caller should use <see cref="WriteRaw(in ReadOnlySequence{byte})"/> or <see cref="WriteRaw(ReadOnlySpan{byte})"/> 874/// Alternatively a single call to <see cref="WriteString(ReadOnlySpan{byte})"/> or <see cref="WriteString(in ReadOnlySequence{byte})"/> will take care of the header and content in one call.

src\aspnetcore\src\submodules\MessagePack-CSharp\src\MessagePack.UnityClient\Assets\Scripts\MessagePack\SequenceReader.cs (5)

26private ReadOnlySequence<T> sequence; 55/// over the given <see cref="ReadOnlySequence{T}"/>. 58public SequenceReader(in ReadOnlySequence<T> sequence) 106/// Gets the underlying <see cref="ReadOnlySequence{T}"/> for the reader. 108public ReadOnlySequence<T> Sequence

src\aspnetcore\src\Components\Shared\src\ExpressionFormatting\ReverseStringBuilder.cs (1)

153var sequence = new ReadOnlySequence<char>(this, startIndex, tail, tail.Memory.Length);

Internal\Transports\LongPollingServerTransport.cs (1)

37var buffer = result.Buffer;

Internal\Transports\ServerSentEventsServerTransport.cs (1)

52var buffer = result.Buffer;

Internal\Transports\WebSocketsServerTransport.cs (1)

209var buffer = result.Buffer;

ServerSentEventsMessageFormatter.cs (5)

15public static async Task WriteMessageAsync(ReadOnlySequence<byte> payload, Stream output, CancellationToken token) 46private static ReadOnlyMemory<byte> GetLastSegment(in ReadOnlySequence<byte> source, out long offset) 66private static async Task WriteMessageToMemory(Stream output, ReadOnlySequence<byte> payload) 73ReadOnlySequence<byte> lineSegment; 77payload = ReadOnlySequence<byte>.Empty;

src\aspnetcore\src\SignalR\common\Shared\StreamExtensions.cs (2)

14public static ValueTask WriteAsync(this Stream stream, ReadOnlySequence<byte> buffer, CancellationToken cancellationToken = default) 31private static async ValueTask WriteMultiSegmentAsync(Stream stream, ReadOnlySequence<byte> buffer, CancellationToken cancellationToken)

src\aspnetcore\src\SignalR\common\Shared\WebSocketExtensions.cs (2)

14public static ValueTask SendAsync(this WebSocket webSocket, ReadOnlySequence<byte> buffer, WebSocketMessageType webSocketMessageType, CancellationToken cancellationToken = default) 39private static async ValueTask SendMultiSegmentAsync(WebSocket webSocket, ReadOnlySequence<byte> buffer, WebSocketMessageType webSocketMessageType, CancellationToken cancellationToken = default)

Internal\SendUtils.cs (3)

28var buffer = result.Buffer; 93private readonly ReadOnlySequence<byte> _buffer; 95public ReadOnlySequenceContent(in ReadOnlySequence<byte> buffer)

Internal\WebSocketsTransport.cs (1)

541var buffer = result.Buffer;

src\aspnetcore\src\SignalR\common\Shared\StreamExtensions.cs (2)

14public static ValueTask WriteAsync(this Stream stream, ReadOnlySequence<byte> buffer, CancellationToken cancellationToken = default) 31private static async ValueTask WriteMultiSegmentAsync(Stream stream, ReadOnlySequence<byte> buffer, CancellationToken cancellationToken)

src\aspnetcore\src\SignalR\common\Shared\WebSocketExtensions.cs (2)

14public static ValueTask SendAsync(this WebSocket webSocket, ReadOnlySequence<byte> buffer, WebSocketMessageType webSocketMessageType, CancellationToken cancellationToken = default) 39private static async ValueTask SendMultiSegmentAsync(WebSocket webSocket, ReadOnlySequence<byte> buffer, WebSocketMessageType webSocketMessageType, CancellationToken cancellationToken = default)

BufferingStream.cs (2)

64var ros = new ReadOnlySequence<byte>(_head, 0, _tail, _tailBytesBuffered); 89EncodingExtensions.Convert(decoder, ReadOnlySequence<byte>.Empty, bufferWriter, flush: true, out charUsed, out completed);

IOutputCacheBufferStore.cs (1)

32ValueTask SetAsync(string key, ReadOnlySequence<byte> value, ReadOnlyMemory<string> tags, TimeSpan validFor, CancellationToken cancellationToken);

OutputCacheEntry.cs (2)

62public ReadOnlySequence<byte> Body { get; private set; } 66internal void SetBody(ReadOnlySequence<byte> value, bool recycleBuffers)

OutputCacheEntryFormatter.cs (1)

166var body = entry.Body;

OutputCacheMiddleware.cs (2)

311var body = context.CachedResponse.Body; 426var cachedResponseBody = context.OutputCacheStream.GetCachedResponseBody();

RecyclableReadOnlySequenceSegment.cs (3)

62public static void RecycleChain(in ReadOnlySequence<byte> value, bool recycleBuffers = false) 79internal static ReadOnlySequence<byte> CreateSequence(IList<byte[]> segments) 102public static async ValueTask CopyToAsync(ReadOnlySequence<byte> source, PipeWriter destination, CancellationToken cancellationToken)

RecyclableSequenceBuilder.cs (2)

28internal ReadOnlySequence<byte> DetachAndReset() 48var payload = new ReadOnlySequence<byte>(_firstSegment, 0, _currentSegment!, _currentSegmentIndex);

Streams\OutputCacheStream.cs (1)

45internal ReadOnlySequence<byte> GetCachedResponseBody()

Core\IISHttpContext.IO.cs (2)

31var readableBuffer = result.Buffer; 165var buffer = result.Buffer;

Core\IO\AsyncIOEngine.cs (4)

39public ValueTask<int> WriteAsync(ReadOnlySequence<byte> data) 49private ValueTask<int> WriteDataAsync(in ReadOnlySequence<byte> data) 63private async ValueTask<int> WriteDataOverChunksLimit(ReadOnlySequence<byte> data) 95private static bool SegmentsOverChunksLimit(in ReadOnlySequence<byte> data)

Core\IO\AsyncWriteOperationBase.cs (3)

15private ReadOnlySequence<byte> _buffer; 18public void Initialize(NativeSafeHandle requestHandler, ReadOnlySequence<byte> buffer) 97private unsafe int WriteSequence(NativeSafeHandle requestHandler, int nChunks, ReadOnlySequence<byte> buffer, HTTP_DATA_CHUNK* pDataChunks, out bool fCompletionExpected)

Core\IO\IAsyncIOEngine.cs (1)

11ValueTask<int> WriteAsync(ReadOnlySequence<byte> data);

Core\IO\WebSocketsAsyncIOEngine.cs (1)

45public ValueTask<int> WriteAsync(ReadOnlySequence<byte> data)

src\aspnetcore\src\Shared\ServerInfrastructure\BufferExtensions.cs (6)

22public static ReadOnlySpan<byte> ToSpan(in this ReadOnlySequence<byte> buffer) 32public static void CopyTo(in this ReadOnlySequence<byte> buffer, PipeWriter pipeWriter) 44private static void CopyToMultiSegment(in ReadOnlySequence<byte> buffer, PipeWriter pipeWriter) 67/// Returns position of first occurrence of item in the <see cref="ReadOnlySequence{T}"/> 70public static SequencePosition? PositionOfAny<T>(in this ReadOnlySequence<T> source, T value0, T value1) where T : IEquatable<T> 88private static SequencePosition? PositionOfAnyMultiSegment<T>(in ReadOnlySequence<T> source, T value0, T value1) where T : IEquatable<T>

src\aspnetcore\src\Shared\ServerInfrastructure\DuplexPipeStream.cs (1)

123var readableBuffer = result.Buffer;

HttpsConnectionAdapterOptions.cs (3)

103/// If you want to store the bytes from the <see cref="ReadOnlySequence{T}"/>, 104/// copy them into a buffer that you control rather than keeping a reference to the <see cref="ReadOnlySequence{T}"/> or <see cref="ReadOnlyMemory{T}"/> instances. 111public Action<ConnectionContext, ReadOnlySequence<byte>>? TlsClientHelloBytesCallback { get; set; }

Internal\Http\Http1ChunkedEncodingMessageBody.cs (10)

116var readableBuffer = result.Buffer; 205private bool Read(ReadOnlySequence<byte> readableBuffer, PipeWriter writableBuffer, out SequencePosition consumed, out SequencePosition examined) 294private void ParseChunkedPrefix(in ReadOnlySequence<byte> buffer, out SequencePosition consumed, out SequencePosition examined) 360private void ParseExtension(ReadOnlySequence<byte> buffer, out SequencePosition consumed, out SequencePosition examined) 389var suffixBuffer = buffer.Slice(extensionCursor); 431private void ReadChunkedData(in ReadOnlySequence<byte> buffer, PipeWriter writableBuffer, out SequencePosition consumed, out SequencePosition examined) 448private void ParseChunkedSuffix(in ReadOnlySequence<byte> buffer, out SequencePosition consumed, out SequencePosition examined) 458var suffixBuffer = buffer.Slice(0, 2); 476private void ParseChunkedTrailer(in ReadOnlySequence<byte> buffer, out SequencePosition consumed, out SequencePosition examined) 486var trailerBuffer = buffer.Slice(0, 2);

Internal\Http\Http1Connection.cs (10)

207var trimmedBuffer = reader.Sequence.Slice(reader.Position, ServerOptions.Limits.MaxRequestLineSize); 249var trimmedBuffer = reader.Sequence.Slice(reader.Position, _remainingRequestHeadersBytesAllowed); 337var trimmedBuffer = reader.Sequence.Slice(reader.Position, ServerOptions.Limits.MaxRequestLineSize); 375var trimmedBuffer = reader.Sequence.Slice(reader.Position, _remainingRequestHeadersBytesAllowed); 1015private void HandleBadRequest(ReadOnlySequence<byte> requestData, BadHttpRequestException ex) 1024private void HandleBadRequest(ReadOnlySequence<byte> requestData, RequestRejectionReason reason) 1035private BadHttpRequestException CreateBadRequestException(HttpParseResult parseResult, ReadOnlySequence<byte> buffer) 1049var errorSlice = buffer.Slice(parseResult.ErrorOffset, parseResult.ErrorLength); 1060private void OnBadRequest(ReadOnlySequence<byte> requestData, BadHttpRequestException ex) 1075private void DetectHttp2Preface(ReadOnlySequence<byte> requestData)

Internal\Http\Http1ContentLengthMessageBody.cs (1)

217var buffer = _readResult.Buffer.Slice(consumed, _readResult.Buffer.End);

Internal\Http\HttpParser.cs (5)

133var currentSlice = reader.UnreadSequence; 192ReadOnlySequence<byte> header; 380private void ThrowParseError(HttpParseResult result, ReadOnlySequence<byte> buffer) 394var errorSlice = buffer.Slice(result.ErrorOffset, result.ErrorLength); 579reader.TryReadExact(requestLine.Length + 1, out var requestLineSequence);

Internal\Http\HttpRequestStream.cs (2)

126var buffer = result.Buffer; 136var slice = actual == length ? buffer : buffer.Slice(0, actual);

Internal\Http2\Http2Connection.cs (17)

Internal\Http2\Http2FrameWriter.cs (8)

193var buffer = readResult.Buffer; 563private ValueTask<FlushResult> WriteDataAndTrailersAsync(Http2Stream stream, in ReadOnlySequence<byte> data, bool writeHeaders, HttpResponseTrailers headers) 715private void WriteDataUnsynchronized(int streamId, in ReadOnlySequence<byte> data, long dataLength, bool endStream) 742void TrimAndWriteDataUnsynchronized(in ReadOnlySequence<byte> data, long dataLength, bool endStream) 750var remainingData = data; 753var currentData = remainingData.Slice(0, dataPayloadLength); 781private ValueTask<FlushResult> WriteDataAsync(Http2Stream stream, ReadOnlySequence<byte> data, long dataLength, bool endStream, bool writeHeaders) 957public ValueTask<FlushResult> WritePingAsync(Http2PingFrameFlags flags, in ReadOnlySequence<byte> payload)

Internal\Http2\Http2KeepAlive.cs (1)

24internal static readonly ReadOnlySequence<byte> PingPayload = new ReadOnlySequence<byte>(new byte[8]);

Internal\Http2\Http2Stream.cs (2)

463public Task OnDataAsync(Http2Frame dataFrame, in ReadOnlySequence<byte> payload) 472var dataPayload = payload.Slice(0, dataFrame.DataPayloadLength); // minus padding

Internal\Http3\Http3ControlStream.cs (9)

161var readableBuffer = result.Buffer; 264var readableBuffer = result.Buffer; 273while (Http3FrameReader.TryReadFrame(ref readableBuffer, incomingFrame, isContinuedFrame, out var framePayload)) 324private ValueTask ProcessHttp3ControlStream(Http3RawFrame incomingFrame, bool isContinuedFrame, in ReadOnlySequence<byte> payload, out SequencePosition consumed) 360private ValueTask ProcessSettingsFrameAsync(bool isContinuedFrame, ReadOnlySequence<byte> payload, out SequencePosition consumed) 422private ValueTask ProcessGoAwayFrameAsync(bool isContinuedFrame, Http3RawFrame incomingFrame, ReadOnlySequence<byte> payload, out SequencePosition consumed) 444private ValueTask ProcessCancelPushFrameAsync(Http3RawFrame incomingFrame, ReadOnlySequence<byte> payload, out SequencePosition consumed) 456private ValueTask ProcessMaxPushIdFrameAsync(Http3RawFrame incomingFrame, ReadOnlySequence<byte> payload, out SequencePosition consumed) 479private static void ParseVarIntWithFrameLengthValidation(Http3RawFrame incomingFrame, ReadOnlySequence<byte> payload, out SequencePosition consumed)

Internal\Http3\Http3FrameReader.cs (5)

24internal static bool TryReadFrame(ref ReadOnlySequence<byte> readableBuffer, Http3RawFrame frame, bool isContinuedFrame, out ReadOnlySequence<byte> framePayload) 26framePayload = ReadOnlySequence<byte>.Empty; 37var firstLengthBuffer = readableBuffer.Slice(consumed); 48var startOfFramePayload = readableBuffer.Slice(consumed);

Internal\Http3\Http3FrameWriter.cs (5)

160public ValueTask<FlushResult> WriteDataAsync(in ReadOnlySequence<byte> data) 177private void WriteDataUnsynchronized(in ReadOnlySequence<byte> data, long dataLength) 200void SplitAndWriteDataUnsynchronized(in ReadOnlySequence<byte> data, long dataLength) 208var remainingData = data; 211var currentData = remainingData.Slice(0, dataPayloadLength);

Internal\Http3\Http3PendingStream.cs (1)

57var readableBuffer = result.Buffer;

Internal\Http3\Http3Stream.cs (5)

644var readableBuffer = result.Buffer; 652while (Http3FrameReader.TryReadFrame(ref readableBuffer, incomingFrame, isContinuedFrame, out var framePayload)) 788in ReadOnlySequence<byte> payload, bool isCompleted) where TContext : notnull 816ReadOnlySequence<byte> payload, bool isCompleted) where TContext : notnull 927private Task ProcessDataFrameAsync(in ReadOnlySequence<byte> payload)

Internal\Http3\QPack\DecoderStreamReader.cs (1)

53public void Read(ReadOnlySequence<byte> data)

Internal\Http3\QPack\EncoderStreamReader.cs (1)

100public void Read(ReadOnlySequence<byte> data)

ListenOptionsHttpsExtensions.cs (1)

304public static ListenOptions UseTlsClientHelloListener(this ListenOptions listenOptions, Action<ConnectionContext, ReadOnlySequence<byte>> tlsClientHelloBytesCallback, TimeSpan? timeout = null)

Middleware\TlsListener.cs (6)

12private readonly Action<ConnectionContext, ReadOnlySequence<byte>> _tlsClientHelloBytesCallback; 14public TlsListener(Action<ConnectionContext, ReadOnlySequence<byte>> tlsClientHelloBytesCallback) 34var buffer = result.Buffer; 45parseState = TryParseClientHello(buffer, ref recordLength, out var clientHelloBytes); 88private static ClientHelloParseState TryParseClientHello(ReadOnlySequence<byte> buffer, ref short recordLength, out ReadOnlySequence<byte> clientHelloBytes)

src\aspnetcore\src\Shared\runtime\Http2\Hpack\HPackDecoder.cs (1)

126public void Decode(in ReadOnlySequence<byte> data, bool endHeaders, IHttpStreamHeadersHandler handler)

src\aspnetcore\src\Shared\runtime\Http3\Helpers\VariableLengthIntegerHelper.cs (1)

132public static bool TryGetInteger(in ReadOnlySequence<byte> buffer, out SequencePosition consumed, out long integer)

src\aspnetcore\src\Shared\runtime\Http3\QPack\QPackDecoder.cs (1)

166public void Decode(in ReadOnlySequence<byte> data, bool endHeaders, IHttpStreamHeadersHandler handler)

src\aspnetcore\src\Shared\ServerInfrastructure\BufferExtensions.cs (6)

22public static ReadOnlySpan<byte> ToSpan(in this ReadOnlySequence<byte> buffer) 32public static void CopyTo(in this ReadOnlySequence<byte> buffer, PipeWriter pipeWriter) 44private static void CopyToMultiSegment(in ReadOnlySequence<byte> buffer, PipeWriter pipeWriter) 67/// Returns position of first occurrence of item in the <see cref="ReadOnlySequence{T}"/> 70public static SequencePosition? PositionOfAny<T>(in this ReadOnlySequence<T> source, T value0, T value1) where T : IEquatable<T> 88private static SequencePosition? PositionOfAnyMultiSegment<T>(in ReadOnlySequence<T> source, T value0, T value1) where T : IEquatable<T>

src\aspnetcore\src\Shared\ServerInfrastructure\DuplexPipeStream.cs (1)

123var readableBuffer = result.Buffer;

src\aspnetcore\src\Shared\ServerInfrastructure\Http2\Http2FrameReader.cs (6)

39public static bool TryReadFrame(ref ReadOnlySequence<byte> buffer, Http2Frame frame, uint maxFrameSize, out ReadOnlySequence<byte> framePayload) 41framePayload = ReadOnlySequence<byte>.Empty; 48var headerSlice = buffer.Slice(0, HeaderLength); 78private static int ReadExtendedFields(Http2Frame frame, in ReadOnlySequence<byte> readableBuffer) 226public static IList<Http2PeerSetting> ReadSettings(in ReadOnlySequence<byte> payload)

Internal\QuicStreamContext.cs (1)

400var buffer = result.Buffer;

HubConnection.cs (2)

1696var buffer = result.Buffer; 1815var buffer = result.Buffer;

Protocol\HandshakeProtocol.cs (4)

116public static bool TryParseResponseMessage(ref ReadOnlySequence<byte> buffer, [NotNullWhen(true)] out HandshakeResponseMessage? responseMessage) 118if (!TextMessageParser.TryParseMessage(ref buffer, out var payload)) 170public static bool TryParseRequestMessage(ref ReadOnlySequence<byte> buffer, [NotNullWhen(true)] out HandshakeRequestMessage? requestMessage) 172if (!TextMessageParser.TryParseMessage(ref buffer, out var payload))

Protocol\IHubProtocol.cs (1)

38bool TryParseMessage(ref ReadOnlySequence<byte> input, IInvocationBinder binder, [NotNullWhen(true)] out HubMessage? message);

Protocol\RawResult.cs (2)

27public RawResult(ReadOnlySequence<byte> rawBytes) 36public ReadOnlySequence<byte> RawSerializedData { get; private set; }

src\aspnetcore\src\SignalR\common\Shared\TextMessageParser.cs (4)

13public static bool TryParseMessage(ref ReadOnlySequence<byte> buffer, out ReadOnlySequence<byte> payload) 37private static bool TryParseMessageMultiSegment(ref ReadOnlySequence<byte> buffer, out ReadOnlySequence<byte> payload)

src\aspnetcore\src\SignalR\common\Shared\Utf8BufferTextReader.cs (3)

15private ReadOnlySequence<byte> _utf8Buffer; 29public static Utf8BufferTextReader Get(in ReadOnlySequence<byte> utf8Buffer) 59public void SetBuffer(in ReadOnlySequence<byte> utf8Buffer)

HubConnectionContext.cs (2)

622var buffer = result.Buffer; 637var segment = buffer;

HubConnectionHandler.cs (2)

345var buffer = result.Buffer; 380var segment = buffer;

Protocol\JsonHubProtocol.cs (5)

89public bool TryParseMessage(ref ReadOnlySequence<byte> input, IInvocationBinder binder, [NotNullWhen(true)] out HubMessage? message) 91if (!TextMessageParser.TryParseMessage(ref input, out var payload)) 115private HubMessage? ParseMessage(ReadOnlySequence<byte> input, IInvocationBinder binder) 814private object? BindType(ref Utf8JsonReader reader, ReadOnlySequence<byte> input, Type type) 821var sequence = input.Slice(start, end - start);

src\aspnetcore\src\SignalR\common\Shared\TextMessageParser.cs (4)

13public static bool TryParseMessage(ref ReadOnlySequence<byte> buffer, out ReadOnlySequence<byte> payload) 37private static bool TryParseMessageMultiSegment(ref ReadOnlySequence<byte> buffer, out ReadOnlySequence<byte> payload)

src\aspnetcore\src\SignalR\common\Shared\Utf8BufferTextReader.cs (3)

15private ReadOnlySequence<byte> _utf8Buffer; 29public static Utf8BufferTextReader Get(in ReadOnlySequence<byte> utf8Buffer) 59public void SetBuffer(in ReadOnlySequence<byte> utf8Buffer)

Protocol\MessagePackHubProtocol.cs (1)

60public bool TryParseMessage(ref ReadOnlySequence<byte> input, IInvocationBinder binder, [NotNullWhen(true)] out HubMessage? message)

Protocol\MessagePackHubProtocolWorker.cs (2)

28public bool TryParseMessage(ref ReadOnlySequence<byte> input, IInvocationBinder binder, [NotNullWhen(true)] out HubMessage? message) 30if (!BinaryMessageParser.TryParseMessage(ref input, out var payload))

src\aspnetcore\src\SignalR\common\Shared\BinaryMessageParser.cs (4)

13public static bool TryParseMessage(ref ReadOnlySequence<byte> buffer, out ReadOnlySequence<byte> payload) 36var lengthPrefixBuffer = buffer.Slice(0, Math.Min(MaxLengthPrefixSize, buffer.Length)); 75private static ReadOnlySpan<byte> GetSpan(in ReadOnlySequence<byte> lengthPrefixBuffer)

Protocol\NewtonsoftJsonHubProtocol.cs (2)

79public bool TryParseMessage(ref ReadOnlySequence<byte> input, IInvocationBinder binder, [NotNullWhen(true)] out HubMessage? message) 81if (!TextMessageParser.TryParseMessage(ref input, out var payload))

src\aspnetcore\src\SignalR\common\Shared\TextMessageParser.cs (4)

13public static bool TryParseMessage(ref ReadOnlySequence<byte> buffer, out ReadOnlySequence<byte> payload) 37private static bool TryParseMessageMultiSegment(ref ReadOnlySequence<byte> buffer, out ReadOnlySequence<byte> payload)

src\aspnetcore\src\SignalR\common\Shared\Utf8BufferTextReader.cs (3)

15private ReadOnlySequence<byte> _utf8Buffer; 29public static Utf8BufferTextReader Get(in ReadOnlySequence<byte> utf8Buffer) 59public void SetBuffer(in ReadOnlySequence<byte> utf8Buffer)

src\aspnetcore\src\SignalR\common\testassets\Tests.Utils\TestClient.cs (2)

249var buffer = result.Buffer; 282var buffer = result.Buffer;

Internal\RedisCompletion.cs (2)

10public ReadOnlySequence<byte> CompletionMessage { get; } 14public RedisCompletion(string protocolName, ReadOnlySequence<byte> completionMessage)

RedisHubLifetimeManager.cs (1)

666var ros = completion.CompletionMessage;

ResponseBodyReaderStream.cs (1)

101var readableBuffer = result.Buffer;

FormPipeReader.cs (7)

98var buffer = readResult.Buffer; 132ref ReadOnlySequence<byte> buffer, 235ref ReadOnlySequence<byte> buffer, 240ReadOnlySequence<byte> keyValuePair; 276ReadOnlySequence<byte> value; 278if (keyValueReader.TryReadTo(out ReadOnlySequence<byte> key, equalsDelimiter)) 345private string GetDecodedStringFromReadOnlySequence(in ReadOnlySequence<byte> ros)

Hybrid\IHybridCacheSerializer.cs (1)

17T Deserialize(ReadOnlySequence<byte> source);

IBufferDistributedCache.cs (2)

41void Set(string key, ReadOnlySequence<byte> value, DistributedCacheEntryOptions options); 51ValueTask SetAsync(string key, ReadOnlySequence<byte> value, DistributedCacheEntryOptions options, CancellationToken token = default);

Internal\BufferChunk.cs (1)

92internal ReadOnlySequence<byte> AsSequence() => Length == 0 ? default : new ReadOnlySequence<byte>(OversizedArray!, Offset, Length);

Internal\DefaultJsonSerializerFactory.cs (1)

148T IHybridCacheSerializer<T>.Deserialize(ReadOnlySequence<byte> source)

Internal\HybridCachePayload.cs (1)

102string key, long creationTime, TimeSpan duration, PayloadFlags flags, TagSet tags, ReadOnlySequence<byte> payload)

Internal\InbuiltTypeSerializer.cs (3)

19string IHybridCacheSerializer<string>.Deserialize(ReadOnlySequence<byte> source) 25byte[] IHybridCacheSerializer<byte[]>.Deserialize(ReadOnlySequence<byte> source) 31internal static string DeserializeString(ReadOnlySequence<byte> source)

Internal\RecyclableArrayBufferWriter.cs (1)

134public ReadOnlySequence<T> AsSequence() => new(_buffer, 0, _index);

BufferReleaseTests.cs (2)

92void IBufferDistributedCache.Set(string key, ReadOnlySequence<byte> value, DistributedCacheEntryOptions options) 95ValueTask IBufferDistributedCache.SetAsync(string key, ReadOnlySequence<byte> value, DistributedCacheEntryOptions options, CancellationToken token)

DistributedCacheTests.cs (4)

182var payload = Invent(size, kind); 244var payload = Invent(size, kind); 277private static ReadOnlySequence<byte> Invent(int size, SequenceKind kind) 280ReadOnlySequence<byte> payload;

L2Tests.cs (2)

165void IBufferDistributedCache.Set(string key, ReadOnlySequence<byte> value, DistributedCacheEntryOptions options) 172ValueTask IBufferDistributedCache.SetAsync(string key, ReadOnlySequence<byte> value, DistributedCacheEntryOptions options, CancellationToken token)

SerializerTests.cs (3)

303private static ReadOnlySequence<byte> Split(ReadOnlySequence<byte> value) 316var result = new ReadOnlySequence<byte>(first, 0, second, chunk.Length - 1);

ServiceConstructionTests.cs (1)

671Customer IHybridCacheSerializer<Customer>.Deserialize(ReadOnlySequence<byte> source) => throw new NotSupportedException();

SizeTests.cs (2)

288public MutablePoco Deserialize(ReadOnlySequence<byte> source) 331public ImmutablePoco Deserialize(ReadOnlySequence<byte> source)

SqlServerCache.cs (3)

182void IBufferDistributedCache.Set(string key, ReadOnlySequence<byte> value, DistributedCacheEntryOptions options) 217ReadOnlySequence<byte> value, 234private static ArraySegment<byte> Linearize(in ReadOnlySequence<byte> value, out byte[]? lease)

RedisCache.cs (5)

131private static ReadOnlyMemory<byte> Linearize(in ReadOnlySequence<byte> value, out byte[]? lease) 158void IBufferDistributedCache.Set(string key, ReadOnlySequence<byte> value, DistributedCacheEntryOptions options) 161private void SetImpl(string key, ReadOnlySequence<byte> value, DistributedCacheEntryOptions options) 205ValueTask IBufferDistributedCache.SetAsync(string key, ReadOnlySequence<byte> value, DistributedCacheEntryOptions options, CancellationToken token) 208private async Task SetImplAsync(string key, ReadOnlySequence<byte> value, DistributedCacheEntryOptions options, CancellationToken token = default)

mscorlib.cs (1)

43[assembly:System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Buffers.ReadOnlySequence<>))]

netstandard.cs (1)

70[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Buffers.ReadOnlySequence<>))]

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

973var readOnlySequence = new ReadOnlySequence<byte>(head, _readHeadIndex, _readTail, _readTailIndex);

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

71ReadOnlySequence<byte> buffer = result.Buffer; 164/// Creates a <see cref="PipeReader"/> wrapping the specified <see cref="ReadOnlySequence{T}"/>. 167/// <returns>A <see cref="PipeReader"/> that wraps the <see cref="ReadOnlySequence{T}"/>.</returns> 168public static PipeReader Create(ReadOnlySequence<byte> sequence) 237ReadOnlySequence<byte> buffer = result.Buffer;

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

118ReadOnlySequence<byte> sequence = result.Buffer; 128ReadOnlySequence<byte> slice = actual == bufferLength ? sequence : sequence.Slice(0, actual);

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

11internal readonly ReadOnlySequence<byte> _resultBuffer; 18public ReadResult(ReadOnlySequence<byte> buffer, bool isCanceled, bool isCompleted) 33/// <summary>Gets the <see cref="System.Buffers.ReadOnlySequence{T}" /> that was read.</summary> 35public ReadOnlySequence<byte> Buffer => _resultBuffer;

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

12private ReadOnlySequence<byte> _sequence; 17public SequencePipeReader(ReadOnlySequence<byte> sequence) 36_sequence = ReadOnlySequence<byte>.Empty; 58_sequence = ReadOnlySequence<byte>.Empty; 69result = new ReadResult(ReadOnlySequence<byte>.Empty, isCanceled: false, isCompleted: true);

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

473ReadOnlySequence<byte> buffer = GetCurrentReadOnlySequence(); 483private ReadOnlySequence<byte> GetCurrentReadOnlySequence()

System\Buffers\BuffersExtensions.cs (10)

9/// Extension methods for <see cref="ReadOnlySequence{T}"/> 14/// Returns position of first occurrence of item in the <see cref="ReadOnlySequence{T}"/> 17public static SequencePosition? PositionOf<T>(in this ReadOnlySequence<T> source, T value) where T : IEquatable<T>? 35private static SequencePosition? PositionOfMultiSegment<T>(in ReadOnlySequence<T> source, T value) where T : IEquatable<T>? 58/// Copy the <see cref="ReadOnlySequence{T}"/> to the specified <see cref="Span{Byte}"/>. 60/// <param name="source">The source <see cref="ReadOnlySequence{T}"/>.</param> 63public static void CopyTo<T>(in this ReadOnlySequence<T> source, Span<T> destination) 78private static void CopyToMultiSegment<T>(in ReadOnlySequence<T> sequence, Span<T> destination) 100/// Converts the <see cref="ReadOnlySequence{T}"/> to an array 102public static T[] ToArray<T>(in this ReadOnlySequence<T> sequence)

System\Buffers\ReadOnlySequence.cs (43)

System\Buffers\ReadOnlySequence.Helpers.cs (2)

467private ReadOnlySequence<T> SliceImpl(in SequencePosition start, in SequencePosition end) 482private ReadOnlySequence<T> SliceImpl(in SequencePosition start)

System\Buffers\ReadOnlySequenceDebugView.cs (1)

14public ReadOnlySequenceDebugView(ReadOnlySequence<T> sequence)

System\Buffers\ReadOnlySequenceStream.cs (8)

11/// Provides a seekable, read-only <see cref="Stream"/> over a <see cref="ReadOnlySequence{Byte}"/>. 19private ReadOnlySequence<byte> _sequence; 26/// Initializes a new instance of the <see cref="ReadOnlySequenceStream"/> class over the specified <see cref="ReadOnlySequence{Byte}"/>. 28/// <param name="source">The <see cref="ReadOnlySequence{Byte}"/> to wrap.</param> 29public ReadOnlySequenceStream(ReadOnlySequence<byte> source) 105ReadOnlySequence<byte> remaining = _sequence.Slice(_position); 167ReadOnlySequence<byte> remaining = _sequence.Slice(_position); 198ReadOnlySequence<byte> remaining = _sequence.Slice(_position);

System\Buffers\SequenceReader.cs (5)

17/// Create a <see cref="SequenceReader{T}"/> over the given <see cref="ReadOnlySequence{T}"/>. 20public SequenceReader(ReadOnlySequence<T> sequence) 45/// The underlying <see cref="ReadOnlySequence{T}"/> for the reader. 47public ReadOnlySequence<T> Sequence { get; } 55public readonly ReadOnlySequence<T> UnreadSequence => Sequence.Slice(Position);

System\Buffers\SequenceReader.Search.cs (12)

System\Runtime\InteropServices\SequenceMarshal.cs (9)

10/// Provides a collection of methods for interoperating with <see cref="ReadOnlySequence{T}"/> 15/// Get <see cref="ReadOnlySequenceSegment{T}"/> from the underlying <see cref="ReadOnlySequence{T}"/>. 18public static bool TryGetReadOnlySequenceSegment<T>(ReadOnlySequence<T> sequence, 28/// Get an array segment from the underlying <see cref="ReadOnlySequence{T}"/>. 31public static bool TryGetArray<T>(ReadOnlySequence<T> sequence, out ArraySegment<T> segment) 37/// Get <see cref="ReadOnlyMemory{T}"/> from the underlying <see cref="ReadOnlySequence{T}"/>. 40public static bool TryGetReadOnlyMemory<T>(ReadOnlySequence<T> sequence, out ReadOnlyMemory<T> memory) 53/// Get <see cref="string"/> from the underlying <see cref="ReadOnlySequence{T}"/>. 56internal static bool TryGetString(ReadOnlySequence<char> sequence, [NotNullWhen(true)] out string? text, out int start, out int length)

System\SequencePosition.cs (2)

41/// <see cref="SequencePosition"/> equality does not guarantee that they point to the same location in <see cref="System.Buffers.ReadOnlySequence{T}" /> 47/// <see cref="SequencePosition"/> equality does not guarantee that they point to the same location in <see cref="System.Buffers.ReadOnlySequence{T}" />

System\Text\EncodingExtensions.cs (28)

src\runtime\src\libraries\Common\src\System\Net\Http\aspnetcore\Http2\Hpack\HPackDecoder.cs (1)

126public void Decode(in ReadOnlySequence<byte> data, bool endHeaders, IHttpStreamHeadersHandler handler)

src\runtime\src\libraries\Common\src\System\Net\Http\aspnetcore\Http3\Helpers\VariableLengthIntegerHelper.cs (1)

132public static bool TryGetInteger(in ReadOnlySequence<byte> buffer, out SequencePosition consumed, out long integer)

src\runtime\src\libraries\Common\src\System\Net\Http\aspnetcore\Http3\QPack\QPackDecoder.cs (1)

166public void Decode(in ReadOnlySequence<byte> data, bool endHeaders, IHttpStreamHeadersHandler handler)

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

57/// The <see cref="ReadOnlySequence{T}"/> may be used for the entire lifetime of the 77public static JsonDocument Parse(ReadOnlySequence<byte> utf8Json, JsonDocumentOptions options = default) 460ReadOnlySequence<byte> valueSequence = default; 515ReadOnlySequence<byte> sequence = reader.OriginalSequence; 572ReadOnlySequence<byte> sequence = reader.OriginalSequence;

System\Text\Json\Reader\JsonReaderHelper.Unescaping.cs (1)

121public static unsafe bool UnescapeAndCompare(ReadOnlySequence<byte> utf8Source, ReadOnlySpan<byte> other)

System\Text\Json\Reader\Utf8JsonReader.cs (6)

47private readonly ReadOnlySequence<byte> _sequence; 51internal readonly ReadOnlySequence<byte> OriginalSequence => _sequence; 160public ReadOnlySequence<byte> ValueSequence { get; private set; } 247ValueSequence = ReadOnlySequence<byte>.Empty; 583ReadOnlySequence<byte> localSequence = ValueSequence; 636ReadOnlySequence<byte> localSequence = ValueSequence;

System\Text\Json\Reader\Utf8JsonReader.MultiSegment.cs (4)

24public Utf8JsonReader(ReadOnlySequence<byte> jsonData, bool isFinalBlock, JsonReaderState state) 54ValueSequence = ReadOnlySequence<byte>.Empty; 115public Utf8JsonReader(ReadOnlySequence<byte> jsonData, JsonReaderOptions options = default) 2201ReadOnlySequence<byte> commentSequence = _sequence.Slice(start, end);

System\Text\Json\Reader\Utf8JsonReader.TryGet.cs (3)

98ReadOnlySequence<byte> valueSequence = ValueSequence; 168ReadOnlySequence<byte> valueSequence = ValueSequence; 205ReadOnlySequence<byte> valueSequence = ValueSequence;

System\Text\Json\Serialization\Converters\Object\ObjectWithParameterizedConstructorConverter.cs (1)

57ReadOnlySequence<byte> originalSequence = reader.OriginalSequence;

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

17public abstract ReadOnlySequence<byte> Bytes { get; }

System\Text\Json\Serialization\JsonSerializer.Read.Utf8JsonReader.cs (3)

326ReadOnlySequence<byte> valueSequence = default; 371ReadOnlySequence<byte> sequence = reader.OriginalSequence; 410ReadOnlySequence<byte> originalSequence = reader.OriginalSequence;

System\Text\Json\Serialization\PipeReadBufferState.cs (7)

18private ReadOnlySequence<byte> _sequence = ReadOnlySequence<byte>.Empty; 31public readonly ReadOnlySequence<byte> Bytes => _sequence; 45_sequence = ReadOnlySequence<byte>.Empty; 55Debug.Assert(_sequence.Equals(ReadOnlySequence<byte>.Empty), "ReadAsync should only be called when the buffer is empty."); 141if (_sequence.Equals(ReadOnlySequence<byte>.Empty)) 150_sequence = ReadOnlySequence<byte>.Empty;

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

55public readonly ReadOnlySequence<byte> Bytes => new(_buffer.AsMemory(_offset, _count));

System\Text\Json\Writer\Utf8JsonWriter.WriteValues.Raw.cs (1)

134public void WriteRawValue(ReadOnlySequence<byte> utf8Json, bool skipInputValidation = false)