Minor refactoring so cancellation exceptions can be handled in a sing…

…le try/catch block instead of having more than one

Signed-off-by: Whit Waldo <whit.waldo@innovian.net>

src/Dapr.Messaging/PublishSubscribe/PublishSubscribeReceiver.cs

@@ -98,15 +98,15 @@ public async Task SubscribeAsync(CancellationToken cancellationToken = default)
         //Retrieve the messages from the sidecar and write to the messages channel
         _ = FetchDataFromSidecarAsync(stream, channel.Writer, cancellationToken);
 
-        //Processes each acknowledgement from the acknowledgement channel reader as it's populated
-        await foreach (var acknowledgement in acknowledgements.Reader.ReadAllAsync(cancellationToken))
-        {
-            await ProcessAcknowledgementAsync(acknowledgement);
-        }
-
-        //Read the messages one-by-one out of the messages channel
         try
         {
+            //Processes each acknowledgement from the acknowledgement channel reader as it's populated
+            await foreach (var acknowledgement in acknowledgements.Reader.ReadAllAsync(cancellationToken))
+            {
+                await ProcessAcknowledgementAsync(acknowledgement);
+            }
+
+            //Read the messages one-by-one out of the messages channel
             while (await channel.Reader.WaitToReadAsync(cancellationToken))
             {
                 while (channel.Reader.TryRead(out var message))