pubsub: slightly loosen TestStreamingPull_ClosedClient
Things take a while to close. Also, the wait for Receive doesn't have
to be an entire second - this takes it down to 100ms.
@@ -291,13 +291,17 @@ func TestStreamingPull_ClosedClient(t *testing.T) {
recvFinished <- err
}()
- time.Sleep(time.Second)
+ // wait for receives to happen
+ time.Sleep(100 * time.Millisecond)
err := client.Close()
if err != nil {
t.Fatal(err)
}
+ // wait for things to close
+ time.Sleep(100 * time.Millisecond)
+
select {
case recvErr := <-recvFinished:
s, ok := status.FromError(recvErr)
