chore: make test stable (#3412)
This commit is contained in:
@@ -574,6 +574,7 @@ func TestMapReduceWithContext(t *testing.T) {
|
|||||||
cancel()
|
cancel()
|
||||||
}
|
}
|
||||||
writer.Write(i)
|
writer.Write(i)
|
||||||
|
time.Sleep(time.Millisecond)
|
||||||
}, func(pipe <-chan int, cancel func(error)) {
|
}, func(pipe <-chan int, cancel func(error)) {
|
||||||
for item := range pipe {
|
for item := range pipe {
|
||||||
i := item
|
i := item
|
||||||
|
|||||||
Reference in New Issue
Block a user