| 934 | } |
| 935 | |
| 936 | type querierNextServer struct { |
| 937 | grpc.ServerStream |
| 938 | } |
| 939 | |
| 940 | func (x *querierNextServer) Send(m *StepVectorBatch) error { |
| 941 | return x.ServerStream.SendMsg(m) |
nothing calls this directly
no outgoing calls
no test coverage detected