(stream streamingClient[T])
| 190 | } |
| 191 | |
| 192 | func drainStreamingClient[T any](stream streamingClient[T]) error { |
| 193 | for { |
| 194 | resp, err := stream.Recv() |
| 195 | if resp != nil { |
| 196 | break |
| 197 | } |
| 198 | if errors.Is(err, io.EOF) { |
| 199 | return nil |
| 200 | } |
| 201 | if err != nil { |
| 202 | return err |
| 203 | } |
| 204 | } |
| 205 | |
| 206 | return nil |
| 207 | } |
| 208 | |
| 209 | func assertMetricEquals(t *testing.T, service *e2e.HTTPService, metric string, expected float64, labelValues map[string]string) { |
| 210 | t.Helper() |