accumulator, BiConsumer combiner) {
- try {
- return super.collect(supplier, accumulator, combiner);
- } finally {
- close();
- }
- }
-
- @Override
- public long sum() {
- try {
- return super.sum();
- } finally {
- close();
- }
- }
-
- @Override
- public OptionalLong min() {
- try {
- return super.min();
- } finally {
- close();
- }
- }
-
- @Override
- public OptionalLong max() {
- try {
- return super.max();
- } finally {
- close();
- }
- }
-
- @Override
- public long count() {
- try {
- return super.count();
- } finally {
- close();
- }
- }
-
- @Override
- public OptionalDouble average() {
- try {
- return super.average();
- } finally {
- close();
- }
- }
-
- @Override
- public LongSummaryStatistics summaryStatistics() {
- try {
- return super.summaryStatistics();
- } finally {
- close();
- }
- }
-
- @Override
- public boolean anyMatch(LongPredicate predicate) {
- try {
- return super.anyMatch(predicate);
- } finally {
- close();
- }
- }
-
- @Override
- public boolean allMatch(LongPredicate predicate) {
- try {
- return super.allMatch(predicate);
- } finally {
- close();
- }
- }
-
- @Override
- public boolean noneMatch(LongPredicate predicate) {
- try {
- return super.noneMatch(predicate);
- } finally {
- close();
- }
- }
-
- @Override
- public OptionalLong findFirst() {
- try {
- return super.findFirst();
- } finally {
- close();
- }
- }
-
- @Override
- public OptionalLong findAny() {
- try {
- return super.findAny();
- } finally {
- close();
- }
- }
-
-}
diff --git a/main/commons/src/main/java/org/cryptomator/common/streams/AutoClosingStream.java b/main/commons/src/main/java/org/cryptomator/common/streams/AutoClosingStream.java
deleted file mode 100644
index 7207bcf02..000000000
--- a/main/commons/src/main/java/org/cryptomator/common/streams/AutoClosingStream.java
+++ /dev/null
@@ -1,173 +0,0 @@
-package org.cryptomator.common.streams;
-
-import static org.cryptomator.common.streams.AutoClosingStreamFactory.AUTO_CLOSING_STREAM_FACTORY;
-
-import java.util.Comparator;
-import java.util.Optional;
-import java.util.function.BiConsumer;
-import java.util.function.BiFunction;
-import java.util.function.BinaryOperator;
-import java.util.function.Consumer;
-import java.util.function.IntFunction;
-import java.util.function.Predicate;
-import java.util.function.Supplier;
-import java.util.stream.Collector;
-import java.util.stream.Stream;
-
-/**
- *
- * A Stream which is automatically closed after execution of a terminal operation.
- *
- * Streams returned by intermediate operations are also auto closing.
- *
- * Note: When using {@link #iterator()} or {@link #spliterator()} auto closing does not occur.
- *
- * @author Markus Kreusch
- */
-public class AutoClosingStream extends DelegatingStream {
-
- public static Stream from(Stream delegate) {
- return new AutoClosingStream<>(delegate);
- }
-
- private AutoClosingStream(Stream delegate) {
- super(delegate, AUTO_CLOSING_STREAM_FACTORY);
- }
-
- public void forEach(Consumer action) {
- try {
- super.forEach(action);
- } finally {
- close();
- }
- }
-
- public void forEachOrdered(Consumer action) {
- try {
- super.forEachOrdered(action);
- } finally {
- close();
- }
- }
-
- public Object[] toArray() {
- try {
- return super.toArray();
- } finally {
- close();
- }
- }
-
- public A[] toArray(IntFunction generator) {
- try {
- return super.toArray(generator);
- } finally {
- close();
- }
- }
-
- public T reduce(T identity, BinaryOperator accumulator) {
- try {
- return super.reduce(identity, accumulator);
- } finally {
- close();
- }
- }
-
- public Optional reduce(BinaryOperator accumulator) {
- try {
- return super.reduce(accumulator);
- } finally {
- close();
- }
- }
-
- public U reduce(U identity, BiFunction accumulator, BinaryOperator combiner) {
- try {
- return super.reduce(identity, accumulator, combiner);
- } finally {
- close();
- }
- }
-
- public R collect(Supplier supplier, BiConsumer accumulator, BiConsumer combiner) {
- try {
- return super.collect(supplier, accumulator, combiner);
- } finally {
- close();
- }
- }
-
- public R collect(Collector collector) {
- try {
- return super.collect(collector);
- } finally {
- close();
- }
- }
-
- public Optional min(Comparator comparator) {
- try {
- return super.min(comparator);
- } finally {
- close();
- }
- }
-
- public Optional max(Comparator comparator) {
- try {
- return super.max(comparator);
- } finally {
- close();
- }
- }
-
- public long count() {
- try {
- return super.count();
- } finally {
- close();
- }
- }
-
- public boolean anyMatch(Predicate predicate) {
- try {
- return super.anyMatch(predicate);
- } finally {
- close();
- }
- }
-
- public boolean allMatch(Predicate predicate) {
- try {
- return super.allMatch(predicate);
- } finally {
- close();
- }
- }
-
- public boolean noneMatch(Predicate predicate) {
- try {
- return super.noneMatch(predicate);
- } finally {
- close();
- }
- }
-
- public Optional findFirst() {
- try {
- return super.findFirst();
- } finally {
- close();
- }
- }
-
- public Optional findAny() {
- try {
- return super.findAny();
- } finally {
- close();
- }
- }
-
-}
diff --git a/main/commons/src/main/java/org/cryptomator/common/streams/AutoClosingStreamFactory.java b/main/commons/src/main/java/org/cryptomator/common/streams/AutoClosingStreamFactory.java
deleted file mode 100644
index 18b8ab4d8..000000000
--- a/main/commons/src/main/java/org/cryptomator/common/streams/AutoClosingStreamFactory.java
+++ /dev/null
@@ -1,51 +0,0 @@
-package org.cryptomator.common.streams;
-
-import java.util.stream.DoubleStream;
-import java.util.stream.IntStream;
-import java.util.stream.LongStream;
-import java.util.stream.Stream;
-
-class AutoClosingStreamFactory implements DelegatingStreamFactory {
-
- public static final DelegatingStreamFactory AUTO_CLOSING_STREAM_FACTORY = new AutoClosingStreamFactory();
-
- private AutoClosingStreamFactory() {
- }
-
- @Override
- public Stream from(Stream other) {
- if (AutoClosingStream.class.isInstance(other)) {
- return other;
- } else {
- return AutoClosingStream.from(other);
- }
- }
-
- @Override
- public IntStream from(IntStream other) {
- if (AutoClosingIntStream.class.isInstance(other)) {
- return other;
- } else {
- return AutoClosingIntStream.from(other);
- }
- }
-
- @Override
- public LongStream from(LongStream other) {
- if (AutoClosingLongStream.class.isInstance(other)) {
- return other;
- } else {
- return AutoClosingLongStream.from(other);
- }
- }
-
- @Override
- public DoubleStream from(DoubleStream other) {
- if (AutoClosingDoubleStream.class.isInstance(other)) {
- return other;
- } else {
- return AutoClosingDoubleStream.from(other);
- }
- }
-
-}
diff --git a/main/commons/src/main/java/org/cryptomator/common/streams/DelegatingDoubleStream.java b/main/commons/src/main/java/org/cryptomator/common/streams/DelegatingDoubleStream.java
deleted file mode 100644
index 8fca0e7fd..000000000
--- a/main/commons/src/main/java/org/cryptomator/common/streams/DelegatingDoubleStream.java
+++ /dev/null
@@ -1,179 +0,0 @@
-package org.cryptomator.common.streams;
-
-import java.util.DoubleSummaryStatistics;
-import java.util.OptionalDouble;
-import java.util.PrimitiveIterator.OfDouble;
-import java.util.function.BiConsumer;
-import java.util.function.DoubleBinaryOperator;
-import java.util.function.DoubleConsumer;
-import java.util.function.DoubleFunction;
-import java.util.function.DoublePredicate;
-import java.util.function.DoubleToIntFunction;
-import java.util.function.DoubleToLongFunction;
-import java.util.function.DoubleUnaryOperator;
-import java.util.function.ObjDoubleConsumer;
-import java.util.function.Supplier;
-import java.util.stream.DoubleStream;
-import java.util.stream.IntStream;
-import java.util.stream.LongStream;
-import java.util.stream.Stream;
-
-abstract class DelegatingDoubleStream implements DoubleStream {
-
- private final DoubleStream delegate;
- private final DelegatingStreamFactory wrapper;
-
- public DelegatingDoubleStream(DoubleStream delegate, DelegatingStreamFactory wrapper) {
- this.delegate = delegate;
- this.wrapper = wrapper;
- }
-
- public DoubleStream filter(DoublePredicate predicate) {
- return wrapper.from(delegate.filter(predicate));
- }
-
- public boolean isParallel() {
- return delegate.isParallel();
- }
-
- public DoubleStream map(DoubleUnaryOperator mapper) {
- return wrapper.from(delegate.map(mapper));
- }
-
- public Stream mapToObj(DoubleFunction mapper) {
- return wrapper.from(delegate.mapToObj(mapper));
- }
-
- public DoubleStream unordered() {
- return wrapper.from(delegate.unordered());
- }
-
- public DoubleStream onClose(Runnable closeHandler) {
- return wrapper.from(delegate.onClose(closeHandler));
- }
-
- public IntStream mapToInt(DoubleToIntFunction mapper) {
- return wrapper.from(delegate.mapToInt(mapper));
- }
-
- public LongStream mapToLong(DoubleToLongFunction mapper) {
- return wrapper.from(delegate.mapToLong(mapper));
- }
-
- public void close() {
- delegate.close();
- }
-
- public DoubleStream flatMap(DoubleFunction mapper) {
- return wrapper.from(delegate.flatMap(mapper));
- }
-
- public DoubleStream distinct() {
- return wrapper.from(delegate.distinct());
- }
-
- public DoubleStream sorted() {
- return wrapper.from(delegate.sorted());
- }
-
- public DoubleStream peek(DoubleConsumer action) {
- return wrapper.from(delegate.peek(action));
- }
-
- public DoubleStream limit(long maxSize) {
- return wrapper.from(delegate.limit(maxSize));
- }
-
- public DoubleStream skip(long n) {
- return wrapper.from(delegate.skip(n));
- }
-
- public void forEach(DoubleConsumer action) {
- delegate.forEach(action);
- }
-
- public void forEachOrdered(DoubleConsumer action) {
- delegate.forEachOrdered(action);
- }
-
- public double[] toArray() {
- return delegate.toArray();
- }
-
- public double reduce(double identity, DoubleBinaryOperator op) {
- return delegate.reduce(identity, op);
- }
-
- public OptionalDouble reduce(DoubleBinaryOperator op) {
- return delegate.reduce(op);
- }
-
- public R collect(Supplier supplier, ObjDoubleConsumer accumulator, BiConsumer combiner) {
- return delegate.collect(supplier, accumulator, combiner);
- }
-
- public double sum() {
- return delegate.sum();
- }
-
- public OptionalDouble min() {
- return delegate.min();
- }
-
- public OptionalDouble max() {
- return delegate.max();
- }
-
- public long count() {
- return delegate.count();
- }
-
- public OptionalDouble average() {
- return delegate.average();
- }
-
- public DoubleSummaryStatistics summaryStatistics() {
- return delegate.summaryStatistics();
- }
-
- public boolean anyMatch(DoublePredicate predicate) {
- return delegate.anyMatch(predicate);
- }
-
- public boolean allMatch(DoublePredicate predicate) {
- return delegate.allMatch(predicate);
- }
-
- public boolean noneMatch(DoublePredicate predicate) {
- return delegate.noneMatch(predicate);
- }
-
- public OptionalDouble findFirst() {
- return delegate.findFirst();
- }
-
- public OptionalDouble findAny() {
- return delegate.findAny();
- }
-
- public Stream boxed() {
- return wrapper.from(delegate.boxed());
- }
-
- public DoubleStream sequential() {
- return wrapper.from(delegate.sequential());
- }
-
- public DoubleStream parallel() {
- return wrapper.from(delegate.parallel());
- }
-
- public OfDouble iterator() {
- return delegate.iterator();
- }
-
- public java.util.Spliterator.OfDouble spliterator() {
- return delegate.spliterator();
- }
-
-}
diff --git a/main/commons/src/main/java/org/cryptomator/common/streams/DelegatingIntStream.java b/main/commons/src/main/java/org/cryptomator/common/streams/DelegatingIntStream.java
deleted file mode 100644
index f3ee72e16..000000000
--- a/main/commons/src/main/java/org/cryptomator/common/streams/DelegatingIntStream.java
+++ /dev/null
@@ -1,188 +0,0 @@
-package org.cryptomator.common.streams;
-
-import java.util.IntSummaryStatistics;
-import java.util.OptionalDouble;
-import java.util.OptionalInt;
-import java.util.PrimitiveIterator.OfInt;
-import java.util.function.BiConsumer;
-import java.util.function.IntBinaryOperator;
-import java.util.function.IntConsumer;
-import java.util.function.IntFunction;
-import java.util.function.IntPredicate;
-import java.util.function.IntToDoubleFunction;
-import java.util.function.IntToLongFunction;
-import java.util.function.IntUnaryOperator;
-import java.util.function.ObjIntConsumer;
-import java.util.function.Supplier;
-import java.util.stream.DoubleStream;
-import java.util.stream.IntStream;
-import java.util.stream.LongStream;
-import java.util.stream.Stream;
-
-abstract class DelegatingIntStream implements IntStream {
-
- private final IntStream delegate;
- private final DelegatingStreamFactory wrapper;
-
- public DelegatingIntStream(IntStream delegate, DelegatingStreamFactory wrapper) {
- this.delegate = delegate;
- this.wrapper = wrapper;
- }
-
- public IntStream filter(IntPredicate predicate) {
- return wrapper.from(delegate.filter(predicate));
- }
-
- public boolean isParallel() {
- return delegate.isParallel();
- }
-
- public IntStream map(IntUnaryOperator mapper) {
- return wrapper.from(delegate.map(mapper));
- }
-
- public Stream mapToObj(IntFunction mapper) {
- return wrapper.from(delegate.mapToObj(mapper));
- }
-
- public IntStream unordered() {
- return wrapper.from(delegate.unordered());
- }
-
- public LongStream mapToLong(IntToLongFunction mapper) {
- return wrapper.from(delegate.mapToLong(mapper));
- }
-
- public IntStream onClose(Runnable closeHandler) {
- return wrapper.from(delegate.onClose(closeHandler));
- }
-
- public DoubleStream mapToDouble(IntToDoubleFunction mapper) {
- return wrapper.from(delegate.mapToDouble(mapper));
- }
-
- public void close() {
- delegate.close();
- }
-
- public IntStream flatMap(IntFunction mapper) {
- return wrapper.from(delegate.flatMap(mapper));
- }
-
- public IntStream distinct() {
- return wrapper.from(delegate.distinct());
- }
-
- public IntStream sorted() {
- return wrapper.from(delegate.sorted());
- }
-
- public IntStream peek(IntConsumer action) {
- return wrapper.from(delegate.peek(action));
- }
-
- public IntStream limit(long maxSize) {
- return wrapper.from(delegate.limit(maxSize));
- }
-
- public IntStream skip(long n) {
- return wrapper.from(delegate.skip(n));
- }
-
- public void forEach(IntConsumer action) {
- delegate.forEach(action);
- }
-
- public void forEachOrdered(IntConsumer action) {
- delegate.forEachOrdered(action);
- }
-
- public int[] toArray() {
- return delegate.toArray();
- }
-
- public int reduce(int identity, IntBinaryOperator op) {
- return delegate.reduce(identity, op);
- }
-
- public OptionalInt reduce(IntBinaryOperator op) {
- return delegate.reduce(op);
- }
-
- public R collect(Supplier supplier, ObjIntConsumer accumulator, BiConsumer combiner) {
- return delegate.collect(supplier, accumulator, combiner);
- }
-
- public int sum() {
- return delegate.sum();
- }
-
- public OptionalInt min() {
- return delegate.min();
- }
-
- public OptionalInt max() {
- return delegate.max();
- }
-
- public long count() {
- return delegate.count();
- }
-
- public OptionalDouble average() {
- return delegate.average();
- }
-
- public IntSummaryStatistics summaryStatistics() {
- return delegate.summaryStatistics();
- }
-
- public boolean anyMatch(IntPredicate predicate) {
- return delegate.anyMatch(predicate);
- }
-
- public boolean allMatch(IntPredicate predicate) {
- return delegate.allMatch(predicate);
- }
-
- public boolean noneMatch(IntPredicate predicate) {
- return delegate.noneMatch(predicate);
- }
-
- public OptionalInt findFirst() {
- return delegate.findFirst();
- }
-
- public OptionalInt findAny() {
- return delegate.findAny();
- }
-
- public LongStream asLongStream() {
- return wrapper.from(delegate.asLongStream());
- }
-
- public DoubleStream asDoubleStream() {
- return wrapper.from(delegate.asDoubleStream());
- }
-
- public Stream boxed() {
- return wrapper.from(delegate.boxed());
- }
-
- public IntStream sequential() {
- return wrapper.from(delegate.sequential());
- }
-
- public IntStream parallel() {
- return wrapper.from(delegate.parallel());
- }
-
- public OfInt iterator() {
- return delegate.iterator();
- }
-
- public java.util.Spliterator.OfInt spliterator() {
- return delegate.spliterator();
- }
-
-}
diff --git a/main/commons/src/main/java/org/cryptomator/common/streams/DelegatingLongStream.java b/main/commons/src/main/java/org/cryptomator/common/streams/DelegatingLongStream.java
deleted file mode 100644
index c33baef4f..000000000
--- a/main/commons/src/main/java/org/cryptomator/common/streams/DelegatingLongStream.java
+++ /dev/null
@@ -1,184 +0,0 @@
-package org.cryptomator.common.streams;
-
-import java.util.LongSummaryStatistics;
-import java.util.OptionalDouble;
-import java.util.OptionalLong;
-import java.util.PrimitiveIterator.OfLong;
-import java.util.function.BiConsumer;
-import java.util.function.LongBinaryOperator;
-import java.util.function.LongConsumer;
-import java.util.function.LongFunction;
-import java.util.function.LongPredicate;
-import java.util.function.LongToDoubleFunction;
-import java.util.function.LongToIntFunction;
-import java.util.function.LongUnaryOperator;
-import java.util.function.ObjLongConsumer;
-import java.util.function.Supplier;
-import java.util.stream.DoubleStream;
-import java.util.stream.IntStream;
-import java.util.stream.LongStream;
-import java.util.stream.Stream;
-
-abstract class DelegatingLongStream implements LongStream {
-
- private final LongStream delegate;
- private final DelegatingStreamFactory wrapper;
-
- public DelegatingLongStream(LongStream delegate, DelegatingStreamFactory wrapper) {
- this.delegate = delegate;
- this.wrapper = wrapper;
- }
-
- public LongStream filter(LongPredicate predicate) {
- return wrapper.from(delegate.filter(predicate));
- }
-
- public boolean isParallel() {
- return delegate.isParallel();
- }
-
- public LongStream map(LongUnaryOperator mapper) {
- return wrapper.from(delegate.map(mapper));
- }
-
- public Stream mapToObj(LongFunction mapper) {
- return wrapper.from(delegate.mapToObj(mapper));
- }
-
- public LongStream unordered() {
- return wrapper.from(delegate.unordered());
- }
-
- public LongStream onClose(Runnable closeHandler) {
- return wrapper.from(delegate.onClose(closeHandler));
- }
-
- public IntStream mapToInt(LongToIntFunction mapper) {
- return wrapper.from(delegate.mapToInt(mapper));
- }
-
- public DoubleStream mapToDouble(LongToDoubleFunction mapper) {
- return wrapper.from(delegate.mapToDouble(mapper));
- }
-
- public void close() {
- delegate.close();
- }
-
- public LongStream flatMap(LongFunction mapper) {
- return wrapper.from(delegate.flatMap(mapper));
- }
-
- public LongStream distinct() {
- return wrapper.from(delegate.distinct());
- }
-
- public LongStream sorted() {
- return wrapper.from(delegate.sorted());
- }
-
- public LongStream peek(LongConsumer action) {
- return wrapper.from(delegate.peek(action));
- }
-
- public LongStream limit(long maxSize) {
- return wrapper.from(delegate.limit(maxSize));
- }
-
- public LongStream skip(long n) {
- return wrapper.from(delegate.skip(n));
- }
-
- public void forEach(LongConsumer action) {
- delegate.forEach(action);
- }
-
- public void forEachOrdered(LongConsumer action) {
- delegate.forEachOrdered(action);
- }
-
- public long[] toArray() {
- return delegate.toArray();
- }
-
- public long reduce(long identity, LongBinaryOperator op) {
- return delegate.reduce(identity, op);
- }
-
- public OptionalLong reduce(LongBinaryOperator op) {
- return delegate.reduce(op);
- }
-
- public R collect(Supplier supplier, ObjLongConsumer accumulator, BiConsumer combiner) {
- return delegate.collect(supplier, accumulator, combiner);
- }
-
- public long sum() {
- return delegate.sum();
- }
-
- public OptionalLong min() {
- return delegate.min();
- }
-
- public OptionalLong max() {
- return delegate.max();
- }
-
- public long count() {
- return delegate.count();
- }
-
- public OptionalDouble average() {
- return delegate.average();
- }
-
- public LongSummaryStatistics summaryStatistics() {
- return delegate.summaryStatistics();
- }
-
- public boolean anyMatch(LongPredicate predicate) {
- return delegate.anyMatch(predicate);
- }
-
- public boolean allMatch(LongPredicate predicate) {
- return delegate.allMatch(predicate);
- }
-
- public boolean noneMatch(LongPredicate predicate) {
- return delegate.noneMatch(predicate);
- }
-
- public OptionalLong findFirst() {
- return delegate.findFirst();
- }
-
- public OptionalLong findAny() {
- return delegate.findAny();
- }
-
- public DoubleStream asDoubleStream() {
- return wrapper.from(delegate.asDoubleStream());
- }
-
- public Stream boxed() {
- return wrapper.from(delegate.boxed());
- }
-
- public LongStream sequential() {
- return wrapper.from(delegate.sequential());
- }
-
- public LongStream parallel() {
- return wrapper.from(delegate.parallel());
- }
-
- public OfLong iterator() {
- return delegate.iterator();
- }
-
- public java.util.Spliterator.OfLong spliterator() {
- return delegate.spliterator();
- }
-
-}
diff --git a/main/commons/src/main/java/org/cryptomator/common/streams/DelegatingStream.java b/main/commons/src/main/java/org/cryptomator/common/streams/DelegatingStream.java
deleted file mode 100644
index 585bb8cd3..000000000
--- a/main/commons/src/main/java/org/cryptomator/common/streams/DelegatingStream.java
+++ /dev/null
@@ -1,194 +0,0 @@
-package org.cryptomator.common.streams;
-
-import java.util.Comparator;
-import java.util.Iterator;
-import java.util.Optional;
-import java.util.Spliterator;
-import java.util.function.BiConsumer;
-import java.util.function.BiFunction;
-import java.util.function.BinaryOperator;
-import java.util.function.Consumer;
-import java.util.function.Function;
-import java.util.function.IntFunction;
-import java.util.function.Predicate;
-import java.util.function.Supplier;
-import java.util.function.ToDoubleFunction;
-import java.util.function.ToIntFunction;
-import java.util.function.ToLongFunction;
-import java.util.stream.Collector;
-import java.util.stream.DoubleStream;
-import java.util.stream.IntStream;
-import java.util.stream.LongStream;
-import java.util.stream.Stream;
-
-abstract class DelegatingStream implements Stream {
-
- private final Stream delegate;
- private final DelegatingStreamFactory wrapper;
-
- protected DelegatingStream(Stream delegate, DelegatingStreamFactory wrapper) {
- this.delegate = delegate;
- this.wrapper = wrapper;
- }
-
- public Iterator iterator() {
- return delegate.iterator();
- }
-
- public Spliterator spliterator() {
- return delegate.spliterator();
- }
-
- public boolean isParallel() {
- return delegate.isParallel();
- }
-
- public Stream sequential() {
- return wrapper.from(delegate.sequential());
- }
-
- public Stream parallel() {
- return wrapper.from(delegate.parallel());
- }
-
- public Stream unordered() {
- return wrapper.from(delegate.unordered());
- }
-
- public Stream onClose(Runnable closeHandler) {
- return wrapper.from(delegate.onClose(closeHandler));
- }
-
- public void close() {
- delegate.close();
- }
-
- public Stream filter(Predicate predicate) {
- return wrapper.from(delegate.filter(predicate));
- }
-
- public Stream map(Function mapper) {
- return wrapper.from(delegate.map(mapper));
- }
-
- public IntStream mapToInt(ToIntFunction mapper) {
- return wrapper.from(delegate.mapToInt(mapper));
- }
-
- public LongStream mapToLong(ToLongFunction mapper) {
- return wrapper.from(delegate.mapToLong(mapper));
- }
-
- public DoubleStream mapToDouble(ToDoubleFunction mapper) {
- return wrapper.from(delegate.mapToDouble(mapper));
- }
-
- public Stream flatMap(Function> mapper) {
- return wrapper.from(delegate.flatMap(mapper));
- }
-
- public IntStream flatMapToInt(Function mapper) {
- return wrapper.from(delegate.flatMapToInt(mapper));
- }
-
- public LongStream flatMapToLong(Function mapper) {
- return wrapper.from(delegate.flatMapToLong(mapper));
- }
-
- public DoubleStream flatMapToDouble(Function mapper) {
- return wrapper.from(delegate.flatMapToDouble(mapper));
- }
-
- public Stream distinct() {
- return wrapper.from(delegate.distinct());
- }
-
- public Stream sorted() {
- return wrapper.from(delegate.sorted());
- }
-
- public Stream sorted(Comparator comparator) {
- return wrapper.from(delegate.sorted(comparator));
- }
-
- public Stream peek(Consumer action) {
- return wrapper.from(delegate.peek(action));
- }
-
- public Stream limit(long maxSize) {
- return wrapper.from(delegate.limit(maxSize));
- }
-
- public Stream skip(long n) {
- return wrapper.from(delegate.skip(n));
- }
-
- public void forEach(Consumer action) {
- delegate.forEach(action);
- }
-
- public void forEachOrdered(Consumer action) {
- delegate.forEachOrdered(action);
- }
-
- public Object[] toArray() {
- return delegate.toArray();
- }
-
- public A[] toArray(IntFunction generator) {
- return delegate.toArray(generator);
- }
-
- public T reduce(T identity, BinaryOperator accumulator) {
- return delegate.reduce(identity, accumulator);
- }
-
- public Optional reduce(BinaryOperator accumulator) {
- return delegate.reduce(accumulator);
- }
-
- public U reduce(U identity, BiFunction accumulator, BinaryOperator combiner) {
- return delegate.reduce(identity, accumulator, combiner);
- }
-
- public R collect(Supplier supplier, BiConsumer accumulator, BiConsumer combiner) {
- return delegate.collect(supplier, accumulator, combiner);
- }
-
- public R collect(Collector collector) {
- return delegate.collect(collector);
- }
-
- public Optional min(Comparator comparator) {
- return delegate.min(comparator);
- }
-
- public Optional max(Comparator comparator) {
- return delegate.max(comparator);
- }
-
- public long count() {
- return delegate.count();
- }
-
- public boolean anyMatch(Predicate predicate) {
- return delegate.anyMatch(predicate);
- }
-
- public boolean allMatch(Predicate predicate) {
- return delegate.allMatch(predicate);
- }
-
- public boolean noneMatch(Predicate predicate) {
- return delegate.noneMatch(predicate);
- }
-
- public Optional findFirst() {
- return delegate.findFirst();
- }
-
- public Optional findAny() {
- return delegate.findAny();
- }
-
-}
diff --git a/main/commons/src/main/java/org/cryptomator/common/streams/DelegatingStreamFactory.java b/main/commons/src/main/java/org/cryptomator/common/streams/DelegatingStreamFactory.java
deleted file mode 100644
index 24203baf8..000000000
--- a/main/commons/src/main/java/org/cryptomator/common/streams/DelegatingStreamFactory.java
+++ /dev/null
@@ -1,22 +0,0 @@
-package org.cryptomator.common.streams;
-
-import java.util.stream.DoubleStream;
-import java.util.stream.IntStream;
-import java.util.stream.LongStream;
-import java.util.stream.Stream;
-
-public interface DelegatingStreamFactory {
-
- Stream from(Stream other);
-
- IntStream from(IntStream other);
-
- LongStream from(LongStream other);
-
- DoubleStream from(DoubleStream other);
-
- public interface ObjectStreamWrapper {
- Stream from(Stream other);
- }
-
-}
\ No newline at end of file
diff --git a/main/commons/src/test/java/org/cryptomator/common/CachingSupplierTest.java b/main/commons/src/test/java/org/cryptomator/common/CachingSupplierTest.java
deleted file mode 100644
index 4917c5eac..000000000
--- a/main/commons/src/test/java/org/cryptomator/common/CachingSupplierTest.java
+++ /dev/null
@@ -1,43 +0,0 @@
-package org.cryptomator.common;
-
-import static org.hamcrest.CoreMatchers.is;
-import static org.junit.Assert.assertThat;
-import static org.mockito.Mockito.mock;
-import static org.mockito.Mockito.verify;
-import static org.mockito.Mockito.when;
-
-import java.util.function.Supplier;
-
-import org.junit.Test;
-
-public class CachingSupplierTest {
-
- @Test
- public void testInvokingGetInvokesDelegate() {
- @SuppressWarnings("unchecked")
- Supplier