ReadOnlySequence

src\Shared\Http2cat\Http2Utilities.cs (1)

1000public ReadOnlySequence<byte> PayloadSequence => new ReadOnlySequence<byte>(Payload);

src\Shared\Http2cat\Http2Utilities.cs (1)

1000public ReadOnlySequence<byte> PayloadSequence => new ReadOnlySequence<byte>(Payload);

src\Shared\Http2cat\Http2Utilities.cs (1)

1000public ReadOnlySequence<byte> PayloadSequence => new ReadOnlySequence<byte>(Payload);

src\Shared\Http2cat\Http2Utilities.cs (1)

1000public ReadOnlySequence<byte> PayloadSequence => new ReadOnlySequence<byte>(Payload);

src\Shared\Http2cat\Http2Utilities.cs (1)

1000public ReadOnlySequence<byte> PayloadSequence => new ReadOnlySequence<byte>(Payload);

src\Shared\Http2cat\Http2Utilities.cs (1)

1000public ReadOnlySequence<byte> PayloadSequence => new ReadOnlySequence<byte>(Payload);

Http2\Http2TestBase.cs (1)

1450public ReadOnlySequence<byte> PayloadSequence => new ReadOnlySequence<byte>(Payload);

Http3\WebTransport\WebTransportTestUtilities.cs (2)

194new ReadOnlySequence<byte>((ReadOnlyMemory<byte>)_sharedMemory), false, true)); 199result = new ReadResult(new ReadOnlySequence<byte>((ReadOnlyMemory<byte>)_sharedMemory), false, true);

src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (1)

812public ReadOnlySequence<byte> PayloadSequence => new ReadOnlySequence<byte>(Payload);

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\submodules\MessagePack-CSharp\src\MessagePack.UnityClient\Assets\Scripts\MessagePack\ExtensionResult.cs (1)

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

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

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

src\SignalR\common\SignalR.Common\test\Internal\Protocol\MessagePackHubProtocolTestBase.cs (7)

229var data = new ReadOnlySequence<byte>(bytes); 254var data = new ReadOnlySequence<byte>(bytes); 275var byteSpan = new ReadOnlySequence<byte>(bytes); 363var data = new ReadOnlySequence<byte>(buffer); 396var data = new ReadOnlySequence<byte>(buffer); 407var data = new ReadOnlySequence<byte>(payload); 479var data = new ReadOnlySequence<byte>(bytes);

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

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

HttpConnectionDispatcherTests.cs (4)

2963services.AddSingleton(new MessageWrapper() { Buffer = new ReadOnlySequence<byte>(new byte[] { 1, 2, 3 }) }); 2986services.AddSingleton(new MessageWrapper() { Buffer = new ReadOnlySequence<byte>(new byte[] { 4, 5, 6 }) }); 3018return new MessageWrapper() { Buffer = new ReadOnlySequence<byte>(new byte[] { (byte)(iteration + 1), (byte)(iteration + 2), (byte)(iteration + 3) }) }; 3073return new MessageWrapper() { Buffer = new ReadOnlySequence<byte>(new byte[] { (byte)(iteration + 1), (byte)(iteration + 2), (byte)(iteration + 3) }) };

ServerSentEventsMessageFormatterTests.cs (1)

20var buffer = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes(payload));

src\Shared\Buffers.Testing\ReadOnlySequenceFactory.cs (5)

31return new ReadOnlySequence<byte>(new byte[size + 20], 10, size); 38return new ReadOnlySequence<byte>(startSegment, 10, data.Length); 53return new ReadOnlySequence<byte>(new Memory<byte>(startSegment, 10, data.Length)); 68return new ReadOnlySequence<byte>(new CustomMemoryForTest<byte>(startSegment, 10, data.Length).Memory); 146return new ReadOnlySequence<byte>(first, 0, last, last.Memory.Length);

BufferingStream.cs (1)

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

PrerenderComponentApplicationStoreTest.cs (1)

37["MyValue"] = new ReadOnlySequence<byte>(new byte[] { 1, 2, 3, 4 })

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);

RedisOutputCacheStore.cs (1)

240return ((IOutputCacheBufferStore)this).SetAsync(key, new ReadOnlySequence<byte>(value), tags.AsMemory(), validFor, cancellationToken);

src\Shared\Http2cat\Http2Utilities.cs (1)

1000public ReadOnlySequence<byte> PayloadSequence => new ReadOnlySequence<byte>(Payload);

Internal\Http\Http1ContentLengthMessageBody.cs (1)

221_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]);

HttpParserTests.cs (21)

src\Shared\Buffers.Testing\ReadOnlySequenceFactory.cs (5)

31return new ReadOnlySequence<byte>(new byte[size + 20], 10, size); 38return new ReadOnlySequence<byte>(startSegment, 10, data.Length); 53return new ReadOnlySequence<byte>(new Memory<byte>(startSegment, 10, data.Length)); 68return new ReadOnlySequence<byte>(new CustomMemoryForTest<byte>(startSegment, 10, data.Length).Memory); 146return new ReadOnlySequence<byte>(first, 0, last, last.Memory.Length);

