Save changes.

Author: kannanjgithub

core/src/main/java/io/grpc/internal/InternalSubchannel.java

@@ -647,8 +647,8 @@ public void run() {
           if (state.getState() == SHUTDOWN) {
             return;
           }
-          if (activeTransports == transport) {
-            activeTransports = null;
+          if (activeTransports.containsKey(transport)) {
+            activeTransports.remove(transport);
             addressIndex.reset();
             gotoNonErrorState(IDLE);
             subchannelMetrics.recordDisconnection(/* target= */ target,