Adding .ConfigureAwait(false)

stebet · stebet · commit 89ae3efbf2c4 · 2022-10-13T11:12:30.000Z
diff --git a/projects/RabbitMQ.Client/client/impl/Connection.Receive.cs b/projects/RabbitMQ.Client/client/impl/Connection.Receive.cs
@@ -47,7 +47,7 @@ private async Task MainLoop()
         {
             try
             {
-                await ReceiveLoop();
+                await ReceiveLoop().ConfigureAwait(false);
             }
             catch (EndOfStreamException eose)
             {
@@ -56,7 +56,7 @@ private async Task MainLoop()
             }
             catch (HardProtocolException hpe)
             {
-                await HardProtocolExceptionHandler(hpe);
+                await HardProtocolExceptionHandler(hpe).ConfigureAwait(false);
             }
             catch (Exception ex)
             {
@@ -70,7 +70,7 @@ private async Task ReceiveLoop()
         {
             while (!_closed)
             {
-                InboundFrame frame = await _frameHandler.ReadFrame();
+                InboundFrame frame = await _frameHandler.ReadFrame().ConfigureAwait(false);
                 NotifyHeartbeatListener();
 
                 bool shallReturn = true;
@@ -151,7 +151,7 @@ private async Task HardProtocolExceptionHandler(HardProtocolException hpe)
                     _session0.Transmit(in cmd);
                     if (hpe.CanShutdownCleanly)
                     {
-                        await ClosingLoop();
+                        await ClosingLoop().ConfigureAwait(false);
                     }
                 }
                 catch (IOException ioe)
@@ -174,7 +174,7 @@ private async Task ClosingLoop()
             {
                 _frameHandler.ReadTimeout = TimeSpan.Zero;
                 // Wait for response/socket closure or timeout
-                await ReceiveLoop();
+                await ReceiveLoop().ConfigureAwait(false);
             }
             catch (ObjectDisposedException ode)
             {

Original file line number	Diff line number	Diff line change
`@@ -47,7 +47,7 @@ private async Task MainLoop()`
`47`	`47`	`{`
`48`	`48`	`try`
`49`	`49`	`{`
`50`		`- await ReceiveLoop();`
	`50`	`+ await ReceiveLoop().ConfigureAwait(false);`
`51`	`51`	`}`
`52`	`52`	`catch (EndOfStreamException eose)`
`53`	`53`	`{`
`@@ -56,7 +56,7 @@ private async Task MainLoop()`
`56`	`56`	`}`
`57`	`57`	`catch (HardProtocolException hpe)`
`58`	`58`	`{`
`59`		`- await HardProtocolExceptionHandler(hpe);`
	`59`	`+ await HardProtocolExceptionHandler(hpe).ConfigureAwait(false);`
`60`	`60`	`}`
`61`	`61`	`catch (Exception ex)`
`62`	`62`	`{`
`@@ -70,7 +70,7 @@ private async Task ReceiveLoop()`
`70`	`70`	`{`
`71`	`71`	`while (!_closed)`
`72`	`72`	`{`
`73`		`- InboundFrame frame = await _frameHandler.ReadFrame();`
	`73`	`+ InboundFrame frame = await _frameHandler.ReadFrame().ConfigureAwait(false);`
`74`	`74`	`NotifyHeartbeatListener();`
`75`	`75`
`76`	`76`	`bool shallReturn = true;`
`@@ -151,7 +151,7 @@ private async Task HardProtocolExceptionHandler(HardProtocolException hpe)`
`151`	`151`	`_session0.Transmit(in cmd);`
`152`	`152`	`if (hpe.CanShutdownCleanly)`
`153`	`153`	`{`
`154`		`- await ClosingLoop();`
	`154`	`+ await ClosingLoop().ConfigureAwait(false);`
`155`	`155`	`}`
`156`	`156`	`}`
`157`	`157`	`catch (IOException ioe)`
`@@ -174,7 +174,7 @@ private async Task ClosingLoop()`
`174`	`174`	`{`
`175`	`175`	`_frameHandler.ReadTimeout = TimeSpan.Zero;`
`176`	`176`	`// Wait for response/socket closure or timeout`
`177`		`- await ReceiveLoop();`
	`177`	`+ await ReceiveLoop().ConfigureAwait(false);`
`178`	`178`	`}`
`179`	`179`	`catch (ObjectDisposedException ode)`
`180`	`180`	`{`