src\Shared\test\Shared.Tests\runtime\Http3\VariableLengthIntegerHelperTests.cs (6)

139ReadOnlySequence<byte> readOnlySequence = new ReadOnlySequence<byte>(new byte[] 177ReadOnlySequence<byte> readOnlySequence = new ReadOnlySequence<byte>( 193ReadOnlySequence<byte> readOnlySequence = new ReadOnlySequence<byte>( 209ReadOnlySequence<byte> readOnlySequence = new ReadOnlySequence<byte>( 224ReadOnlySequence<byte> readOnlySequence = new ReadOnlySequence<byte>( 239ReadOnlySequence<byte> readOnlySequence = new ReadOnlySequence<byte>(

StartLineTests.cs (17)

VariableIntHelperTests.cs (1)

17var decoded = VariableLengthIntegerHelper.GetInteger(new ReadOnlySequence<byte>(input), out _, out _);

Http1ConnectionBenchmark.cs (1)

75_buffer = new ReadOnlySequence<byte>(data);

HttpParserBenchmark.cs (1)

84_buffer = new ReadOnlySequence<byte>(data);

src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (1)

812public ReadOnlySequence<byte> PayloadSequence => new ReadOnlySequence<byte>(Payload);

runtime\Http3\VariableLengthIntegerHelperTests.cs (6)

139ReadOnlySequence<byte> readOnlySequence = new ReadOnlySequence<byte>(new byte[] 177ReadOnlySequence<byte> readOnlySequence = new ReadOnlySequence<byte>( 193ReadOnlySequence<byte> readOnlySequence = new ReadOnlySequence<byte>( 209ReadOnlySequence<byte> readOnlySequence = new ReadOnlySequence<byte>( 224ReadOnlySequence<byte> readOnlySequence = new ReadOnlySequence<byte>( 239ReadOnlySequence<byte> readOnlySequence = new ReadOnlySequence<byte>(

Protocol\RawResult.cs (1)

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

Internal\Formatters\BinaryMessageParserTests.cs (6)

21var span = new ReadOnlySequence<byte>(encoded); 56var span = new ReadOnlySequence<byte>(encoded); 70var buffer = new ReadOnlySequence<byte>(payload); 83var buffer = new ReadOnlySequence<byte>(payload); 98var buffer = new ReadOnlySequence<byte>(encoded); 117var buffer = new ReadOnlySequence<byte>(encoded);

Internal\Formatters\TextMessageParserTests.cs (4)

17var message = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes("ABC\u001e")); 27var message = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes("ABC")); 34var message = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes("ABC\u001eXYZ\u001e")); 44var message = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes("ABC\u001eXYZ\u001e123"));

Internal\Protocol\HandshakeProtocolTests.cs (5)

26var message = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes(json)); 52var message = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes(json)); 71var message = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes("42")); 89var message = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes(payload)); 105var message = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes(payload));

Internal\Protocol\JsonHubProtocolTests.cs (6)

53var data = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes(input)); 90var data = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes(input)); 104var data = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes(input)); 130var data = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes(json)); 163var data = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes(json)); 196var data = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes(json));

Internal\Protocol\JsonHubProtocolTestsBase.cs (14)

Internal\Protocol\MessagePackHubProtocolTestBase.cs (7)

229var data = new ReadOnlySequence<byte>(bytes); 254var data = new ReadOnlySequence<byte>(bytes); 275var byteSpan = new ReadOnlySequence<byte>(bytes); 363var data = new ReadOnlySequence<byte>(buffer); 396var data = new ReadOnlySequence<byte>(buffer); 407var data = new ReadOnlySequence<byte>(payload); 479var data = new ReadOnlySequence<byte>(bytes);

Internal\Protocol\MessagePackHubProtocolTests.cs (3)

221var data = new ReadOnlySequence<byte>(input); 251var data = new ReadOnlySequence<byte>(input); 264var data = new ReadOnlySequence<byte>(input);

Internal\Protocol\NewtonsoftJsonHubProtocolTests.cs (2)

51var data = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes(input)); 89var data = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes(input));

Internal\Protocol\Utf8BufferTextReaderTests.cs (5)

18var buffer = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes("Hello World")); 31var buffer = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes("a\u00E4\u00E4\u00a9o")); 49var buffer = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes("Hello World")); 63var buffer = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes("Hello World")); 95var buffer = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes("\u00E4\u00E4\u00E5"));

src\Shared\Buffers.Testing\ReadOnlySequenceFactory.cs (5)

31return new ReadOnlySequence<byte>(new byte[size + 20], 10, size); 38return new ReadOnlySequence<byte>(startSegment, 10, data.Length); 53return new ReadOnlySequence<byte>(new Memory<byte>(startSegment, 10, data.Length)); 68return new ReadOnlySequence<byte>(new CustomMemoryForTest<byte>(startSegment, 10, data.Length).Memory); 146return new ReadOnlySequence<byte>(first, 0, last, last.Memory.Length);

