Skip to content

Commit bf8d40e

Browse files
committed
refac
1 parent 60a5ddd commit bf8d40e

3 files changed

Lines changed: 6 additions & 7 deletions

File tree

src/StackExchange.Redis/MessageWriter.cs

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -103,8 +103,7 @@ internal static void WriteBulkString(in RedisValue value, IBufferWriter<byte> wr
103103
WriteUnifiedSpan(writer, value.RawSpan());
104104
break;
105105
case RedisValue.StorageType.Sequence:
106-
var rosi = value.RawSequenceIterator();
107-
WriteUnifiedSequenceIterator(writer, ref rosi);
106+
WriteUnifiedSequenceIterator(writer, value.RawSequenceIterator());
108107
break;
109108
default:
110109
throw new InvalidOperationException($"Unexpected {value.Type} value: '{value}'");
@@ -597,14 +596,14 @@ private static void WriteUnifiedSequence(IBufferWriter<byte> writer, in ReadOnly
597596
}
598597
}
599598

600-
private static void WriteUnifiedSequenceIterator(IBufferWriter<byte> writer, ref ReadOnlySequenceIterator<byte> rosi)
599+
private static void WriteUnifiedSequenceIterator(IBufferWriter<byte> writer, ReadOnlySequenceSegmentIterator<byte> seq)
601600
{
602601
var span = writer.GetSpan(3 + Format.MaxInt32TextLen);
603602
span[0] = (byte)'$';
604-
int bytes = WriteRaw(span, rosi.Length, offset: 1);
603+
int bytes = WriteRaw(span, seq.Length, offset: 1);
605604
writer.Advance(bytes);
606605

607-
while (rosi.TryNext(out var memory))
606+
while (seq.TryNext(out var memory))
608607
{
609608
writer.Write(memory.Span);
610609
}

src/StackExchange.Redis/ReadOnlySequenceIterator.cs renamed to src/StackExchange.Redis/ReadOnlySequenceSegmentIterator.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33

44
namespace StackExchange.Redis;
55

6-
internal ref struct ReadOnlySequenceIterator<T>(ReadOnlySequenceSegment<T> segment, int startIndex, int length)
6+
internal struct ReadOnlySequenceSegmentIterator<T>(ReadOnlySequenceSegment<T> segment, int startIndex, int length)
77
{
88
private int _index = startIndex;
99
private int _length = length;

src/StackExchange.Redis/RedisValue.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -270,7 +270,7 @@ private static ReadOnlySequence<byte> GetSequence(ReadOnlySequenceSegment<byte>
270270
return new ReadOnlySequence<byte>(startSegment, startIndex, endSegment, endIndex);
271271
}
272272

273-
internal ReadOnlySequenceIterator<byte> RawSequenceIterator()
273+
internal ReadOnlySequenceSegmentIterator<byte> RawSequenceIterator()
274274
{
275275
if (_obj is ReadOnlySequenceSegment<byte> s) return new(s, _index, _length);
276276
ThrowRawType();

0 commit comments

Comments
 (0)