class AggregatingJobServiceGateway implements JobServiceGateway {

    @Override
    public Completable killTask(TaskKillRequest request, CallMetadata callMetadata) {
        Observable<Empty> result = findTaskInAllCells(request.getTaskId(), callMetadata)
                .flatMap(response -> singleCellCall(response.getCell(),
                        (client, streamObserver) -> client.killTask(request, streamObserver),
                        callMetadata)
                );
        return result.toCompletable();
    }

    @Inject public  AggregatingJobServiceGateway(GrpcConfiguration grpcConfiguration,
                                        TitusFederationConfiguration federationConfiguration,
                                        CellConnector connector,
                                        CellRouter router,
                                        AggregatingCellClient aggregatingClient,
                                        AggregatingJobManagementServiceHelper jobManagementServiceHelper);

}