HandshakeProtocolBenchmark.cs (10)

HubConnectionReceiveBenchmark.cs (2)

137_pipe.AddReadResult(new ValueTask<ReadResult>(new ReadResult(new ReadOnlySequence<byte>(_invocationMessageBytes), false, false))); 154_tcs.SetResult(new ReadResult(new ReadOnlySequence<byte>(_invocationMessageBytes), false, false));

HubProtocolBenchmark.cs (1)

62var data = new ReadOnlySequence<byte>(_binaryInput);

MessageParserBenchmark.cs (2)

57var data = new ReadOnlySequence<byte>(_binaryInput); 67var data = new ReadOnlySequence<byte>(_textInput);

ServerSentEventsBenchmark.cs (1)

58_rawData = new ReadOnlySequence<byte>(protocol.GetMessageBytes(hubMessage));

src\Shared\Buffers.Testing\ReadOnlySequenceFactory.cs (5)

31return new ReadOnlySequence<byte>(new byte[size + 20], 10, size); 38return new ReadOnlySequence<byte>(startSegment, 10, data.Length); 53return new ReadOnlySequence<byte>(new Memory<byte>(startSegment, 10, data.Length)); 68return new ReadOnlySequence<byte>(new CustomMemoryForTest<byte>(startSegment, 10, data.Length).Memory); 146return new ReadOnlySequence<byte>(first, 0, last, last.Memory.Length);

Protocol\NewtonsoftJsonHubProtocol.cs (1)

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

Internal\RedisProtocol.cs (1)

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

RedisProtocolTests.cs (2)

207new RedisCompletion("json", new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes("{\"type\":3,\"invocationId\":\"1\",\"result\":1}"))), 221new RedisCompletion("messagepack", new ReadOnlySequence<byte>(new byte[] { 0x95, 0x03, 0x80, 0xa3, (byte)'x', (byte)'y', (byte)'z', 0x03, 0x2a })),

FormPipeReaderInternalsBenchmark.cs (1)

29var buffer = new ReadOnlySequence<byte>(_singleUtf8);

src\Shared\Buffers.Testing\ReadOnlySequenceFactory.cs (5)

31return new ReadOnlySequence<byte>(new byte[size + 20], 10, size); 38return new ReadOnlySequence<byte>(startSegment, 10, data.Length); 53return new ReadOnlySequence<byte>(new Memory<byte>(startSegment, 10, data.Length)); 68return new ReadOnlySequence<byte>(new CustomMemoryForTest<byte>(startSegment, 10, data.Length).Memory); 146return new ReadOnlySequence<byte>(first, 0, last, last.Memory.Length);

FormPipeReaderTests.cs (3)

258var readOnlySequence = new ReadOnlySequence<byte>(encoding.GetBytes("foo=bar&baz=boo")); 603{ new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes("fo=bar&ba")) } 610{ new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes("fo=bar&b=")) }

src\Shared\Buffers.Testing\ReadOnlySequenceFactory.cs (5)

31return new ReadOnlySequence<byte>(new byte[size + 20], 10, size); 38return new ReadOnlySequence<byte>(startSegment, 10, data.Length); 53return new ReadOnlySequence<byte>(new Memory<byte>(startSegment, 10, data.Length)); 68return new ReadOnlySequence<byte>(new CustomMemoryForTest<byte>(startSegment, 10, data.Length).Memory); 146return new ReadOnlySequence<byte>(first, 0, last, last.Memory.Length);

Internal\BufferChunk.cs (1)

84internal ReadOnlySequence<byte> AsSequence() => Length == 0 ? default : new ReadOnlySequence<byte>(Array!, 0, Length);

Internal\DefaultHybridCache.StampedeStateT.cs (1)

292immutable.SetValue(serializer.Deserialize(new(value.Array!, 0, value.Length)), value.Length);

DistributedCacheTests.cs (4)

287payload = new(arr); 292payload = new(arr, 5, arr.Length - 10); 296payload = new(mem); 313payload = new(first, 7, third, 4);

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)

488return _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>(

Otlp\Http\OtlpHttpEndpointsBuilder.cs (1)

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

Dcp\DcpHost.cs (1)

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

RawSample.cs (1)

80var buffer = result.Buffer;

Tcp\SocketSender.cs (2)

31public SocketAwaitable SendAsync(in ReadOnlySequence<byte> buffers) 80private List<ArraySegment<byte>> GetBufferList(in ReadOnlySequence<byte> buffer)

Tcp\TcpConnection.cs (1)

222var buffer = result.Buffer;

src\Shared\Http2cat\Http2Utilities.cs (2)

848if (Http2FrameReader.TryReadFrame(ref buffer, frame, maxFrameSize, out var framePayload)) 1000public ReadOnlySequence<byte> PayloadSequence => new ReadOnlySequence<byte>(Payload);

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

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

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\Shared\ServerInfrastructure\DuplexPipeStream.cs (1)

122var readableBuffer = result.Buffer;

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)

