ReactiveDeploy.java

	@Override
	public Flux<DeploymentState> deploy(AppDeploymentRequest request) {
		logger.trace("Entered deploy: Deploying AppDeploymentRequest: AppDefinition = {}, Resource = {}, Deployment Properties = {}",
				request.getDefinition(), request.getResource(), request.getDeploymentProperties());
		String deploymentId = deploymentId(request);

		logger.trace("deploy: Pushing application");
		return pushApplication(deploymentId, request)
			.timeout(Duration.ofSeconds(this.deploymentProperties.getApiTimeout()))
			.doOnError(error -> {
				if (isNotFoundError().test(error)) {
					logger.warn("Unable to deploy application. It may have been destroyed before start completed: " + error.getMessage());
				}
				else {
					logError(String.format("Failed to deploy %s", deploymentId)).accept(error);
				}
			})
			.then(getStatus(deploymentId))
			.repeat()
			.map(AppStatus::getState)
			.distinctUntilChanged()
			.takeUntil(pred -> pred.equals(DeploymentState.deployed));
	}