refactor: no need defer in closeAll
Signed-off-by: Michael Wan <zirenwan@gmail.com>
This commit is contained in:
parent
e1383c3d23
commit
9639db5522
@ -138,10 +138,10 @@ func (e *Exchange) Subscribe(ctx context.Context, fs ...string) (ch <-chan *even
|
|||||||
)
|
)
|
||||||
|
|
||||||
closeAll := func() {
|
closeAll := func() {
|
||||||
defer close(errq)
|
channel.Close()
|
||||||
defer e.broadcaster.Remove(dst)
|
queue.Close()
|
||||||
defer queue.Close()
|
e.broadcaster.Remove(dst)
|
||||||
defer channel.Close()
|
close(errq)
|
||||||
}
|
}
|
||||||
|
|
||||||
ch = evch
|
ch = evch
|
||||||
|
Loading…
Reference in New Issue
Block a user