src\Shared\Http2cat\Http2Utilities.cs (2)

848if (Http2FrameReader.TryReadFrame(ref buffer, frame, maxFrameSize, out var framePayload)) 1000public ReadOnlySequence<byte> PayloadSequence => new ReadOnlySequence<byte>(Payload);

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

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

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\Shared\ServerInfrastructure\DuplexPipeStream.cs (1)

122var readableBuffer = result.Buffer;

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)

src\Shared\Http2cat\Http2Utilities.cs (2)

848if (Http2FrameReader.TryReadFrame(ref buffer, frame, maxFrameSize, out var framePayload)) 1000public ReadOnlySequence<byte> PayloadSequence => new ReadOnlySequence<byte>(Payload);

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

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

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\Shared\ServerInfrastructure\DuplexPipeStream.cs (1)

122var readableBuffer = result.Buffer;

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)

src\Shared\Http2cat\Http2Utilities.cs (2)

848if (Http2FrameReader.TryReadFrame(ref buffer, frame, maxFrameSize, out var framePayload)) 1000public ReadOnlySequence<byte> PayloadSequence => new ReadOnlySequence<byte>(Payload);

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

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

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\Shared\ServerInfrastructure\DuplexPipeStream.cs (1)

122var readableBuffer = result.Buffer;

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)

src\Shared\Http2cat\Http2Utilities.cs (2)

848if (Http2FrameReader.TryReadFrame(ref buffer, frame, maxFrameSize, out var framePayload)) 1000public ReadOnlySequence<byte> PayloadSequence => new ReadOnlySequence<byte>(Payload);

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

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

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\Shared\ServerInfrastructure\DuplexPipeStream.cs (1)

122var readableBuffer = result.Buffer;

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)

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\Shared\ServerInfrastructure\DuplexPipeStream.cs (1)

122var readableBuffer = result.Buffer;

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)

src\Shared\Http2cat\Http2Utilities.cs (2)

848if (Http2FrameReader.TryReadFrame(ref buffer, frame, maxFrameSize, out var framePayload)) 1000public ReadOnlySequence<byte> PayloadSequence => new ReadOnlySequence<byte>(Payload);

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

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

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\Shared\ServerInfrastructure\DuplexPipeStream.cs (1)

122var readableBuffer = result.Buffer;

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)

Http2\Http2TestBase.cs (2)

1242if (Http2FrameReader.TryReadFrame(ref buffer, frame, maxFrameSize, out var framePayload)) 1450public ReadOnlySequence<byte> PayloadSequence => new ReadOnlySequence<byte>(Payload);

Http2\TlsTests.cs (2)

110var buffer = result.Buffer; 116if (Http2FrameReader.TryReadFrame(ref buffer, frame, 16_384, out var framePayload))

src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (6)

552var buffer = result.Buffer; 555var copyBuffer = buffer; 569if (Http3FrameReader.TryReadFrame(ref buffer, frame, out var framePayload)) 812public ReadOnlySequence<byte> PayloadSequence => new ReadOnlySequence<byte>(Payload); 842var payload = http3WithPayload.PayloadSequence; 929var readableBuffer = result.Buffer;

HttpClientHttp2InteropTests.cs (2)

280var sequence = readResult.Buffer.Slice(0, "Hello World".Length); 337var sequence = readResult.Buffer.Slice(0, "Hello World".Length);

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\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\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\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\submodules\MessagePack-CSharp\src\MessagePack.UnityClient\Assets\Scripts\MessagePack\MessagePackReader.cs (13)

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\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\SignalR\common\SignalR.Common\test\Internal\Protocol\MessagePackHubProtocolTestBase.cs (9)

229var data = new ReadOnlySequence<byte>(bytes); 254var data = new ReadOnlySequence<byte>(bytes); 275var byteSpan = new ReadOnlySequence<byte>(bytes); 276Assert.True(BinaryMessageParser.TryParseMessage(ref byteSpan, out var unframed)); 363var data = new ReadOnlySequence<byte>(buffer); 396var data = new ReadOnlySequence<byte>(buffer); 407var data = new ReadOnlySequence<byte>(payload); 479var data = new ReadOnlySequence<byte>(bytes); 480Assert.True(BinaryMessageParser.TryParseMessage(ref data, out var message));

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

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

ServerStreamingServerCallHandlerTests.cs (3)

268var buffer = result.Buffer; 287private static string? ReadLine(ref ReadOnlySequence<byte> buffer, out SequencePosition end) 291if (reader.TryReadTo(out ReadOnlySequence<byte> line, (byte)'\n'))

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\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\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\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\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)

HttpConnectionDispatcherTests.cs (2)

3912var buffer = result.Buffer; 4086public ReadOnlySequence<byte> Buffer { get; set; }

ServerSentEventsMessageFormatterTests.cs (2)

20var buffer = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes(payload)); 32var buffer = ReadOnlySequenceFactory.SegmentPerByteFactory.CreateWithContent(Encoding.UTF8.GetBytes(payload));

