Prevent duplicate bus shutdowns on container destroy; bump version
This commit is contained in:
@@ -234,6 +234,8 @@ export class Bus<TEvent extends Event = Event> extends Unit implements EventBus<
|
||||
}
|
||||
|
||||
onContainerDestroy(): Awaitable<void> {
|
||||
this.down()
|
||||
if ( this.isUp ) {
|
||||
this.down()
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@@ -139,6 +139,8 @@ export class LocalBus<TEvent extends Event = Event> extends CanonicalItemClass i
|
||||
}
|
||||
|
||||
onContainerRelease(): Awaitable<void> {
|
||||
this.down()
|
||||
if ( this.isUp ) {
|
||||
this.down()
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user