Compare commits
1 Commits
2023.10.20
...
2023.10.21
Author | SHA1 | Date | |
---|---|---|---|
de4ab0d02c |
@ -83,8 +83,12 @@ func (d *eventDispatcher) Close() {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (d *eventDispatcher) close() {
|
func (d *eventDispatcher) close() {
|
||||||
d.closed = true
|
if d.closed {
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
close(d.in)
|
close(d.in)
|
||||||
|
d.closed = true
|
||||||
}
|
}
|
||||||
|
|
||||||
func (d *eventDispatcher) In(msg bus.Message) (err error) {
|
func (d *eventDispatcher) In(msg bus.Message) (err error) {
|
||||||
|
Reference in New Issue
Block a user