src\Shared\Buffers.Testing\ReadOnlySequenceFactory.cs (14)

WebSocketsTests.cs (2)

55var buffer = result.Buffer; 404var sequence = ReadOnlySequenceFactory.CreateSegments(new byte[] { 1 }, new byte[] { 15 });

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);

PrerenderComponentApplicationStoreTest.cs (1)

35var expected = new Dictionary<string, ReadOnlySequence<byte>>()

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;

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()

EndToEndBenchmarks.cs (4)

121ReadOnlySequence<byte> body; 137ReadOnlySequence<byte> body; 153ReadOnlySequence<byte> body; 192var body = value.Body;

RedisOutputCacheStore.cs (1)

243async ValueTask IOutputCacheBufferStore.SetAsync(string key, ReadOnlySequence<byte> value, ReadOnlyMemory<string> tags, TimeSpan validFor, CancellationToken cancellationToken)

CachedResponseBodyTests.cs (6)

18var body = RecyclableReadOnlySequenceSegment.CreateSequence(segments); 29var body = RecyclableReadOnlySequenceSegment.CreateSequence(segments); 51var body = RecyclableReadOnlySequenceSegment.CreateSequence(segments); 75var body = RecyclableReadOnlySequenceSegment.CreateSequence(segments); 90static async Task CopyDataAsync(ReadOnlySequence<byte> body, PipeWriter writer, CancellationToken cancellationToken) 101var buffer = result.Buffer;

OutputCacheEntryFormatterTests.cs (3)

174static bool SequenceEqual(ReadOnlySequence<byte> x, ReadOnlySequence<byte> y) 192static ReadOnlyMemory<byte> Linearize(in ReadOnlySequence<byte> value, out byte[] lease)

TestUtils.cs (1)

370ValueTask IOutputCacheBufferStore.SetAsync(string key, ReadOnlySequence<byte> value, ReadOnlyMemory<string> tags, TimeSpan validFor, CancellationToken cancellationToken)

ResponseCachingBenchmark.cs (1)

99var buffer = result.Buffer;

CachedResponseBodyTests.cs (1)

106var buffer = result.Buffer;

src\Shared\Http2cat\Http2Utilities.cs (2)

848if (Http2FrameReader.TryReadFrame(ref buffer, frame, maxFrameSize, out var framePayload)) 1000public ReadOnlySequence<byte> PayloadSequence => new ReadOnlySequence<byte>(Payload);

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

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

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\Shared\ServerInfrastructure\DuplexPipeStream.cs (1)

122var readableBuffer = result.Buffer;

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)

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\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\Shared\ServerInfrastructure\DuplexPipeStream.cs (1)

122var readableBuffer = result.Buffer;

Internal\Http\Http1ChunkedEncodingMessageBody.cs (10)

113var readableBuffer = result.Buffer; 202private bool Read(ReadOnlySequence<byte> readableBuffer, PipeWriter writableBuffer, out SequencePosition consumed, out SequencePosition examined) 291private void ParseChunkedPrefix(in ReadOnlySequence<byte> buffer, out SequencePosition consumed, out SequencePosition examined) 348private void ParseExtension(ReadOnlySequence<byte> buffer, out SequencePosition consumed, out SequencePosition examined) 369var suffixBuffer = buffer.Slice(extensionCursor); 400private void ReadChunkedData(in ReadOnlySequence<byte> buffer, PipeWriter writableBuffer, out SequencePosition consumed, out SequencePosition examined) 417private void ParseChunkedSuffix(in ReadOnlySequence<byte> buffer, out SequencePosition consumed, out SequencePosition examined) 427var suffixBuffer = buffer.Slice(0, 2); 445private void ParseChunkedTrailer(in ReadOnlySequence<byte> buffer, out SequencePosition consumed, out SequencePosition examined) 455var trailerBuffer = buffer.Slice(0, 2);

Internal\Http\Http1Connection.cs (4)

225var trimmedBuffer = reader.Sequence.Slice(reader.Position, ServerOptions.Limits.MaxRequestLineSize); 267var trimmedBuffer = reader.Sequence.Slice(reader.Position, _remainingRequestHeadersBytesAllowed); 835private void OnBadRequest(ReadOnlySequence<byte> requestData, BadHttpRequestException ex) 850private void DetectHttp2Preface(ReadOnlySequence<byte> requestData)

Internal\Http\Http1ContentLengthMessageBody.cs (1)

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

Internal\Http\HttpParser.cs (3)

79var readResult = reader.TryReadExact(requestLine.Length + 1, out var requestLineSequence); 338var currentSlice = reader.UnreadSequence; 398ReadOnlySequence<byte> header;

Internal\Http\HttpRequestStream.cs (2)

125var buffer = result.Buffer; 135var 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)

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

Internal\Http3\Http3ControlStream.cs (6)

