| 6548 | } |
| 6549 | |
| 6550 | type workerReceivePredicateServer struct { |
| 6551 | grpc.ServerStream |
| 6552 | } |
| 6553 | |
| 6554 | func (x *workerReceivePredicateServer) SendAndClose(m *api.Payload) error { |
| 6555 | return x.ServerStream.SendMsg(m) |
nothing calls this directly
no outgoing calls
no test coverage detected