File tree Expand file tree Collapse file tree 2 files changed +3
-1
lines changed
driver-core/src/main/com/mongodb/internal/operation Expand file tree Collapse file tree 2 files changed +3
-1
lines changed Original file line number Diff line number Diff line change @@ -552,6 +552,7 @@ class ProcessCommandsCallback implements SingleResultCallback<Void> {
552552 public void onResult (final Void result , final Throwable t ) {
553553 if (t != null ) {
554554 finalCallback .onResult (null , t );
555+ return ;
555556 }
556557 Function <ConnectionDescription , BsonDocument > nextCommandFunction = commands .poll ();
557558 if (nextCommandFunction == null ) {
Original file line number Diff line number Diff line change 1919import com .mongodb .MongoCommandException ;
2020import com .mongodb .MongoNamespace ;
2121import com .mongodb .WriteConcern ;
22- import com .mongodb .internal .async .SingleResultCallback ;
2322import com .mongodb .connection .ConnectionDescription ;
23+ import com .mongodb .internal .async .SingleResultCallback ;
2424import com .mongodb .internal .binding .AsyncReadWriteBinding ;
2525import com .mongodb .internal .binding .AsyncWriteBinding ;
2626import com .mongodb .internal .binding .ReadWriteBinding ;
@@ -264,6 +264,7 @@ class ProcessCommandsCallback implements SingleResultCallback<Void> {
264264 public void onResult (final Void result , final Throwable t ) {
265265 if (t != null && !isNamespaceError (t )) {
266266 finalCallback .onResult (null , t );
267+ return ;
267268 }
268269 Function <ConnectionDescription , BsonDocument > nextCommandFunction = commands .poll ();
269270 if (nextCommandFunction == null ) {
You can’t perform that action at this time.
0 commit comments