opensource/kubo
1
0
Fork 0
mirror of https://github.com/ipfs/kubo.git synced 2025-06-29 09:34:03 +08:00
Code Issues Projects Releases Wiki Activity

test(bitswap:notifications) check if chan is open

Browse Source
This commit is contained in:
Brian Tiger Chow
2014-09-12 03:28:11 -07:00
parent a7ef09554f
commit 2f4175a00d
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
bitswap/notifications/notifications_test.go
View File

@ -18,9 +18,13 @@ func TestPublishSubscribe(t *testing.T) {
ch := n.Subscribe(context.Background(), blockSent.Key()) ch := n.Subscribe(context.Background(), blockSent.Key())
n.Publish(blockSent) n.Publish(blockSent)
blockRecvd := <-ch blockRecvd, ok := <-ch
if !ok {
t.Fail()
}
assertBlocksEqual(t, blockRecvd, blockSent) assertBlocksEqual(t, blockRecvd, blockSent)
} }
func TestCarryOnWhenDeadlineExpires(t *testing.T) { func TestCarryOnWhenDeadlineExpires(t *testing.T) {