We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent e292a79 commit f237c9dCopy full SHA for f237c9d
src/sdam/topology.ts
@@ -509,6 +509,13 @@ export class Topology extends TypedEventEmitter<TopologyEvents> {
509
this.removeListener(Topology.TOPOLOGY_DESCRIPTION_CHANGED, this.s.detectShardedTopology);
510
511
stateTransition(this, STATE_CLOSED);
512
+ this.s.description = new TopologyDescription(TopologyType.Unknown, new Map());
513
+
514
+ // broadcast that topology is in closed state
515
+ this.emitAndLog(
516
+ Topology.TOPOLOGY_DESCRIPTION_CHANGED,
517
+ new TopologyDescriptionChangedEvent(this.s.id, previousDescription, this.s.description)
518
+ );
519
520
// emit an event for close
521
this.emitAndLog(Topology.TOPOLOGY_CLOSED, new TopologyClosedEvent(this.s.id));
0 commit comments