| 847 | } |
| 848 | |
| 849 | func (c *querierClient) Next(ctx context.Context, in *NextRequest, opts ...grpc.CallOption) (Querier_NextClient, error) { |
| 850 | stream, err := c.cc.NewStream(ctx, &_Querier_serviceDesc.Streams[1], "/querierpb.Querier/Next", opts...) |
| 851 | if err != nil { |
| 852 | return nil, err |
| 853 | } |
| 854 | x := &querierNextClient{stream} |
| 855 | if err := x.ClientStream.SendMsg(in); err != nil { |
| 856 | return nil, err |
| 857 | } |
| 858 | if err := x.ClientStream.CloseSend(); err != nil { |
| 859 | return nil, err |
| 860 | } |
| 861 | return x, nil |
| 862 | } |
| 863 | |
| 864 | type Querier_NextClient interface { |
| 865 | Recv() (*StepVectorBatch, error) |