We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 0b7788e commit ee0db01Copy full SHA for ee0db01
lib/operations/close.js
@@ -3,6 +3,7 @@
3
const Aspect = require('./operation').Aspect;
4
const defineAspects = require('./operation').defineAspects;
5
const OperationBase = require('./operation').OperationBase;
6
+const NativeTopology = require('../topologies/native_topology');
7
8
class CloseOperation extends OperationBase {
9
constructor(client, force) {
@@ -16,8 +17,11 @@ class CloseOperation extends OperationBase {
16
17
const force = this.force;
18
const completeClose = err => {
19
client.emit('close', client);
- for (const item of client.s.dbCache) {
20
- item[1].emit('close', client);
+
21
+ if (!(client.topology instanceof NativeTopology)) {
22
+ for (const item of client.s.dbCache) {
23
+ item[1].emit('close', client);
24
+ }
25
}
26
27
client.removeAllListeners('close');
0 commit comments