Newer
Older
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
package event
import (
"testing"
"sync"
"time"
"github.com/stretchr/testify/assert"
evts "github.com/tendermint/go-events"
)
func TestMultiplexedEvents(t *testing.T) {
emitter1 := newMockEventEmitter()
emitter2 := newMockEventEmitter()
emitter12 := Multiplex(emitter1, emitter2)
eventData1 := make(map[evts.EventData]int)
eventData2 := make(map[evts.EventData]int)
eventData12 := make(map[evts.EventData]int)
mutex1 := &sync.Mutex{}
mutex2 := &sync.Mutex{}
mutex12 := &sync.Mutex{}
emitter12.Subscribe("Sub12", "Event12", func(eventData evts.EventData) {
mutex12.Lock()
eventData12[eventData] = 1
mutex12.Unlock()
})
emitter1.Subscribe("Sub1", "Event1", func(eventData evts.EventData) {
mutex1.Lock()
eventData1[eventData] = 1
mutex1.Unlock()
})
emitter2.Subscribe("Sub2", "Event2", func(eventData evts.EventData) {
mutex2.Lock()
eventData2[eventData] = 1
mutex2.Unlock()
})
time.Sleep(mockInterval)
allEventData := make(map[evts.EventData]int)
for k, v := range eventData1 {
allEventData[k] = v
}
for k, v := range eventData2 {
allEventData[k] = v
}
assert.Equal(t, map[evts.EventData]int{mockEventData{"Sub1", "Event1"}: 1},
eventData1)
assert.Equal(t, map[evts.EventData]int{mockEventData{"Sub2", "Event2"}: 1},
eventData2)
assert.Equal(t, map[evts.EventData]int{mockEventData{"Sub12", "Event12"}: 1},
eventData12)
assert.NotEmpty(t, allEventData, "Some events should have been published")
}