fixup

Author: lukebakken

RabbitMQ.AMQP.Client/Impl/AmqpManagement.cs

@@ -142,10 +142,8 @@ private void OnManagementSessionClosed(IAmqpObject sender, Amqp.Framing.Error er
 
         OnNewStatus(State.Closed, Utils.ConvertError(error));
 
-        // TODO since this method is also called when a connection is force-closed,
-        // I don't think we want to set this TCS here
         // Note: TrySetResult *must* be used here
-        // _connectionCloseTaskCompletionSource.TrySetResult(true);
+        _connectionCloseTaskCompletionSource.TrySetResult(true);
     }
 
     private async Task ProcessResponses()

RabbitMQ.AMQP.Client/Impl/AmqpPublisher.cs

@@ -125,7 +125,8 @@ void OutcomeCallback(ILink sender, Message message, Outcome outcome, object stat
             {
                 System.Diagnostics.Debug.Assert(Object.ReferenceEquals(this, state));
                 System.Diagnostics.Debug.Assert(Object.ReferenceEquals(_senderLink, sender));
-                System.Diagnostics.Debug.Assert(Object.ReferenceEquals(nativeMessage, message));
+                // Note: sometimes `message` is null 🤔
+                // System.Diagnostics.Debug.Assert(Object.ReferenceEquals(nativeMessage, message));
 
                 OutcomeState publishState = OutcomeState.Accepted;
                 // TODO what about other outcomes, like Released?