Using ConfigureAwait(false) to avoid context restoration

src/Microsoft.Azure.EventHubs.Processor/EventHubPartitionPump.cs

@@ -61,7 +61,7 @@ protected override async Task OnOpenAsync()
             if (this.PumpStatus == PartitionPumpStatus.OpenFailed)
             {
                 this.PumpStatus = PartitionPumpStatus.Closing;
-                await this.CleanUpClientsAsync();
+                await this.CleanUpClientsAsync().ConfigureAwait(false);
                 this.PumpStatus = PartitionPumpStatus.Closed;
             }
         }

src/Microsoft.Azure.EventHubs.Processor/PartitionPump.cs

@@ -166,7 +166,7 @@ protected async Task ProcessEventsAsync(IEnumerable<EventData> events)
                 catch (Exception e)
                 {
                     ProcessorEventSource.Log.PartitionPumpInvokeProcessorEventsError(this.Host.Id, this.PartitionContext.PartitionId, e.ToString());
-                    await this.ProcessErrorAsync(e);
+                    await this.ProcessErrorAsync(e).ConfigureAwait(false);
                 }
                 finally
                 {

src/Microsoft.Azure.EventHubs/Amqp/AmqpPartitionReceiver.cs

@@ -299,15 +299,15 @@ async Task ReceivePumpAsync(CancellationToken cancellationToken)
                             batchSize = receiveHandler.MaxBatchSize;
                         }
 
-                        receivedEvents = await this.ReceiveAsync(batchSize);
+                        receivedEvents = await this.ReceiveAsync(batchSize).ConfigureAwait(false);
                     }
                     catch (Exception e)
                     {
                         EventHubsEventSource.Log.ReceiveHandlerExitingWithError(this.ClientId, this.PartitionId, e.Message);
                         await this.ReceiveHandlerProcessErrorAsync(e).ConfigureAwait(false);
 
                         // Avoid tight loop if Receieve call keeps faling.
-                        await Task.Delay(100);
+                        await Task.Delay(100).ConfigureAwait(false);
 
                         continue;
                     }

src/Microsoft.Azure.EventHubs/Amqp/AmqpServiceClient.cs

@@ -171,7 +171,7 @@ internal void OnAbort()
         async Task<RequestResponseAmqpLink> OpenLinkAsync(TimeSpan timeout)
         {
             ActiveClientRequestResponseLink activeClientLink = await OpenRequestResponseLinkAsync(
-                "svc", this.Address, null, AmqpServiceClient.RequiredClaims, timeout);
+                "svc", this.Address, null, AmqpServiceClient.RequiredClaims, timeout).ConfigureAwait(false);
             return activeClientLink.Link;
         }