libp2p/go-eventbus
1
0
Fork 0
mirror of https://github.com/libp2p/go-eventbus.git synced 2025-03-25 12:10:06 +08:00
Code Issues Projects Releases Wiki Activity

Return error when closing already closed emitter

Browse Source
This commit is contained in:
Cole Brown 2019-07-31 19:46:51 -04:00
parent b1629519a0
commit 217da8e826
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
basic.go
View File

@ -38,7 +38,7 @@ func (e *emitter) Emit(evt interface{}) error {
func (e *emitter) Close() error {
if !atomic.CompareAndSwapInt32(&e.closed, 0, 1) {
panic("closed an emitter more than once")
return fmt.Errorf("closed an emitter more than once")
}
if atomic.AddInt32(&e.n.nEmitters, -1) == 0 {
e.dropper(e.typ)