Class TaskImpl

src/main/java/org/cryptomator/ui/common/Tasks.java:124–166

Adapter between java.util.function. and javafx.concurrent.

	 * Adapter between java.util.function.* and javafx.concurrent.*
	 */
	private static class TaskImpl<T> extends Task<T> {

		private final Callable<T> callable;
		private final Consumer<T> successHandler;
		private List<ErrorHandler<?>> errorHandlers;
		private final Runnable finallyHandler;

		TaskImpl(Callable<T> callable, Consumer<T> successHandler, List<ErrorHandler<?>> errorHandlers, Runnable finallyHandler) {
			this.callable = callable;
			this.successHandler = successHandler;
			this.errorHandlers = errorHandlers;
			this.finallyHandler = finallyHandler;
		}

		@Override
		protected T call() throws Exception {
			return callable.call();
		}

		@Override
		protected void succeeded() {
			try {
				successHandler.accept(getValue());
			} finally {
				finallyHandler.run();
			}
		}

		@Override
		protected void failed() {
			try {
				Throwable exception = getException();
				errorHandlers.stream().filter(handler -> handler.handles(exception)).findFirst().ifPresentOrElse(exceptionHandler -> {
					exceptionHandler.handle(exception);
				}, () -> {
					LOG.error("Unhandled exception", exception);
				});
			} finally {
				finallyHandler.run();
			}
		}

	}

	/**
	 * A service that keeps executing the next task long as tasks are succeeding.