()
| 6263 | } |
| 6264 | |
| 6265 | func (x *workerReceivePredicateClient) CloseAndRecv() (*api.Payload, error) { |
| 6266 | if err := x.ClientStream.CloseSend(); err != nil { |
| 6267 | return nil, err |
| 6268 | } |
| 6269 | m := new(api.Payload) |
| 6270 | if err := x.ClientStream.RecvMsg(m); err != nil { |
| 6271 | return nil, err |
| 6272 | } |
| 6273 | return m, nil |
| 6274 | } |
| 6275 | |
| 6276 | func (c *workerClient) MovePredicate(ctx context.Context, in *MovePredicatePayload, opts ...grpc.CallOption) (*api.Payload, error) { |
| 6277 | out := new(api.Payload) |
nothing calls this directly
no outgoing calls
no test coverage detected