@@ -14,12 +14,12 @@ public class PipeBencodeReader
1414 /// <summary>
1515 /// The <see cref="PipeReader"/> to read from.
1616 /// </summary>
17- protected readonly PipeReader _reader ;
17+ protected PipeReader Reader { get ; }
1818
1919 /// <summary>
2020 /// Indicates if the <see cref="PipeReader"/> has been completed (i.e. "end of stream").
2121 /// </summary>
22- protected bool _readerCompleted ;
22+ protected bool ReaderCompleted { get ; set ; }
2323
2424 /// <summary>
2525 /// The position in the pipe (number of read bytes/characters) (does not included peeked char).
@@ -37,7 +37,7 @@ public class PipeBencodeReader
3737 /// <param name="reader"></param>
3838 public PipeBencodeReader ( PipeReader reader )
3939 {
40- _reader = reader ;
40+ Reader = reader ;
4141 }
4242
4343 /// <summary>
@@ -54,18 +54,18 @@ public virtual ValueTask<char> ReadCharAsync(CancellationToken cancellationToken
5454
5555 private ValueTask < char > ReadCharAsync ( bool peek = false , CancellationToken cancellationToken = default )
5656 {
57- if ( _readerCompleted )
57+ if ( ReaderCompleted )
5858 return new ValueTask < char > ( default ( char ) ) ;
5959
60- if ( _reader . TryRead ( out var result ) )
60+ if ( Reader . TryRead ( out var result ) )
6161 return new ValueTask < char > ( ReadCharConsume ( result . Buffer , peek ) ) ;
6262
6363 return ReadCharAsyncAwaited ( peek , cancellationToken ) ;
6464 }
6565
6666 private async ValueTask < char > ReadCharAsyncAwaited ( bool peek , CancellationToken cancellationToken )
6767 {
68- var result = await _reader . ReadAsync ( cancellationToken ) . ConfigureAwait ( false ) ;
68+ var result = await Reader . ReadAsync ( cancellationToken ) . ConfigureAwait ( false ) ;
6969 return ReadCharConsume ( result . Buffer , peek ) ;
7070 }
7171
@@ -80,7 +80,7 @@ protected virtual char ReadCharConsume(in ReadOnlySequence<byte> buffer, bool pe
8080 if ( buffer . IsEmpty )
8181 {
8282 // TODO: Add IsCompleted check?
83- _readerCompleted = true ;
83+ ReaderCompleted = true ;
8484 return default ;
8585 }
8686
@@ -89,14 +89,14 @@ protected virtual char ReadCharConsume(in ReadOnlySequence<byte> buffer, bool pe
8989 if ( peek )
9090 {
9191 // Advance reader to start (i.e. don't advance)
92- _reader . AdvanceTo ( buffer . Start ) ;
92+ Reader . AdvanceTo ( buffer . Start ) ;
9393 return c ;
9494 }
9595
9696 // Consume char by advancing reader
9797 Position ++ ;
9898 PreviousChar = c ;
99- _reader . AdvanceTo ( buffer . GetPosition ( 1 ) ) ;
99+ Reader . AdvanceTo ( buffer . GetPosition ( 1 ) ) ;
100100 return c ;
101101 }
102102
@@ -108,10 +108,10 @@ protected virtual char ReadCharConsume(in ReadOnlySequence<byte> buffer, bool pe
108108 /// <param name="cancellationToken"></param>
109109 public virtual ValueTask < long > ReadAsync ( Memory < byte > bytes , CancellationToken cancellationToken = default )
110110 {
111- if ( bytes . Length == 0 || _readerCompleted )
111+ if ( bytes . Length == 0 || ReaderCompleted )
112112 return new ValueTask < long > ( 0 ) ;
113113
114- if ( _reader . TryRead ( out var result ) && TryReadConsume ( result , bytes . Span , out var bytesRead ) )
114+ if ( Reader . TryRead ( out var result ) && TryReadConsume ( result , bytes . Span , out var bytesRead ) )
115115 {
116116 return new ValueTask < long > ( bytesRead ) ;
117117 }
@@ -123,7 +123,7 @@ private async ValueTask<long> ReadAsyncAwaited(Memory<byte> bytes, CancellationT
123123 {
124124 while ( true )
125125 {
126- var result = await _reader . ReadAsync ( cancellationToken ) . ConfigureAwait ( false ) ;
126+ var result = await Reader . ReadAsync ( cancellationToken ) . ConfigureAwait ( false ) ;
127127 if ( TryReadConsume ( result , bytes . Span , out var bytesRead ) )
128128 {
129129 return bytesRead ;
@@ -156,13 +156,13 @@ protected virtual bool TryReadConsume(ReadResult result, in Span<byte> bytes, ou
156156 Position += bytes . Length ;
157157 PreviousChar = ( char ) bytes [ bytes . Length - 1 ] ;
158158 bytesRead = bytes . Length ;
159- _reader . AdvanceTo ( buffer . GetPosition ( bytes . Length ) ) ;
159+ Reader . AdvanceTo ( buffer . GetPosition ( bytes . Length ) ) ;
160160 return true ;
161161 }
162162
163163 if ( result . IsCompleted )
164164 {
165- _readerCompleted = true ;
165+ ReaderCompleted = true ;
166166
167167 if ( buffer . IsEmpty )
168168 {
@@ -176,12 +176,12 @@ protected virtual bool TryReadConsume(ReadResult result, in Span<byte> bytes, ou
176176 Position += buffer . Length ;
177177 PreviousChar = ( char ) buffer . Slice ( buffer . Length - 1 ) . First . Span [ 0 ] ;
178178 bytesRead = buffer . Length ;
179- _reader . AdvanceTo ( buffer . End ) ;
179+ Reader . AdvanceTo ( buffer . End ) ;
180180 return true ;
181181 }
182182
183183 // Not enough bytes read, advance reader
184- _reader . AdvanceTo ( buffer . Start , buffer . End ) ;
184+ Reader . AdvanceTo ( buffer . Start , buffer . End ) ;
185185
186186 bytesRead = - 1 ;
187187 return false ; // Consume unsuccessful
0 commit comments