| 6404 | } |
| 6405 | |
| 6406 | func _Worker_ServeTask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| 6407 | in := new(Query) |
| 6408 | if err := dec(in); err != nil { |
| 6409 | return nil, err |
| 6410 | } |
| 6411 | if interceptor == nil { |
| 6412 | return srv.(WorkerServer).ServeTask(ctx, in) |
| 6413 | } |
| 6414 | info := &grpc.UnaryServerInfo{ |
| 6415 | Server: srv, |
| 6416 | FullMethod: "/pb.Worker/ServeTask", |
| 6417 | } |
| 6418 | handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
| 6419 | return srv.(WorkerServer).ServeTask(ctx, req.(*Query)) |
| 6420 | } |
| 6421 | return interceptor(ctx, in, info, handler) |
| 6422 | } |
| 6423 | |
| 6424 | func _Worker_StreamSnapshot_Handler(srv interface{}, stream grpc.ServerStream) error { |
| 6425 | return srv.(WorkerServer).StreamSnapshot(&workerStreamSnapshotServer{stream}) |