154var readableBuffer = result.Buffer; 253var readableBuffer = result.Buffer; 262while (Http3FrameReader.TryReadFrame(ref readableBuffer, _incomingFrame, out var framePayload)) 292var readableBuffer = result.Buffer; 297private ValueTask ProcessHttp3ControlStream(in ReadOnlySequence<byte> payload) 319private ValueTask ProcessSettingsFrameAsync(ReadOnlySequence<byte> payload)

Internal\Http3\Http3FrameReader.cs (5)

22internal static bool TryReadFrame(ref ReadOnlySequence<byte> readableBuffer, Http3RawFrame frame, out ReadOnlySequence<byte> framePayload) 24framePayload = ReadOnlySequence<byte>.Empty; 33var firstLengthBuffer = readableBuffer.Slice(consumed); 43var 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)

615var readableBuffer = result.Buffer; 623while (Http3FrameReader.TryReadFrame(ref readableBuffer, _incomingFrame, out var framePayload)) 751private Task ProcessHttp3Stream<TContext>(IHttpApplication<TContext> application, in ReadOnlySequence<byte> payload, bool isCompleted) where TContext : notnull 778private async Task ProcessHeadersFrameAsync<TContext>(IHttpApplication<TContext> application, ReadOnlySequence<byte> payload, bool isCompleted) where TContext : notnull 877private 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)

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

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

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

131public static long GetInteger(in ReadOnlySequence<byte> buffer, out SequencePosition consumed, out SequencePosition examined)

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

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

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\Shared\ServerInfrastructure\DuplexPipeStream.cs (1)

122var readableBuffer = result.Buffer;

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)

Http1\Http1ConnectionTests.cs (21)

Http2\Http2FrameWriterTests.cs (1)

105var buffer = result.Buffer;

HttpParserTests.cs (34)

MessageBodyTests.cs (1)

1411private void AssertASCII(string expected, ReadOnlySequence<byte> actual)

PipelineExtensionTests.cs (2)

90var written = reader.Buffer.Slice(spacer.Length, numAsString.Length); 194var written = reader.Buffer.Slice(spacer.Length, stringLength);

src\Shared\Buffers.Testing\ReadOnlySequenceFactory.cs (14)

src\Shared\test\Shared.Tests\runtime\Http3\VariableLengthIntegerHelperTests.cs (6)

