kemko/nomad
1
0
Fork 0
mirror of https://github.com/kemko/nomad.git synced 2026-01-04 01:15:43 +03:00
Code Issues Packages Projects Releases Wiki Activity

tests: defer closing shutdownCh

Browse Source
This commit is contained in:
Mahmood Ali
2020-01-28 09:53:48 -05:00
parent 94a75b4744
commit 8ae03c32fa
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
nomad/util_test.go
View File

@@ -263,6 +263,7 @@ func TestMaxUint64(t *testing.T) {
func TestDropButLastChannelDropsValues(t *testing.T) {
sourceCh := make(chan bool)
shutdownCh := make(chan struct{})
defer close(shutdownCh)
dstCh := dropButLastChannel(sourceCh, shutdownCh)
@@ -327,8 +328,6 @@ func TestDropButLastChannelDropsValues(t *testing.T) {
case <-time.After(timeoutDuration):
require.Fail(t, "timed out waiting for source->dstCh propagation")
}
close(shutdownCh)
}
// TestDropButLastChannel_DeliversMessages asserts that last
@@ -338,6 +337,7 @@ func TestDropButLastChannelDropsValues(t *testing.T) {
func TestDropButLastChannel_DeliversMessages(t *testing.T) {
sourceCh := make(chan bool)
shutdownCh := make(chan struct{})
defer close(shutdownCh)
dstCh := dropButLastChannel(sourceCh, shutdownCh)
@@ -386,6 +386,7 @@ RECEIVE_LOOP:
func TestDropButLastChannel_DeliversMessages_Close(t *testing.T) {
sourceCh := make(chan bool)
shutdownCh := make(chan struct{})
defer close(shutdownCh)
dstCh := dropButLastChannel(sourceCh, shutdownCh)