| 478 | type NodeService_SyncUserServer = grpc.ClientStreamingServer[User, Empty] |
| 479 | |
| 480 | func _NodeService_SyncUsers_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { |
| 481 | in := new(Users) |
| 482 | if err := dec(in); err != nil { |
| 483 | return nil, err |
| 484 | } |
| 485 | if interceptor == nil { |
| 486 | return srv.(NodeServiceServer).SyncUsers(ctx, in) |
| 487 | } |
| 488 | info := &grpc.UnaryServerInfo{ |
| 489 | Server: srv, |
| 490 | FullMethod: NodeService_SyncUsers_FullMethodName, |
| 491 | } |
| 492 | handler := func(ctx context.Context, req interface{}) (interface{}, error) { |
| 493 | return srv.(NodeServiceServer).SyncUsers(ctx, req.(*Users)) |
| 494 | } |
| 495 | return interceptor(ctx, in, info, handler) |
| 496 | } |
| 497 | |
| 498 | func _NodeService_SyncUsersChunked_Handler(srv interface{}, stream grpc.ServerStream) error { |
| 499 | return srv.(NodeServiceServer).SyncUsersChunked(&grpc.GenericServerStream[UsersChunk, Empty]{ServerStream: stream}) |