139ReadOnlySequence<byte> readOnlySequence = new ReadOnlySequence<byte>(new byte[] 177ReadOnlySequence<byte> readOnlySequence = new ReadOnlySequence<byte>( 193ReadOnlySequence<byte> readOnlySequence = new ReadOnlySequence<byte>( 209ReadOnlySequence<byte> readOnlySequence = new ReadOnlySequence<byte>( 224ReadOnlySequence<byte> readOnlySequence = new ReadOnlySequence<byte>( 239ReadOnlySequence<byte> readOnlySequence = new ReadOnlySequence<byte>(

StartLineTests.cs (9)

Http1ConnectionBenchmark.cs (1)

23private ReadOnlySequence<byte> _buffer;

Http1ConnectionParsingOverheadBenchmark.cs (1)

20public ReadOnlySequence<byte> _buffer;

Http2\Http2ConnectionBenchmarkBase.cs (2)

157var buffer = result.Buffer; 163if (Http2FrameReader.TryReadFrame(ref buffer, _receiveHttpFrame, maxFrameSize, out var framePayload))

HttpParserBenchmark.cs (2)

15private ReadOnlySequence<byte> _buffer; 16private ReadOnlySequence<byte> _multispanHeader;

InMemoryTransportBenchmark.cs (3)

197var buffer = result.Buffer; 214var buffer = result.Buffer; 222var response = buffer.Slice(0, length);

RequestParsingBenchmark.cs (2)

148var readableBuffer = awaitable.GetAwaiter().GetResult().Buffer; 181var readableBuffer = result.Buffer;

src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (6)

552var buffer = result.Buffer; 555var copyBuffer = buffer; 569if (Http3FrameReader.TryReadFrame(ref buffer, frame, out var framePayload)) 812public ReadOnlySequence<byte> PayloadSequence => new ReadOnlySequence<byte>(Payload); 842var payload = http3WithPayload.PayloadSequence; 929var readableBuffer = result.Buffer;

Internal\NamedPipeConnection.cs (1)

163var buffer = result.Buffer;

Internal\QuicStreamContext.cs (1)

397var buffer = result.Buffer;

Internal\SocketConnection.cs (1)

280var buffer = result.Buffer;

Internal\SocketSender.cs (2)

20public ValueTask<SocketOperationResult> SendAsync(Socket socket, in ReadOnlySequence<byte> buffers) 76private void SetBufferList(in ReadOnlySequence<byte> buffer)

runtime\Http3\VariableLengthIntegerHelperTests.cs (6)

139ReadOnlySequence<byte> readOnlySequence = new ReadOnlySequence<byte>(new byte[] 177ReadOnlySequence<byte> readOnlySequence = new ReadOnlySequence<byte>( 193ReadOnlySequence<byte> readOnlySequence = new ReadOnlySequence<byte>( 209ReadOnlySequence<byte> readOnlySequence = new ReadOnlySequence<byte>( 224ReadOnlySequence<byte> readOnlySequence = new ReadOnlySequence<byte>( 239ReadOnlySequence<byte> readOnlySequence = new ReadOnlySequence<byte>(

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

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

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

131public static long GetInteger(in ReadOnlySequence<byte> buffer, out SequencePosition consumed, out SequencePosition examined)

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

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

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\Shared\ServerInfrastructure\DuplexPipeStream.cs (1)

122var readableBuffer = result.Buffer;

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)

HubConnection.cs (2)

1518var buffer = result.Buffer; 1637var buffer = result.Buffer;

HubProtocolVersionTests.cs (1)

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

VersionJsonHubProtocol.cs (5)

30public bool TryParseMessage(ref ReadOnlySequence<byte> input, IInvocationBinder binder, out HubMessage message) 32var inputCopy = input; 33if (!TryParseMessage(ref input, out var payload)) 54public static bool TryParseMessage(ref ReadOnlySequence<byte> buffer, out ReadOnlySequence<byte> payload)

HubConnectionTests.cs (1)

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

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)

TestConnection.cs (2)

149var buffer = result.Buffer; 154if (TextMessageParser.TryParseMessage(ref buffer, out var payload))

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\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\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)

Internal\Formatters\BinaryMessageFormatterTests.cs (2)

127var buffer = new ReadOnlySequence<byte>(writer.ToArray()); 128Assert.True(BinaryMessageParser.TryParseMessage(ref buffer, out var roundtripped));

Internal\Formatters\BinaryMessageParserTests.cs (12)

21var span = new ReadOnlySequence<byte>(encoded); 22Assert.True(BinaryMessageParser.TryParseMessage(ref span, out var message)); 56var span = new ReadOnlySequence<byte>(encoded); 57Assert.True(BinaryMessageParser.TryParseMessage(ref span, out var message)); 70var buffer = new ReadOnlySequence<byte>(payload); 71BinaryMessageParser.TryParseMessage(ref buffer, out var message); 83var buffer = new ReadOnlySequence<byte>(payload); 84Assert.False(BinaryMessageParser.TryParseMessage(ref buffer, out var message)); 98var buffer = new ReadOnlySequence<byte>(encoded); 100while (BinaryMessageParser.TryParseMessage(ref buffer, out var message)) 117var buffer = new ReadOnlySequence<byte>(encoded); 118Assert.False(BinaryMessageParser.TryParseMessage(ref buffer, out var message));

Internal\Formatters\TextMessageParserTests.cs (4)

17var message = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes("ABC\u001e")); 27var message = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes("ABC")); 34var message = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes("ABC\u001eXYZ\u001e")); 44var message = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes("ABC\u001eXYZ\u001e123"));

Internal\Protocol\HandshakeProtocolTests.cs (7)

26var message = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes(json)); 37var message = ReadOnlySequenceFactory.SegmentPerByteFactory.CreateWithContent("{\"protocol\":\"json\",\"version\":1}\u001e"); 52var message = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes(json)); 61var message = ReadOnlySequenceFactory.SegmentPerByteFactory.CreateWithContent("{\"error\":\"dummy\"}\u001e"); 71var message = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes("42")); 89var message = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes(payload)); 105var message = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes(payload));

Internal\Protocol\JsonHubProtocolTests.cs (6)

53var data = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes(input)); 90var data = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes(input)); 104var data = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes(input)); 130var data = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes(json)); 163var data = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes(json)); 196var data = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes(json));

Internal\Protocol\JsonHubProtocolTestsBase.cs (14)

Internal\Protocol\MessagePackHubProtocolTestBase.cs (9)

229var data = new ReadOnlySequence<byte>(bytes); 254var data = new ReadOnlySequence<byte>(bytes); 275var byteSpan = new ReadOnlySequence<byte>(bytes); 276Assert.True(BinaryMessageParser.TryParseMessage(ref byteSpan, out var unframed)); 363var data = new ReadOnlySequence<byte>(buffer); 396var data = new ReadOnlySequence<byte>(buffer); 407var data = new ReadOnlySequence<byte>(payload); 479var data = new ReadOnlySequence<byte>(bytes); 480Assert.True(BinaryMessageParser.TryParseMessage(ref data, out var message));

Internal\Protocol\MessagePackHubProtocolTests.cs (5)

37var bytes = new ReadOnlySequence<byte>(writer.ToArray()); 66var bytes = new ReadOnlySequence<byte>(writer.ToArray()); 221var data = new ReadOnlySequence<byte>(input); 251var data = new ReadOnlySequence<byte>(input); 264var data = new ReadOnlySequence<byte>(input);

Internal\Protocol\NewtonsoftJsonHubProtocolTests.cs (2)

51var data = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes(input)); 89var data = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes(input));

Internal\Protocol\Utf8BufferTextReaderTests.cs (5)

