JAVA-2778: Release AsyncConnectionSource in ListDatabasesOperation

jyemin · jyemin · commit ff5db7411982 · 2018-02-12T09:04:21.000-05:00
diff --git a/driver-core/src/main/com/mongodb/operation/ListDatabasesOperation.java b/driver-core/src/main/com/mongodb/operation/ListDatabasesOperation.java
@@ -172,7 +172,7 @@ public void call(final AsyncConnectionSource source, final AsyncConnection conne
                 } else {
                     executeWrappedCommandProtocolAsync(binding,  "admin", getCommand(),
                             CommandResultDocumentCodec.create(decoder, "databases"), connection, asyncTransformer(source, connection),
-                            releasingCallback(errHandlingCallback, connection));
+                            releasingCallback(errHandlingCallback, source, connection));
                 }
             }
         });

Original file line number	Diff line number	Diff line change
`@@ -172,7 +172,7 @@ public void call(final AsyncConnectionSource source, final AsyncConnection conne`
`172`	`172`	`} else {`
`173`	`173`	`executeWrappedCommandProtocolAsync(binding, "admin", getCommand(),`
`174`	`174`	`CommandResultDocumentCodec.create(decoder, "databases"), connection, asyncTransformer(source, connection),`
`175`		`- releasingCallback(errHandlingCallback, connection));`
	`175`	`+ releasingCallback(errHandlingCallback, source, connection));`
`176`	`176`	`}`
`177`	`177`	`}`
`178`	`178`	`});`