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

Simplify withNode a bit

Browse Source
This commit is contained in:
Łukasz Magiera 2019-06-19 12:31:36 +02:00
parent 5b845983c2
commit c54e8ebbe9
1 changed files with 5 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
basic.go
View File

@ -36,19 +36,12 @@ func (b *bus) withNode(typ reflect.Type, cb func(*node), async func(*node)) erro
n.lk.Lock()
b.lk.Unlock()
ok = false
defer func() {
if !ok {
n.lk.Unlock()
}
go func() {
defer n.lk.Unlock()
async(n)
}()
}()
cb(n)
ok = true
go func() {
defer n.lk.Unlock()
async(n)
}()
return nil
}