File tree Expand file tree Collapse file tree 2 files changed +7
-4
lines changed
projects/RabbitMQ.Client/client/impl Expand file tree Collapse file tree 2 files changed +7
-4
lines changed Original file line number Diff line number Diff line change @@ -188,7 +188,8 @@ private async Task ClosingLoop()
188
188
{
189
189
_frameHandler . ReadTimeout = TimeSpan . Zero ;
190
190
// Wait for response/socket closure or timeout
191
- await ReceiveLoop ( ) . ConfigureAwait ( false ) ;
191
+ await ReceiveLoop ( )
192
+ . ConfigureAwait ( false ) ;
192
193
}
193
194
catch ( ObjectDisposedException ode )
194
195
{
Original file line number Diff line number Diff line change @@ -253,7 +253,8 @@ private static void ProcessProtocolHeader(ReadOnlySequence<byte> buffer)
253
253
254
254
internal static async ValueTask < InboundFrame > ReadFromPipeAsync ( PipeReader reader , uint maxMessageSize )
255
255
{
256
- ReadResult result = await reader . ReadAsync ( ) . ConfigureAwait ( false ) ;
256
+ ReadResult result = await reader . ReadAsync ( )
257
+ . ConfigureAwait ( false ) ;
257
258
258
259
ReadOnlySequence < byte > buffer = result . Buffer ;
259
260
if ( result . IsCompleted || buffer . Length == 0 )
@@ -267,8 +268,9 @@ internal static async ValueTask<InboundFrame> ReadFromPipeAsync(PipeReader reade
267
268
{
268
269
reader . AdvanceTo ( buffer . Start , buffer . End ) ;
269
270
270
- // Not enough
271
- result = await reader . ReadAsync ( ) . ConfigureAwait ( false ) ;
271
+ // Not enough data, read a bit more
272
+ result = await reader . ReadAsync ( )
273
+ . ConfigureAwait ( false ) ;
272
274
273
275
if ( result . IsCompleted || buffer . Length == 0 )
274
276
{
You can’t perform that action at this time.
0 commit comments