| 1421 | } |
| 1422 | |
| 1423 | type workerReceivePredicateServer struct { |
| 1424 | grpc.ServerStream |
| 1425 | } |
| 1426 | |
| 1427 | func (x *workerReceivePredicateServer) SendAndClose(m *api.Payload) error { |
| 1428 | return x.ServerStream.SendMsg(m) |
nothing calls this directly
no outgoing calls
no test coverage detected