class AggregatingLoadbalancerService implements LoadBalancerService {

    @Override
    public Completable addLoadBalancer(AddLoadBalancerRequest request, CallMetadata callMetadata) {
        JobId jobId = JobId.newBuilder().setId(request.getJobId()).build();
        final Observable<Empty> responseObservable = jobManagementServiceHelper.findJobInAllCells(jobId.getId(), callMetadata)
                .flatMap(response -> singleCellCall(response.getCell(),
                        (client, responseObserver) -> client.addLoadBalancer(request, responseObserver),
                        callMetadata));
        return responseObservable.toCompletable();
    }

    @Inject public  AggregatingLoadbalancerService(CellConnector connector,
                                          CallMetadataResolver callMetadataResolver,
                                          GrpcConfiguration grpcConfiguration,
                                          AggregatingCellClient aggregatingClient,
                                          AggregatingJobManagementServiceHelper jobManagementServiceHelper);

}