diff --git a/driver-core/src/main/com/mongodb/internal/operation/CreateCollectionOperation.java b/driver-core/src/main/com/mongodb/internal/operation/CreateCollectionOperation.java
index 4dc9adad22c..2f087742383 100644
--- a/driver-core/src/main/com/mongodb/internal/operation/CreateCollectionOperation.java
+++ b/driver-core/src/main/com/mongodb/internal/operation/CreateCollectionOperation.java
@@ -552,6 +552,7 @@ class ProcessCommandsCallback implements SingleResultCallback<Void> {
         public void onResult(final Void result, final Throwable t) {
             if (t != null) {
                 finalCallback.onResult(null, t);
+                return;
             }
             Function<ConnectionDescription, BsonDocument> nextCommandFunction = commands.poll();
             if (nextCommandFunction == null) {
diff --git a/driver-core/src/main/com/mongodb/internal/operation/DropCollectionOperation.java b/driver-core/src/main/com/mongodb/internal/operation/DropCollectionOperation.java
index 5d2c7a588f9..888e16f0a61 100644
--- a/driver-core/src/main/com/mongodb/internal/operation/DropCollectionOperation.java
+++ b/driver-core/src/main/com/mongodb/internal/operation/DropCollectionOperation.java
@@ -19,8 +19,8 @@
 import com.mongodb.MongoCommandException;
 import com.mongodb.MongoNamespace;
 import com.mongodb.WriteConcern;
-import com.mongodb.internal.async.SingleResultCallback;
 import com.mongodb.connection.ConnectionDescription;
+import com.mongodb.internal.async.SingleResultCallback;
 import com.mongodb.internal.binding.AsyncReadWriteBinding;
 import com.mongodb.internal.binding.AsyncWriteBinding;
 import com.mongodb.internal.binding.ReadWriteBinding;
@@ -264,6 +264,7 @@ class ProcessCommandsCallback implements SingleResultCallback<Void> {
         public void onResult(final Void result, final Throwable t) {
             if (t != null && !isNamespaceError(t)) {
                 finalCallback.onResult(null, t);
+                return;
             }
             Function<ConnectionDescription, BsonDocument> nextCommandFunction = commands.poll();
             if (nextCommandFunction == null) {