(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor)
| 6564 | } |
| 6565 | |
| 6566 | func _Worker_MovePredicate_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| 6567 | in := new(MovePredicatePayload) |
| 6568 | if err := dec(in); err != nil { |
| 6569 | return nil, err |
| 6570 | } |
| 6571 | if interceptor == nil { |
| 6572 | return srv.(WorkerServer).MovePredicate(ctx, in) |
| 6573 | } |
| 6574 | info := &grpc.UnaryServerInfo{ |
| 6575 | Server: srv, |
| 6576 | FullMethod: "/pb.Worker/MovePredicate", |
| 6577 | } |
| 6578 | handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
| 6579 | return srv.(WorkerServer).MovePredicate(ctx, req.(*MovePredicatePayload)) |
| 6580 | } |
| 6581 | return interceptor(ctx, in, info, handler) |
| 6582 | } |
| 6583 | |
| 6584 | func _Worker_Subscribe_Handler(srv interface{}, stream grpc.ServerStream) error { |
| 6585 | m := new(SubscriptionRequest) |
nothing calls this directly
no test coverage detected