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

Make the test fail in reasonable time

Browse Source 
License: MIT
Signed-off-by: Jakub Sztandera <kubuxu@protonmail.ch>
This commit is contained in:
Jakub Sztandera 2019-06-22 15:45:09 +02:00
parent 3fd76c7eac
commit 454cbe5497
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
basic_test.go
View File

@ -318,6 +318,11 @@ func TestCloseBlocking(t *testing.T) {
sub.Close() // cancel sub
}
func panicOnTimeout(d time.Duration) {
<-time.After(d)
panic("timeout reached")
}
func TestSubFailFully(t *testing.T) {
bus := NewBus()
em, err := bus.Emitter(new(EventB))
@ -330,6 +335,8 @@ func TestSubFailFully(t *testing.T) {
t.Fatal(err)
}
go panicOnTimeout(5 * time.Second)
em.Emit(EventB(159)) // will hang if sub doesn't fail properly
}