Package com.salesforce.datacloud.jdbc.util

Class StreamUtilities

java.lang.Object

com.salesforce.datacloud.jdbc.util.StreamUtilities

public final class StreamUtilities
extends Object

Method Summary

Modifier and Type	Method	Description
static <T> Stream<T>	lazyLimitedStream(Supplier<Stream<T>> streamSupplier, LongSupplier limitSupplier)
static <T> Stream<T>	toStream(Iterator<T> iterator)
static <T,E extends Exception> Optional<T>	tryTimes(int times, ThrowingSupplier<T,E> attempt, Consumer<Throwable> consumer)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

lazyLimitedStream

public static <T> Stream<T> lazyLimitedStream(Supplier<Stream<T>> streamSupplier,
                                              LongSupplier limitSupplier)

toStream

public static <T> Stream<T> toStream(Iterator<T> iterator)

tryTimes

public static <T,E extends Exception> Optional<T> tryTimes(int times,
                                                                 ThrowingSupplier<T,E> attempt,
                                                                 Consumer<Throwable> consumer)