Skip to content

Commit 69c66e3

Browse files
committed
refactor(topology): flush store entries before topology destroy
1 parent 6c390a4 commit 69c66e3

File tree

1 file changed

+6
-6
lines changed

1 file changed

+6
-6
lines changed

lib/topologies/topology_base.js

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -390,18 +390,18 @@ class TopologyBase extends EventEmitter {
390390
this.s.sessionPool.endAllPooledSessions();
391391
}
392392

393+
// We need to wash out all stored processes
394+
if (forceClosed === true) {
395+
this.s.storeOptions.force = forceClosed;
396+
this.s.store.flush();
397+
}
398+
393399
this.s.coreTopology.destroy(
394400
{
395401
force: typeof forceClosed === 'boolean' ? forceClosed : false
396402
},
397403
callback
398404
);
399-
400-
// We need to wash out all stored processes
401-
if (forceClosed === true) {
402-
this.s.storeOptions.force = forceClosed;
403-
this.s.store.flush();
404-
}
405405
}
406406
}
407407

0 commit comments

Comments
 (0)