libp2p/go-eventbus
1
0
Fork 0
mirror of https://github.com/libp2p/go-eventbus.git synced 2024-12-26 23:30:08 +08:00
Code Issues Projects Releases Wiki Activity

BasicBus to basicBus

Browse Source
This commit is contained in:
Łukasz Magiera 2019-06-19 15:00:22 +02:00
parent 401bb25f47
commit 04b7ec33de
2 changed files with 10 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
basic.go
View File

@ -11,18 +11,18 @@ import (
///////////////////////
// BUS
type BasicBus struct {
type basicBus struct {
lk sync.Mutex
nodes map[reflect.Type]*node
}
func NewBus() Bus {
return &BasicBus{
func NewBus() *basicBus {
return &basicBus{
nodes: map[reflect.Type]*node{},
}
}
func (b *BasicBus) withNode(typ reflect.Type, cb func(*node), async func(*node)) error {
func (b *basicBus) withNode(typ reflect.Type, cb func(*node), async func(*node)) error {
b.lk.Lock()
n, ok := b.nodes[typ]
@ -44,7 +44,7 @@ func (b *BasicBus) withNode(typ reflect.Type, cb func(*node), async func(*node))
return nil
}
func (b *BasicBus) tryDropNode(typ reflect.Type) {
func (b *basicBus) tryDropNode(typ reflect.Type) {
b.lk.Lock()
n, ok := b.nodes[typ]
if !ok { // already dropped
@ -64,7 +64,7 @@ func (b *BasicBus) tryDropNode(typ reflect.Type) {
b.lk.Unlock()
}
func (b *BasicBus) Subscribe(typedChan interface{}, opts ...SubOption) (c CancelFunc, err error) {
func (b *basicBus) Subscribe(typedChan interface{}, opts ...SubOption) (c CancelFunc, err error) {
var settings subSettings
for _, opt := range opts {
if err := opt(&settings); err != nil {
@ -118,7 +118,7 @@ func (b *BasicBus) Subscribe(typedChan interface{}, opts ...SubOption) (c Cancel
return
}
func (b *BasicBus) Emitter(evtType interface{}, opts ...EmitterOption) (e EmitFunc, err error) {
func (b *basicBus) Emitter(evtType interface{}, opts ...EmitterOption) (e EmitFunc, err error) {
var settings emitterSettings
for _, opt := range opts {
opt(&settings)
@ -156,7 +156,7 @@ func (b *BasicBus) Emitter(evtType interface{}, opts ...EmitterOption) (e EmitFu
// NODE
type node struct {
// Note: make sure to NEVER lock BasicBus.lk when this lock is held
// Note: make sure to NEVER lock basicBus.lk when this lock is held
lk sync.RWMutex
typ reflect.Type
@ -196,4 +196,4 @@ func (n *node) emit(event interface{}) {
///////////////////////
// UTILS
var _ Bus = &BasicBus{}
var _ Bus = &basicBus{}

2
basic_test.go
View File

@ -156,7 +156,7 @@ func TestClosingRaces(t *testing.T) {
wg.Wait()
if len(b.(*BasicBus).nodes) != 0 {
if len(b.nodes) != 0 {
t.Error("expected no nodes")
}
}