(srv interface{}, stream grpc.ServerStream)
| 6538 | } |
| 6539 | |
| 6540 | func _Worker_ReceivePredicate_Handler(srv interface{}, stream grpc.ServerStream) error { |
| 6541 | return srv.(WorkerServer).ReceivePredicate(&workerReceivePredicateServer{stream}) |
| 6542 | } |
| 6543 | |
| 6544 | type Worker_ReceivePredicateServer interface { |
| 6545 | SendAndClose(*api.Payload) error |
nothing calls this directly
no test coverage detected