18var buffer = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes("Hello World")); 31var buffer = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes("a\u00E4\u00E4\u00a9o")); 49var buffer = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes("Hello World")); 63var buffer = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes("Hello World")); 95var buffer = new ReadOnlySequence<byte>(Encoding.UTF8.GetBytes("\u00E4\u00E4\u00E5"));

src\Shared\Buffers.Testing\ReadOnlySequenceFactory.cs (14)

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)

HubConnectionContext.cs (2)

512var buffer = result.Buffer; 527var segment = buffer;

HubConnectionHandler.cs (2)

274var buffer = result.Buffer; 309var segment = buffer;

BroadcastBenchmark.cs (1)

79var buffer = result.Buffer;

DefaultHubDispatcherBenchmark.cs (1)

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

HandshakeProtocolBenchmark.cs (22)

HubProtocolBenchmark.cs (1)

62var data = new ReadOnlySequence<byte>(_binaryInput);

MessageParserBenchmark.cs (2)

57var data = new ReadOnlySequence<byte>(_binaryInput); 67var data = new ReadOnlySequence<byte>(_textInput);

RedisHubLifetimeManagerBenchmark.cs (1)

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

RedisProtocolBenchmark.cs (1)

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

ServerSentEventsBenchmark.cs (1)

15private ReadOnlySequence<byte> _rawData;

src\Shared\Buffers.Testing\ReadOnlySequenceFactory.cs (14)

src\SignalR\common\Http.Connections\src\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\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\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)

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\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\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\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\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\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\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;

DefaultHubMessageSerializerTests.cs (1)

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

AddSignalRTests.cs (1)

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

AuthConnectionHandler.cs (1)

19var buffer = result.Buffer;

EchoConnectionHandler.cs (1)

17var buffer = result.Buffer;

HttpHeaderConnectionHandler.cs (1)

19var buffer = result.Buffer;

Internal\MessageBufferTests.cs (12)

36var buffer = res.Buffer; 61var buffer = res.Buffer; 102var buffer = res.Buffer; 136var buffer = res.Buffer; 185var buffer = res.Buffer; 230var buffer = res.Buffer; 262var buffer = res.Buffer; 299var buffer = res.Buffer; 343var buffer = res.Buffer; 379var buffer = res.Buffer; 423var buffer = res.Buffer; 470var buffer = res.Buffer;

WriteThenCloseConnectionHandler.cs (1)

15var buffer = result.Buffer;

DummyHubProtocol.cs (1)

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

PipeReaderExtensions.cs (1)

96var buffer = result.Buffer.Slice(0, numBytes);

TestClient.cs (2)

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

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)

FormPipeReaderInternalsBenchmark.cs (2)

29var buffer = new ReadOnlySequence<byte>(_singleUtf8); 38var buffer = ReadOnlySequenceFactory.CreateSegments(_firstUtf8, _secondUtf8);

src\Shared\Buffers.Testing\ReadOnlySequenceFactory.cs (14)

FormPipeReaderTests.cs (23)

src\Shared\Buffers.Testing\ReadOnlySequenceFactory.cs (14)

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)

84internal ReadOnlySequence<byte> AsSequence() => Length == 0 ? default : new ReadOnlySequence<byte>(Array!, 0, Length);

Internal\DefaultJsonSerializerFactory.cs (1)

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

Internal\InbuiltTypeSerializer.cs (2)

19string IHybridCacheSerializer<string>.Deserialize(ReadOnlySequence<byte> source) 53byte[] IHybridCacheSerializer<byte[]>.Deserialize(ReadOnlySequence<byte> source)

BufferReleaseTests.cs (2)

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

DistributedCacheTests.cs (4)

183var payload = Invent(size, kind); 245var payload = Invent(size, kind); 278private static ReadOnlySequence<byte> Invent(int size, SequenceKind kind) 281ReadOnlySequence<byte> payload;

L2Tests.cs (2)

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

ServiceConstructionTests.cs (1)

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

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<>))]

EchoConnectionHandler.cs (1)

16var buffer = result.Buffer;

ConnectionHandlers\MessagesConnectionHandler.cs (1)

28var buffer = result.Buffer;

SocialWeatherConnectionHandler.cs (1)

38var buffer = result.Buffer;

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)

475ReadOnlySequence<byte> buffer = GetCurrentReadOnlySequence(); 485private 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\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\libraries\Common\src\System\Net\Http\aspnetcore\Http2\Hpack\HPackDecoder.cs (1)

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

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

131public static long GetInteger(in ReadOnlySequence<byte> buffer, out SequencePosition consumed, out SequencePosition examined)

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) 440ReadOnlySequence<byte> valueSequence = default; 495ReadOnlySequence<byte> sequence = reader.OriginalSequence; 552ReadOnlySequence<byte> sequence = reader.OriginalSequence;

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

121public static 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) 2194ReadOnlySequence<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\JsonSerializer.Read.Utf8JsonReader.cs (3)

341ReadOnlySequence<byte> valueSequence = default; 376ReadOnlySequence<byte> sequence = reader.OriginalSequence; 410ReadOnlySequence<byte> originalSequence = reader.OriginalSequence;

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

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