mirror of https://github.com/milvus-io/milvus.git
parent
f4deb6d2d7
commit
6168c0b9c7
|
@ -195,7 +195,7 @@ func TestPulsarClient_Consume1(t *testing.T) {
|
|||
|
||||
// launch produce
|
||||
Produce(ctx, t, pc, topic, arr)
|
||||
time.Sleep(1 * time.Second)
|
||||
time.Sleep(100 * time.Millisecond)
|
||||
|
||||
// launch consume1
|
||||
ctx1, cancel1 := context.WithTimeout(ctx, 2*time.Second)
|
||||
|
@ -346,7 +346,7 @@ func TestPulsarClient_Consume2(t *testing.T) {
|
|||
|
||||
// launch produce
|
||||
Produce(ctx, t, pc, topic, arr)
|
||||
time.Sleep(1 * time.Second)
|
||||
time.Sleep(100 * time.Millisecond)
|
||||
|
||||
// launch consume1
|
||||
ctx1, cancel1 := context.WithTimeout(ctx, 2*time.Second)
|
||||
|
|
|
@ -120,7 +120,7 @@ func TestContextCancel(t *testing.T) {
|
|||
}
|
||||
|
||||
go func() {
|
||||
time.Sleep(1 * time.Second)
|
||||
time.Sleep(100 * time.Millisecond)
|
||||
cancel()
|
||||
}()
|
||||
|
||||
|
|
Loading…
Reference in New Issue