SendQueryStream wraps the stream's Send() checking if the context is done before calling Send().
(s Ingester_QueryStreamServer, m *QueryStreamResponse)
| 7 | // SendQueryStream wraps the stream's Send() checking if the context is done |
| 8 | // before calling Send(). |
| 9 | func SendQueryStream(s Ingester_QueryStreamServer, m *QueryStreamResponse) error { |
| 10 | return sendWithContextErrChecking(s.Context(), func() error { |
| 11 | return s.Send(m) |
| 12 | }) |
| 13 | } |
| 14 | |
| 15 | func SendMetricsForLabelMatchersStream(s Ingester_MetricsForLabelMatchersStreamServer, m *MetricsForLabelMatchersStreamResponse) error { |
| 16 | return sendWithContextErrChecking(s.Context(), func() error { |