A B C D E F G H I J K L M N O P R S T U V W Z

A

accept(T, R) - Method in interface org.davidmoten.kool.function.BiConsumer

accept(T) - Method in interface org.davidmoten.kool.function.Consumer

acceptUnchecked(T) - Method in interface org.davidmoten.kool.function.Consumer

accumulator(BiFunction<? super S, ? super T, ? extends S>) - Method in class org.davidmoten.kool.BufferBuilder.BuilderHasCondition

Action - Interface in org.davidmoten.kool.function

add(T) - Method in class org.davidmoten.kool.internal.util.EvictingQueue

add(T) - Method in class org.davidmoten.kool.internal.util.RingBuffer

All<T> - Class in org.davidmoten.kool.internal.operators.stream

All(Stream<T>, Predicate<? super T>) - Constructor for class org.davidmoten.kool.internal.operators.stream.All

all(Predicate<? super T>) - Method in interface org.davidmoten.kool.Stream

alwaysFalse() - Static method in class org.davidmoten.kool.function.Predicates

alwaysTrue() - Static method in class org.davidmoten.kool.function.Predicates

Any<T> - Class in org.davidmoten.kool.internal.operators.stream

Any(Stream<T>, Predicate<? super T>) - Constructor for class org.davidmoten.kool.internal.operators.stream.Any

any(Predicate<? super T>) - Method in interface org.davidmoten.kool.Stream

apply(T, R) - Method in interface org.davidmoten.kool.function.BiFunction

apply(T) - Method in interface org.davidmoten.kool.function.Function

applyUnchecked(T, R) - Method in interface org.davidmoten.kool.function.BiFunction

applyUnchecked(T) - Method in interface org.davidmoten.kool.function.Function

arrayList() - Method in class org.davidmoten.kool.BufferBuilder

arrayNode() - Method in class org.davidmoten.kool.json.Json

arrayNodes() - Method in class org.davidmoten.kool.json.JsonArray

assertError(Class<? extends Throwable>) - Method in class org.davidmoten.kool.MaybeTester

assertError(Class<? extends Throwable>) - Method in class org.davidmoten.kool.SingleTester

assertError(Class<? extends Throwable>) - Method in class org.davidmoten.kool.Tester

assertError(Predicate<? super Throwable>) - Method in class org.davidmoten.kool.Tester

assertErrorMessage(String) - Method in class org.davidmoten.kool.MaybeTester

assertErrorMessage(String) - Method in class org.davidmoten.kool.SingleTester

assertErrorMessage(String) - Method in class org.davidmoten.kool.Tester

assertNoError() - Method in class org.davidmoten.kool.MaybeTester

assertNoError() - Method in class org.davidmoten.kool.SingleTester

assertNoError() - Method in class org.davidmoten.kool.Tester

assertNoValue() - Method in class org.davidmoten.kool.MaybeTester

assertNoValues() - Method in class org.davidmoten.kool.Tester

assertNoValuesOnly() - Method in class org.davidmoten.kool.Tester

assertPresent() - Method in class org.davidmoten.kool.MaybeTester

assertValue(T) - Method in class org.davidmoten.kool.MaybeTester

assertValue(T) - Method in class org.davidmoten.kool.SingleTester

assertValueOnly(T) - Method in class org.davidmoten.kool.SingleTester

assertValues(T...) - Method in class org.davidmoten.kool.Tester

assertValuesOnly(T...) - Method in class org.davidmoten.kool.Tester

B

BaseStreamIterator<R,T> - Class in org.davidmoten.kool.internal.util

BaseStreamIterator(StreamIterable<R>) - Constructor for class org.davidmoten.kool.internal.util.BaseStreamIterator

BiConsumer<T,R> - Interface in org.davidmoten.kool.function

BiFunction<T,R,S> - Interface in org.davidmoten.kool.function

BiPredicate<T,R> - Interface in org.davidmoten.kool.function

Buffer<T> - Class in org.davidmoten.kool.internal.operators.stream

Buffer(Stream<T>, int, int, boolean) - Constructor for class org.davidmoten.kool.internal.operators.stream.Buffer

buffer(int) - Method in interface org.davidmoten.kool.Stream

buffer(int, int) - Method in interface org.davidmoten.kool.Stream

buffer(int, int, boolean) - Method in interface org.davidmoten.kool.Stream

Buffers the stream into list chunks of given size and step.

BufferBuilder<T> - Class in org.davidmoten.kool

BufferBuilder.BuilderHasAccumulator<T,S> - Class in org.davidmoten.kool

BufferBuilder.BuilderHasCondition<T,S> - Class in org.davidmoten.kool

BufferBuilder.BuilderHasFactory<T,S> - Class in org.davidmoten.kool

BufferBuilder.BuilderHasFactoryArrayList<T> - Class in org.davidmoten.kool

BufferBuilder.BuilderHasStep<T,S> - Class in org.davidmoten.kool

BufferOverflowException - Exception in org.davidmoten.kool.exceptions

BufferOverflowException(String) - Constructor for exception org.davidmoten.kool.exceptions.BufferOverflowException

bufferUntil(BiPredicate<? super List<T>, ? super T>, boolean) - Method in interface org.davidmoten.kool.Stream

bufferUntil(BiPredicate<? super List<T>, ? super T>, boolean, int, int) - Method in interface org.davidmoten.kool.Stream

bufferUntil(BiPredicate<? super List<T>, ? super T>, boolean, Function<? super List<T>, Integer>, int) - Method in interface org.davidmoten.kool.Stream

bufferUntil(Callable<? extends S>, BiFunction<? super S, ? super T, ? extends S>, BiPredicate<? super S, ? super T>, boolean, Function<? super S, Integer>, int) - Method in interface org.davidmoten.kool.Stream

Buffers until a condition is true then emits the buffer and starts a new buffer for emission.

bufferUntil() - Method in interface org.davidmoten.kool.Stream

bufferWhile(BiPredicate<? super List<T>, ? super T>, boolean) - Method in interface org.davidmoten.kool.Stream

bufferWhile(BiPredicate<? super List<T>, ? super T>, boolean, int, int) - Method in interface org.davidmoten.kool.Stream

bufferWhile(BiPredicate<? super List<T>, ? super T>, boolean, Function<? super List<T>, Integer>, int) - Method in interface org.davidmoten.kool.Stream

bufferWhile(Callable<? extends S>, BiFunction<? super S, ? super T, ? extends S>, BiPredicate<? super S, ? super T>, boolean, Function<? super S, Integer>, int) - Method in interface org.davidmoten.kool.Stream

Buffers while a condition is true then emits the buffer and starts a new buffer for emission.

bufferWhile() - Method in interface org.davidmoten.kool.Stream

BufferWithFactoryPredicateAndStep<S,T> - Class in org.davidmoten.kool.internal.operators.stream

BufferWithFactoryPredicateAndStep(Callable<? extends S>, BiFunction<? super S, ? super T, ? extends S>, BiPredicate<? super S, ? super T>, boolean, boolean, Stream<T>, Function<? super S, Integer>, int) - Constructor for class org.davidmoten.kool.internal.operators.stream.BufferWithFactoryPredicateAndStep

BufferWithPredicate<T> - Class in org.davidmoten.kool.internal.operators.stream

BufferWithPredicate(BiPredicate<? super List<T>, ? super T>, boolean, boolean, Stream<T>) - Constructor for class org.davidmoten.kool.internal.operators.stream.BufferWithPredicate

build() - Method in class org.davidmoten.kool.BufferBuilder.BuilderHasStep

build(Stream<T>, Stream<Long>, int, Predicate<? super Throwable>) - Static method in class org.davidmoten.kool.internal.operators.stream.RetryWhen

build() - Method in class org.davidmoten.kool.RetryWhenBuilder

build() - Method in class org.davidmoten.kool.RetryWhenBuilderMaybe

build() - Method in class org.davidmoten.kool.RetryWhenBuilderSingle

BuilderHasCondition(BufferBuilder.BuilderHasFactory<T, S>) - Constructor for class org.davidmoten.kool.BufferBuilder.BuilderHasCondition

byteBuffers(Callable<? extends InputStream>, int) - Static method in interface org.davidmoten.kool.Stream

byteBuffers(Callable<? extends InputStream>) - Static method in interface org.davidmoten.kool.Stream

byteBuffers(InputStream) - Static method in interface org.davidmoten.kool.Stream

byteBuffers(InputStream, int) - Static method in interface org.davidmoten.kool.Stream

bytes(Callable<? extends InputStream>, int) - Static method in interface org.davidmoten.kool.Stream

bytes(Callable<? extends InputStream>) - Static method in interface org.davidmoten.kool.Stream

bytes(InputStream, int) - Static method in interface org.davidmoten.kool.Stream

bytes(InputStream) - Static method in interface org.davidmoten.kool.Stream

C

Cache<T> - Class in org.davidmoten.kool.internal.operators.stream

Cache(Stream<T>) - Constructor for class org.davidmoten.kool.internal.operators.stream.Cache

cache() - Method in interface org.davidmoten.kool.Stream

call() - Method in interface org.davidmoten.kool.function.Action

callUnchecked() - Method in interface org.davidmoten.kool.function.Action

cast(Class<R>) - Method in interface org.davidmoten.kool.Stream

chars(CharSequence) - Static method in interface org.davidmoten.kool.Stream

chars(CharSequence, int, int) - Static method in interface org.davidmoten.kool.Stream

CLOSEABLE_CLOSER - Static variable in interface org.davidmoten.kool.Stream

Collect<T,R> - Class in org.davidmoten.kool.internal.operators.stream

Collect(Callable<? extends R>, BiConsumer<? super R, ? super T>, Stream<T>) - Constructor for class org.davidmoten.kool.internal.operators.stream.Collect

collect(Callable<? extends R>, BiConsumer<? super R, ? super T>) - Method in interface org.davidmoten.kool.Stream

collect(Collector<T, R>) - Method in interface org.davidmoten.kool.Stream

collect(Collector<T, A, R>) - Method in interface org.davidmoten.kool.Stream

Collector<T,R> - Interface in org.davidmoten.kool

complete() - Static method in class org.davidmoten.kool.Notification

compose(Function<? super Stream<T>, ? extends Stream<? extends R>>) - Method in interface org.davidmoten.kool.Stream

composeMaybe(Function<? super Stream<T>, ? extends Maybe<? extends R>>) - Method in interface org.davidmoten.kool.Stream

composeSingle(Function<? super Stream<T>, ? extends Single<? extends R>>) - Method in interface org.davidmoten.kool.Stream

CompositeException - Exception in org.davidmoten.kool.exceptions

Represents an exception that is a composite of one or more other exceptions.

CompositeException(Throwable...) - Constructor for exception org.davidmoten.kool.exceptions.CompositeException

Constructs a CompositeException with the given array of Throwables as the list of suppressed exceptions.

CompositeException(Iterable<? extends Throwable>) - Constructor for exception org.davidmoten.kool.exceptions.CompositeException

Constructs a CompositeException with the given array of Throwables as the list of suppressed exceptions.

Concat<T> - Class in org.davidmoten.kool.internal.operators.stream

Concat(StreamIterable<? extends T>, StreamIterable<? extends T>) - Constructor for class org.davidmoten.kool.internal.operators.stream.Concat

concatWith(StreamIterable<? extends T>) - Method in interface org.davidmoten.kool.Stream

concatWith(Iterable<? extends T>) - Method in interface org.davidmoten.kool.Stream

condition(BiPredicate<? super S, ? super T>) - Method in class org.davidmoten.kool.BufferBuilder.BuilderHasFactory

condition(BiPredicate<? super List<T>, ? super T>) - Method in class org.davidmoten.kool.BufferBuilder.BuilderHasFactoryArrayList

Constants - Class in org.davidmoten.kool.internal.operators.stream

Consumer<T> - Interface in org.davidmoten.kool.function

Consumers - Class in org.davidmoten.kool.function

contains(T) - Method in interface org.davidmoten.kool.Stream

Count - Class in org.davidmoten.kool.internal.operators.stream

Count(Stream<?>) - Constructor for class org.davidmoten.kool.internal.operators.stream.Count

count() - Method in interface org.davidmoten.kool.Maybe

count() - Method in class org.davidmoten.kool.Statistics

count() - Method in interface org.davidmoten.kool.Stream

create(T, long) - Static method in class org.davidmoten.kool.Indexed

create(Iterable<? extends T>) - Static method in interface org.davidmoten.kool.Stream

D

DEFAULT_BUFFER_SIZE - Static variable in class org.davidmoten.kool.internal.operators.stream.Constants

DEFAULT_BUFFER_SIZE - Static variable in interface org.davidmoten.kool.Stream

DEFAULT_BYTE_BUFFER_SIZE - Static variable in interface org.davidmoten.kool.Stream

Defer<T> - Class in org.davidmoten.kool.internal.operators.stream

Defer(Callable<? extends Stream<? extends T>>) - Constructor for class org.davidmoten.kool.internal.operators.stream.Defer

defer(Callable<? extends Maybe<? extends T>>) - Static method in interface org.davidmoten.kool.Maybe

defer(Callable<? extends Stream<? extends T>>) - Static method in interface org.davidmoten.kool.Stream

delay(long, TimeUnit) - Method in class org.davidmoten.kool.RetryWhenBuilder

delay(long, TimeUnit) - Method in class org.davidmoten.kool.RetryWhenBuilderMaybe

delay(long, TimeUnit) - Method in class org.davidmoten.kool.RetryWhenBuilderSingle

delays(Stream<Long>, TimeUnit) - Method in class org.davidmoten.kool.RetryWhenBuilder

delays(Stream<Long>, TimeUnit) - Method in class org.davidmoten.kool.RetryWhenBuilderMaybe

delays(Stream<Long>, TimeUnit) - Method in class org.davidmoten.kool.RetryWhenBuilderSingle

delayStart(long, TimeUnit) - Method in interface org.davidmoten.kool.Stream

Dematerialize<T,R> - Class in org.davidmoten.kool.internal.operators.stream

Dematerialize(Stream<T>, Function<? super T, Notification<? extends R>>) - Constructor for class org.davidmoten.kool.internal.operators.stream.Dematerialize

dematerialize(Function<? super T, Notification<? extends R>>) - Method in interface org.davidmoten.kool.Stream

dispose() - Method in class org.davidmoten.kool.internal.operators.maybe.MaybeIterator

dispose() - Method in class org.davidmoten.kool.internal.operators.single.SingleIterator

dispose() - Method in class org.davidmoten.kool.internal.operators.stream.ReplayableStreamIterator

dispose() - Method in class org.davidmoten.kool.internal.util.BaseStreamIterator

dispose() - Method in class org.davidmoten.kool.internal.util.EmptyStream

dispose() - Method in interface org.davidmoten.kool.StreamIterator

Idempotent method for cancellation.

Distinct<T,K> - Class in org.davidmoten.kool.internal.operators.stream

Distinct(Stream<T>, Function<? super T, K>) - Constructor for class org.davidmoten.kool.internal.operators.stream.Distinct

distinct(Function<? super T, K>) - Method in interface org.davidmoten.kool.Stream

distinct() - Method in interface org.davidmoten.kool.Stream

DistinctUntilChanged<T,K> - Class in org.davidmoten.kool.internal.operators.stream

DistinctUntilChanged(Stream<T>, Function<? super T, K>) - Constructor for class org.davidmoten.kool.internal.operators.stream.DistinctUntilChanged

distinctUntilChanged() - Method in interface org.davidmoten.kool.Stream

distinctUntilChanged(Function<? super T, K>) - Method in interface org.davidmoten.kool.Stream

doAfterDispose(Action) - Method in interface org.davidmoten.kool.Stream

doBeforeDispose(Action) - Method in interface org.davidmoten.kool.Stream

doNothing() - Static method in class org.davidmoten.kool.function.Consumers

DoOnComplete<T> - Class in org.davidmoten.kool.internal.operators.stream

DoOnComplete(Action, Stream<T>) - Constructor for class org.davidmoten.kool.internal.operators.stream.DoOnComplete

doOnComplete(Action) - Method in interface org.davidmoten.kool.Stream

doOnComplete(Consumer<? super Long>) - Method in interface org.davidmoten.kool.Stream

DoOnDispose<T> - Class in org.davidmoten.kool.internal.operators.stream

DoOnDispose(Action, Stream<T>, boolean) - Constructor for class org.davidmoten.kool.internal.operators.stream.DoOnDispose

doOnDispose(Action) - Method in interface org.davidmoten.kool.Stream

DoOnEmpty<T> - Class in org.davidmoten.kool.internal.operators.stream

DoOnEmpty(Stream<T>, Action) - Constructor for class org.davidmoten.kool.internal.operators.stream.DoOnEmpty

doOnEmpty(Runnable) - Method in interface org.davidmoten.kool.Maybe

doOnEmpty(Action) - Method in interface org.davidmoten.kool.Stream

DoOnError<T> - Class in org.davidmoten.kool.internal.operators.stream

DoOnError(Consumer<? super Throwable>, Stream<T>) - Constructor for class org.davidmoten.kool.internal.operators.stream.DoOnError

doOnError(Consumer<? super Throwable>) - Method in interface org.davidmoten.kool.Maybe

doOnError(Consumer<? super Throwable>) - Method in interface org.davidmoten.kool.Single

doOnError(Consumer<? super Throwable>) - Method in interface org.davidmoten.kool.Stream

DoOnNext<T> - Class in org.davidmoten.kool.internal.operators.stream

DoOnNext(Consumer<? super T>, StreamIterable<T>) - Constructor for class org.davidmoten.kool.internal.operators.stream.DoOnNext

doOnNext(Consumer<? super T>) - Method in interface org.davidmoten.kool.Stream

DoOnStart<T> - Class in org.davidmoten.kool.internal.operators.stream

DoOnStart(Stream<T>, Action) - Constructor for class org.davidmoten.kool.internal.operators.stream.DoOnStart

doOnStart(Action) - Method in interface org.davidmoten.kool.Stream

doOnValue(Consumer<? super T>) - Method in interface org.davidmoten.kool.Maybe

doOnValue(Consumer<? super T>) - Method in interface org.davidmoten.kool.Single

doWithIndex(BiConsumer<? super Long, ? super T>) - Method in interface org.davidmoten.kool.Stream

E

emitRemainder(boolean) - Method in class org.davidmoten.kool.BufferBuilder.BuilderHasStep

Emitter<T> - Interface in org.davidmoten.kool

EMPTY - Static variable in class org.davidmoten.kool.internal.util.StreamUtils.EmptyHolder

empty() - Static method in interface org.davidmoten.kool.Maybe

empty() - Static method in interface org.davidmoten.kool.Stream

EmptyHolder() - Constructor for class org.davidmoten.kool.internal.util.MaybeImpl.EmptyHolder

EmptyHolder() - Constructor for class org.davidmoten.kool.internal.util.StreamUtils.EmptyHolder

EmptyStream - Class in org.davidmoten.kool.internal.util

EmptyStream() - Constructor for class org.davidmoten.kool.internal.util.EmptyStream

equals(Object) - Method in class org.davidmoten.kool.Indexed

equals(Object) - Method in class org.davidmoten.kool.Notification

error(Callable<? extends Throwable>) - Static method in interface org.davidmoten.kool.Maybe

error(Throwable) - Static method in interface org.davidmoten.kool.Maybe

error(Throwable) - Static method in class org.davidmoten.kool.Notification

error() - Method in class org.davidmoten.kool.Notification

error(Callable<? extends Throwable>) - Static method in interface org.davidmoten.kool.Single

error(Throwable) - Static method in interface org.davidmoten.kool.Single

error(Throwable) - Static method in interface org.davidmoten.kool.Stream

error(Callable<? extends Throwable>) - Static method in interface org.davidmoten.kool.Stream

every(long, BiConsumer<Long, T>) - Method in interface org.davidmoten.kool.Stream

EvictingQueue<T> - Class in org.davidmoten.kool.internal.util

EvictingQueue(long) - Constructor for class org.davidmoten.kool.internal.util.EvictingQueue

Exceptions - Class in org.davidmoten.kool.internal.util

excessKurtosis() - Method in class org.davidmoten.kool.Statistics

exists(Predicate<? super T>) - Method in interface org.davidmoten.kool.Stream

F

factory(Callable<? extends S>) - Method in class org.davidmoten.kool.BufferBuilder

field(String) - Method in class org.davidmoten.kool.json.Json

field(String) - Method in class org.davidmoten.kool.json.JsonArray

fieldArray(String) - Method in class org.davidmoten.kool.json.Json

Filter<T> - Class in org.davidmoten.kool.internal.operators.stream

Filter(Predicate<? super T>, StreamIterable<T>) - Constructor for class org.davidmoten.kool.internal.operators.stream.Filter

filter(Predicate<? super T>) - Method in interface org.davidmoten.kool.Maybe

filter(Predicate<? super T>) - Method in interface org.davidmoten.kool.Stream

findFirst(Predicate<? super T>) - Method in interface org.davidmoten.kool.Stream

First<T> - Class in org.davidmoten.kool.internal.operators.stream

First(StreamIterable<T>) - Constructor for class org.davidmoten.kool.internal.operators.stream.First

first() - Method in interface org.davidmoten.kool.Stream

FlatMap<T,R> - Class in org.davidmoten.kool.internal.operators.stream

FlatMap(Function<? super T, ? extends StreamIterable<? extends R>>, StreamIterable<T>) - Constructor for class org.davidmoten.kool.internal.operators.stream.FlatMap

flatMap(Function<? super T, ? extends StreamIterable<? extends R>>) - Method in interface org.davidmoten.kool.Maybe

flatMap(Function<? super T, ? extends StreamIterable<? extends R>>) - Method in interface org.davidmoten.kool.Single

flatMap(Function<? super T, ? extends StreamIterable<? extends R>>) - Method in interface org.davidmoten.kool.Stream

flatMap(BiConsumer<? super T, ? super Consumer<R>>, Consumer<? super Consumer<R>>) - Method in interface org.davidmoten.kool.Stream

flatMap(BiConsumer<? super T, ? super Consumer<R>>) - Method in interface org.davidmoten.kool.Stream

Using a consumer to report items to downstream is more performant (fewer allocations) because a Stream object doesn't have to be created for each upstream element.

FlatMapGenerator<T,R> - Class in org.davidmoten.kool.internal.operators.stream

FlatMapGenerator(BiConsumer<? super T, ? super Consumer<R>>, Consumer<? super Consumer<R>>, Stream<T>) - Constructor for class org.davidmoten.kool.internal.operators.stream.FlatMapGenerator

flatMapJavaStream(Function<? super T, ? extends Stream<? extends R>>) - Method in interface org.davidmoten.kool.Stream

flatMapMaybe(Function<? super T, ? extends Maybe<? extends R>>) - Method in interface org.davidmoten.kool.Maybe

flatMapMaybe(Function<? super T, ? extends Maybe<? extends R>>) - Method in interface org.davidmoten.kool.Single

forEach(Consumer<? super T>) - Method in class org.davidmoten.kool.internal.util.RingBuffer

forEach() - Method in interface org.davidmoten.kool.Maybe

forEach() - Method in interface org.davidmoten.kool.Single

forEach() - Method in interface org.davidmoten.kool.Stream

forEach2(Consumer<? super T>) - Method in interface org.davidmoten.kool.Stream

from(Iterable<? extends T>) - Static method in interface org.davidmoten.kool.Stream

from(Reader) - Static method in interface org.davidmoten.kool.Stream

from(Reader, int) - Static method in interface org.davidmoten.kool.Stream

from(InputStream, Charset, int) - Static method in interface org.davidmoten.kool.Stream

from(InputStream, Charset) - Static method in interface org.davidmoten.kool.Stream

from(InputStream) - Static method in interface org.davidmoten.kool.Stream

from(Stream<? extends T>) - Static method in interface org.davidmoten.kool.Stream

FromArray<T> - Class in org.davidmoten.kool.internal.operators.stream

FromArray(T[], int, int) - Constructor for class org.davidmoten.kool.internal.operators.stream.FromArray

fromArray(T[]) - Static method in class org.davidmoten.kool.internal.util.Iterables

fromArray(T[], int, int) - Static method in interface org.davidmoten.kool.Stream

fromArray(T[]) - Static method in interface org.davidmoten.kool.Stream

fromArray(int[], int, int) - Static method in interface org.davidmoten.kool.Stream

fromArray(int[]) - Static method in interface org.davidmoten.kool.Stream

fromArray(double[], int, int) - Static method in interface org.davidmoten.kool.Stream

fromArray(double[]) - Static method in interface org.davidmoten.kool.Stream

fromArray(float[], int, int) - Static method in interface org.davidmoten.kool.Stream

fromArray(float[]) - Static method in interface org.davidmoten.kool.Stream

FromArrayDouble - Class in org.davidmoten.kool.internal.operators.stream

FromArrayDouble(double[], int, int) - Constructor for class org.davidmoten.kool.internal.operators.stream.FromArrayDouble

FromArrayFloat - Class in org.davidmoten.kool.internal.operators.stream

FromArrayFloat(float[], int, int) - Constructor for class org.davidmoten.kool.internal.operators.stream.FromArrayFloat

FromArrayInt - Class in org.davidmoten.kool.internal.operators.stream

FromArrayInt(int[], int, int) - Constructor for class org.davidmoten.kool.internal.operators.stream.FromArrayInt

FromBufferedReader - Class in org.davidmoten.kool.internal.operators.stream

FromBufferedReader(BufferedReader) - Constructor for class org.davidmoten.kool.internal.operators.stream.FromBufferedReader

fromCallable(Callable<? extends T>) - Static method in interface org.davidmoten.kool.Maybe

fromCallable(Callable<? extends T>) - Static method in interface org.davidmoten.kool.Single

fromCallableNullable(Callable<? extends T>) - Static method in interface org.davidmoten.kool.Maybe

FromChars - Class in org.davidmoten.kool.internal.operators.stream

FromChars(CharSequence, int, int) - Constructor for class org.davidmoten.kool.internal.operators.stream.FromChars

FromInputStream - Class in org.davidmoten.kool.internal.operators.stream

FromInputStream(InputStream, int) - Constructor for class org.davidmoten.kool.internal.operators.stream.FromInputStream

fromOptional(Optional<? extends T>) - Static method in interface org.davidmoten.kool.Maybe

FromReader - Class in org.davidmoten.kool.internal.operators.stream

FromReader(Reader, int) - Constructor for class org.davidmoten.kool.internal.operators.stream.FromReader

Function<T,R> - Interface in org.davidmoten.kool.function

FunctionIdentityHolder() - Constructor for class org.davidmoten.kool.internal.util.StreamUtils.FunctionIdentityHolder

G

Generate<T> - Class in org.davidmoten.kool.internal.operators.stream

Generate(Consumer<? super Emitter<T>>) - Constructor for class org.davidmoten.kool.internal.operators.stream.Generate

generate(Consumer<Emitter<T>>) - Static method in interface org.davidmoten.kool.Stream

generate(Callable<R>, BiConsumer<R, Emitter<T>>) - Static method in interface org.davidmoten.kool.Stream

get() - Method in class org.davidmoten.kool.internal.operators.maybe.MaybeDefer

get() - Method in class org.davidmoten.kool.internal.operators.maybe.MaybeDoOnEmpty

get() - Method in class org.davidmoten.kool.internal.operators.maybe.MaybeDoOnError

get() - Method in class org.davidmoten.kool.internal.operators.maybe.MaybeDoOnValue

get() - Method in class org.davidmoten.kool.internal.operators.maybe.MaybeError

get() - Method in class org.davidmoten.kool.internal.operators.maybe.MaybeFilter

get() - Method in class org.davidmoten.kool.internal.operators.maybe.MaybeFlatMapMaybe

get() - Method in class org.davidmoten.kool.internal.operators.maybe.MaybeFromCallable

get() - Method in class org.davidmoten.kool.internal.operators.maybe.MaybeIsPresent

get() - Method in class org.davidmoten.kool.internal.operators.maybe.MaybeMap

get() - Method in class org.davidmoten.kool.internal.operators.maybe.MaybeOrElse

get() - Method in class org.davidmoten.kool.internal.operators.maybe.MaybeSwitchOnError

get() - Method in class org.davidmoten.kool.internal.operators.single.Map

get() - Method in class org.davidmoten.kool.internal.operators.single.SingleDoOnError

get() - Method in class org.davidmoten.kool.internal.operators.single.SingleDoOnValue

get() - Method in class org.davidmoten.kool.internal.operators.single.SingleError

get() - Method in class org.davidmoten.kool.internal.operators.single.SingleFlatMapMaybe

get() - Method in class org.davidmoten.kool.internal.operators.single.SingleFromCallable

get() - Method in class org.davidmoten.kool.internal.operators.single.SingleOf

get() - Method in class org.davidmoten.kool.internal.operators.single.SingleSwitchOnError

get() - Method in class org.davidmoten.kool.internal.operators.stream.All

get() - Method in class org.davidmoten.kool.internal.operators.stream.Any

get() - Method in class org.davidmoten.kool.internal.operators.stream.Collect

get() - Method in class org.davidmoten.kool.internal.operators.stream.Count

get() - Method in class org.davidmoten.kool.internal.operators.stream.First

get() - Method in class org.davidmoten.kool.internal.operators.stream.IsEmpty

get() - Method in class org.davidmoten.kool.internal.operators.stream.Last

get() - Method in class org.davidmoten.kool.internal.operators.stream.Max

get() - Method in class org.davidmoten.kool.internal.operators.stream.ReduceNoInitialValue

get() - Method in class org.davidmoten.kool.internal.operators.stream.ReduceWithInitialValueSupplier

get() - Method in class org.davidmoten.kool.internal.operators.stream.ToMaybe

get() - Method in class org.davidmoten.kool.internal.operators.stream.ToSingle

get() - Method in class org.davidmoten.kool.internal.operators.stream.TransformMaybe

get() - Method in class org.davidmoten.kool.internal.operators.stream.TransformSingle

get() - Method in class org.davidmoten.kool.internal.util.MaybeImpl

get(int) - Method in class org.davidmoten.kool.internal.util.RingBuffer

get() - Method in class org.davidmoten.kool.json.Json

get() - Method in class org.davidmoten.kool.json.LazyArrayNode

get() - Method in class org.davidmoten.kool.json.LazyObjectNode

get() - Method in class org.davidmoten.kool.json.LazyTreeNode

get() - Method in class org.davidmoten.kool.json.LazyValueNode

get() - Method in interface org.davidmoten.kool.Maybe

get() - Method in interface org.davidmoten.kool.Single

get(long) - Method in interface org.davidmoten.kool.Stream

getCause() - Method in exception org.davidmoten.kool.exceptions.CompositeException

getExceptions() - Method in exception org.davidmoten.kool.exceptions.CompositeException

Retrieves the list of exceptions that make up the CompositeException.

getMessage() - Method in exception org.davidmoten.kool.exceptions.CompositeException

go() - Method in interface org.davidmoten.kool.Maybe

go() - Method in interface org.davidmoten.kool.Single

go() - Method in interface org.davidmoten.kool.Stream

groupBy(Callable<M>, Function<? super T, ? extends K>, Function<? super T, ? extends V>, Callable<D>) - Method in interface org.davidmoten.kool.Stream

groupByList(Callable<M>, Function<? super T, ? extends K>, Function<? super T, ? extends V>) - Method in interface org.davidmoten.kool.Stream

groupByList(Callable<M>, Function<? super T, ? extends K>) - Method in interface org.davidmoten.kool.Stream

groupByList(Function<? super T, ? extends K>) - Method in interface org.davidmoten.kool.Stream

groupBySet(Callable<M>, Function<? super T, ? extends K>, Function<? super T, ? extends V>) - Method in interface org.davidmoten.kool.Stream

groupBySet(Callable<M>, Function<? super T, ? extends K>) - Method in interface org.davidmoten.kool.Stream

groupBySet(Function<? super T, ? extends K>) - Method in interface org.davidmoten.kool.Stream

H

hasElements() - Method in interface org.davidmoten.kool.Stream

hashCode() - Method in class org.davidmoten.kool.Indexed

hashCode() - Method in class org.davidmoten.kool.Notification

hasMoreElements() - Method in class org.davidmoten.kool.internal.util.EvictingQueue

hasNext() - Method in class org.davidmoten.kool.internal.operators.maybe.MaybeIterator

hasNext() - Method in class org.davidmoten.kool.internal.operators.single.SingleIterator

hasNext() - Method in class org.davidmoten.kool.internal.operators.stream.ReplayableStreamIterator

hasNext() - Method in class org.davidmoten.kool.internal.util.BaseStreamIterator

hasNext() - Method in class org.davidmoten.kool.internal.util.EmptyStream

hasValue() - Method in class org.davidmoten.kool.Notification

I

identity() - Static method in interface org.davidmoten.kool.function.Function

IDENTITY - Static variable in class org.davidmoten.kool.internal.util.StreamUtils.FunctionIdentityHolder

IgnoreDisposalError<T> - Class in org.davidmoten.kool.internal.operators.stream

IgnoreDisposalError(Stream<T>, Consumer<? super Throwable>) - Constructor for class org.davidmoten.kool.internal.operators.stream.IgnoreDisposalError

ignoreDisposalError(Consumer<? super Throwable>) - Method in interface org.davidmoten.kool.Stream

ignoreDisposalError() - Method in interface org.davidmoten.kool.Stream

index() - Method in class org.davidmoten.kool.Indexed

Indexed<T> - Class in org.davidmoten.kool

init(StreamIterable<R>) - Method in class org.davidmoten.kool.internal.util.BaseStreamIterator

inputStream(Stream<? extends byte[]>) - Static method in interface org.davidmoten.kool.Stream

InputStreamFactory - Interface in org.davidmoten.kool.json

INSTANCE - Static variable in class org.davidmoten.kool.internal.util.EmptyStream

INSTANCE - Static variable in class org.davidmoten.kool.internal.util.MaybeImpl.EmptyHolder

interval(long, TimeUnit) - Static method in interface org.davidmoten.kool.Stream

Emits the integers 0, 1, 2, ....

isComplete() - Method in class org.davidmoten.kool.Notification

IsEmpty - Class in org.davidmoten.kool.internal.operators.stream

IsEmpty(Stream<?>) - Constructor for class org.davidmoten.kool.internal.operators.stream.IsEmpty

isEmpty() - Method in class org.davidmoten.kool.internal.util.RingBuffer

isEmpty() - Method in interface org.davidmoten.kool.Stream

isError() - Method in class org.davidmoten.kool.Notification

isPresent() - Method in interface org.davidmoten.kool.Maybe

isTrue(Predicate<? super Throwable>) - Method in class org.davidmoten.kool.RetryWhenBuilder

isTrue(Predicate<? super Throwable>) - Method in class org.davidmoten.kool.RetryWhenBuilderMaybe

isTrue(Predicate<? super Throwable>) - Method in class org.davidmoten.kool.RetryWhenBuilderSingle

it - Variable in class org.davidmoten.kool.internal.util.BaseStreamIterator

iterable(List<T>) - Static method in class org.davidmoten.kool.internal.util.Permutations

Iterables - Class in org.davidmoten.kool.internal.util

iterator() - Method in class org.davidmoten.kool.internal.operators.maybe.MaybeFlatMap

iterator() - Method in class org.davidmoten.kool.internal.operators.maybe.MaybeToStream

iterator() - Method in class org.davidmoten.kool.internal.operators.single.SingleFlatMap

iterator() - Method in class org.davidmoten.kool.internal.operators.single.SingleToStream

iterator() - Method in class org.davidmoten.kool.internal.operators.stream.Buffer

iterator() - Method in class org.davidmoten.kool.internal.operators.stream.BufferWithFactoryPredicateAndStep

iterator() - Method in class org.davidmoten.kool.internal.operators.stream.BufferWithPredicate

iterator() - Method in class org.davidmoten.kool.internal.operators.stream.Cache

iterator() - Method in class org.davidmoten.kool.internal.operators.stream.Concat

iterator() - Method in class org.davidmoten.kool.internal.operators.stream.Defer

iterator() - Method in class org.davidmoten.kool.internal.operators.stream.Dematerialize

iterator() - Method in class org.davidmoten.kool.internal.operators.stream.Distinct

iterator() - Method in class org.davidmoten.kool.internal.operators.stream.DistinctUntilChanged

iterator() - Method in class org.davidmoten.kool.internal.operators.stream.DoOnComplete

iterator() - Method in class org.davidmoten.kool.internal.operators.stream.DoOnDispose

iterator() - Method in class org.davidmoten.kool.internal.operators.stream.DoOnEmpty

iterator() - Method in class org.davidmoten.kool.internal.operators.stream.DoOnError

iterator() - Method in class org.davidmoten.kool.internal.operators.stream.DoOnNext

iterator() - Method in class org.davidmoten.kool.internal.operators.stream.DoOnStart

iterator() - Method in class org.davidmoten.kool.internal.operators.stream.Filter

iterator() - Method in class org.davidmoten.kool.internal.operators.stream.FlatMap

iterator() - Method in class org.davidmoten.kool.internal.operators.stream.FlatMapGenerator

iterator() - Method in class org.davidmoten.kool.internal.operators.stream.FromArray

iterator() - Method in class org.davidmoten.kool.internal.operators.stream.FromArrayDouble

iterator() - Method in class org.davidmoten.kool.internal.operators.stream.FromArrayFloat

iterator() - Method in class org.davidmoten.kool.internal.operators.stream.FromArrayInt

iterator() - Method in class org.davidmoten.kool.internal.operators.stream.FromBufferedReader

iterator() - Method in class org.davidmoten.kool.internal.operators.stream.FromChars

iterator() - Method in class org.davidmoten.kool.internal.operators.stream.FromInputStream

iterator() - Method in class org.davidmoten.kool.internal.operators.stream.FromReader

iterator() - Method in class org.davidmoten.kool.internal.operators.stream.Generate

iterator() - Method in class org.davidmoten.kool.internal.operators.stream.IgnoreDisposalError

iterator() - Method in class org.davidmoten.kool.internal.operators.stream.Map

iterator() - Method in class org.davidmoten.kool.internal.operators.stream.Materialize

iterator() - Method in class org.davidmoten.kool.internal.operators.stream.MergeInterleaved

iterator() - Method in class org.davidmoten.kool.internal.operators.stream.PowerSet

iterator() - Method in class org.davidmoten.kool.internal.operators.stream.PrependOne

iterator() - Method in class org.davidmoten.kool.internal.operators.stream.Range

iterator() - Method in class org.davidmoten.kool.internal.operators.stream.RangeLong

iterator() - Method in class org.davidmoten.kool.internal.operators.stream.Repeat

iterator() - Method in class org.davidmoten.kool.internal.operators.stream.RepeatElement

iterator() - Method in class org.davidmoten.kool.internal.operators.stream.RepeatLast

iterator() - Method in class org.davidmoten.kool.internal.operators.stream.RetryWhen

iterator() - Method in class org.davidmoten.kool.internal.operators.stream.Reverse

iterator() - Method in class org.davidmoten.kool.internal.operators.stream.Skip

iterator() - Method in class org.davidmoten.kool.internal.operators.stream.SkipLast

iterator() - Method in class org.davidmoten.kool.internal.operators.stream.SkipUntil

iterator() - Method in class org.davidmoten.kool.internal.operators.stream.Sorted

iterator() - Method in class org.davidmoten.kool.internal.operators.stream.Split

iterator() - Method in class org.davidmoten.kool.internal.operators.stream.SwitchOnEmpty

iterator() - Method in class org.davidmoten.kool.internal.operators.stream.SwitchOnError

iterator() - Method in class org.davidmoten.kool.internal.operators.stream.Take

iterator() - Method in class org.davidmoten.kool.internal.operators.stream.TakeLast

iterator() - Method in class org.davidmoten.kool.internal.operators.stream.TakeWithPredicate

iterator() - Method in class org.davidmoten.kool.internal.operators.stream.Transform

iterator() - Method in class org.davidmoten.kool.internal.operators.stream.Using

iterator() - Method in class org.davidmoten.kool.internal.operators.stream.Zip

iterator() - Method in class org.davidmoten.kool.internal.util.EmptyStream

iterator(List<T>) - Static method in class org.davidmoten.kool.internal.util.Permutations

iterator() - Method in class org.davidmoten.kool.internal.util.StreamImpl

iterator(StreamIterable<T>) - Static method in class org.davidmoten.kool.internal.util.StreamUtils

iterator() - Method in interface org.davidmoten.kool.Maybe

iterator() - Method in class org.davidmoten.kool.Publisher

iterator() - Method in interface org.davidmoten.kool.Single

iterator() - Method in interface org.davidmoten.kool.StreamIterable

iteratorNullChecked() - Method in interface org.davidmoten.kool.StreamIterable

J

join(String) - Method in interface org.davidmoten.kool.Stream

Json - Class in org.davidmoten.kool.json

JsonArray - Class in org.davidmoten.kool.json

K

kurtosis() - Method in class org.davidmoten.kool.Statistics

Returns the calculated kurtosis of the data.

L

Last<T> - Class in org.davidmoten.kool.internal.operators.stream

Last(StreamIterable<T>) - Constructor for class org.davidmoten.kool.internal.operators.stream.Last

last() - Method in interface org.davidmoten.kool.Stream

LazyArrayNode - Class in org.davidmoten.kool.json

LazyObjectNode - Class in org.davidmoten.kool.json

LazyTreeNode - Class in org.davidmoten.kool.json

LazyValueNode - Class in org.davidmoten.kool.json

left() - Method in class org.davidmoten.kool.internal.util.Permutations.Swap

limit(long) - Method in interface org.davidmoten.kool.Stream

lines(BufferedReader) - Static method in interface org.davidmoten.kool.Stream

lines(Callable<? extends BufferedReader>) - Static method in interface org.davidmoten.kool.Stream

lines(Callable<? extends InputStream>, Charset) - Static method in interface org.davidmoten.kool.Stream

lines(File, Charset) - Static method in interface org.davidmoten.kool.Stream

lines(File) - Static method in interface org.davidmoten.kool.Stream

linesFromResource(String, Charset) - Static method in interface org.davidmoten.kool.Stream

linesFromResource(Class<?>, String, Charset) - Static method in interface org.davidmoten.kool.Stream

linesFromResource(String) - Static method in interface org.davidmoten.kool.Stream

listAccumulator() - Static method in class org.davidmoten.kool.internal.util.StreamUtils

load() - Method in class org.davidmoten.kool.internal.util.BaseStreamIterator

Guaranteed preconditions are that it !

M

Map<T,R> - Class in org.davidmoten.kool.internal.operators.single

Map(Function<? super T, ? extends R>, Single<T>) - Constructor for class org.davidmoten.kool.internal.operators.single.Map

Map<T,R> - Class in org.davidmoten.kool.internal.operators.stream

Map(Function<? super T, ? extends R>, StreamIterable<T>) - Constructor for class org.davidmoten.kool.internal.operators.stream.Map

map(Function<? super T, ? extends R>) - Method in interface org.davidmoten.kool.Maybe

map(Function<? super T, ? extends R>) - Method in interface org.davidmoten.kool.Single

map(Function<? super T, ? extends R>) - Method in interface org.davidmoten.kool.Stream

MAPPER - Static variable in class org.davidmoten.kool.json.Util

mapWithIndex(long) - Method in interface org.davidmoten.kool.Stream

mapWithIndex() - Method in interface org.davidmoten.kool.Stream

Materialize<T> - Class in org.davidmoten.kool.internal.operators.stream

Materialize(Stream<T>) - Constructor for class org.davidmoten.kool.internal.operators.stream.Materialize

materialize() - Method in interface org.davidmoten.kool.Stream

Max<T> - Class in org.davidmoten.kool.internal.operators.stream

Max(Stream<T>, Comparator<? super T>, boolean) - Constructor for class org.davidmoten.kool.internal.operators.stream.Max

max() - Method in class org.davidmoten.kool.Statistics

max(Comparator<? super T>) - Method in interface org.davidmoten.kool.Stream

maxReplay(int) - Method in class org.davidmoten.kool.BufferBuilder.BuilderHasStep

maxRetries(int) - Method in class org.davidmoten.kool.RetryWhenBuilder

maxRetries(int) - Method in class org.davidmoten.kool.RetryWhenBuilderMaybe

maxRetries(int) - Method in class org.davidmoten.kool.RetryWhenBuilderSingle

Maybe<T> - Interface in org.davidmoten.kool

maybe() - Method in interface org.davidmoten.kool.Stream

MaybeDefer<T> - Class in org.davidmoten.kool.internal.operators.maybe

MaybeDefer(Callable<? extends Maybe<? extends T>>) - Constructor for class org.davidmoten.kool.internal.operators.maybe.MaybeDefer

MaybeDoOnEmpty<T> - Class in org.davidmoten.kool.internal.operators.maybe

MaybeDoOnEmpty(Maybe<T>, Runnable) - Constructor for class org.davidmoten.kool.internal.operators.maybe.MaybeDoOnEmpty

MaybeDoOnError<T> - Class in org.davidmoten.kool.internal.operators.maybe

MaybeDoOnError(Consumer<? super Throwable>, Maybe<T>) - Constructor for class org.davidmoten.kool.internal.operators.maybe.MaybeDoOnError

MaybeDoOnValue<T> - Class in org.davidmoten.kool.internal.operators.maybe

MaybeDoOnValue(Consumer<? super T>, Maybe<T>) - Constructor for class org.davidmoten.kool.internal.operators.maybe.MaybeDoOnValue

MaybeError<T> - Class in org.davidmoten.kool.internal.operators.maybe

MaybeError(Callable<? extends Throwable>) - Constructor for class org.davidmoten.kool.internal.operators.maybe.MaybeError

MaybeFilter<T> - Class in org.davidmoten.kool.internal.operators.maybe

MaybeFilter(Predicate<? super T>, Maybe<T>) - Constructor for class org.davidmoten.kool.internal.operators.maybe.MaybeFilter

MaybeFlatMap<T,R> - Class in org.davidmoten.kool.internal.operators.maybe

MaybeFlatMap(Maybe<T>, Function<? super T, ? extends StreamIterable<? extends R>>) - Constructor for class org.davidmoten.kool.internal.operators.maybe.MaybeFlatMap

MaybeFlatMapMaybe<T,R> - Class in org.davidmoten.kool.internal.operators.maybe

MaybeFlatMapMaybe(Maybe<T>, Function<? super T, ? extends Maybe<? extends R>>) - Constructor for class org.davidmoten.kool.internal.operators.maybe.MaybeFlatMapMaybe

MaybeFromCallable<T> - Class in org.davidmoten.kool.internal.operators.maybe

MaybeFromCallable(Callable<? extends T>, boolean) - Constructor for class org.davidmoten.kool.internal.operators.maybe.MaybeFromCallable

MaybeImpl<T> - Class in org.davidmoten.kool.internal.util

MaybeImpl(Optional<T>) - Constructor for class org.davidmoten.kool.internal.util.MaybeImpl

MaybeImpl.EmptyHolder - Class in org.davidmoten.kool.internal.util

MaybeIsPresent - Class in org.davidmoten.kool.internal.operators.maybe

MaybeIsPresent(Maybe<?>) - Constructor for class org.davidmoten.kool.internal.operators.maybe.MaybeIsPresent

MaybeIterator<T> - Class in org.davidmoten.kool.internal.operators.maybe

MaybeIterator(Maybe<T>) - Constructor for class org.davidmoten.kool.internal.operators.maybe.MaybeIterator

MaybeMap<T,R> - Class in org.davidmoten.kool.internal.operators.maybe

MaybeMap(Maybe<T>, Function<? super T, ? extends R>) - Constructor for class org.davidmoten.kool.internal.operators.maybe.MaybeMap

MaybeOrElse<T> - Class in org.davidmoten.kool.internal.operators.maybe

MaybeOrElse(Maybe<T>, T) - Constructor for class org.davidmoten.kool.internal.operators.maybe.MaybeOrElse

MaybeSwitchOnError<T> - Class in org.davidmoten.kool.internal.operators.maybe

MaybeSwitchOnError(Maybe<T>, Function<? super Throwable, ? extends Maybe<? extends T>>) - Constructor for class org.davidmoten.kool.internal.operators.maybe.MaybeSwitchOnError

MaybeTester<T> - Class in org.davidmoten.kool

MaybeTester(Maybe<T>) - Constructor for class org.davidmoten.kool.MaybeTester

MaybeToStream<T> - Class in org.davidmoten.kool.internal.operators.maybe

MaybeToStream(Maybe<T>) - Constructor for class org.davidmoten.kool.internal.operators.maybe.MaybeToStream

mean() - Method in class org.davidmoten.kool.Statistics

merge(Stream<? extends T>...) - Static method in interface org.davidmoten.kool.Stream

Returns an interleaved merge of the streams (one item emitted from each stream in round-robin style).

MergeInterleaved<T> - Class in org.davidmoten.kool.internal.operators.stream

MergeInterleaved(Stream<? extends T>...) - Constructor for class org.davidmoten.kool.internal.operators.stream.MergeInterleaved

mergeWith(Stream<? extends T>) - Method in interface org.davidmoten.kool.Stream

min() - Method in class org.davidmoten.kool.Statistics

min(Comparator<? super T>) - Method in interface org.davidmoten.kool.Stream

N

next() - Method in class org.davidmoten.kool.internal.operators.maybe.MaybeIterator

next() - Method in class org.davidmoten.kool.internal.operators.single.SingleIterator

next() - Method in class org.davidmoten.kool.internal.operators.stream.ReplayableStreamIterator

next - Variable in class org.davidmoten.kool.internal.util.BaseStreamIterator

next() - Method in class org.davidmoten.kool.internal.util.BaseStreamIterator

next() - Method in class org.davidmoten.kool.internal.util.EmptyStream

next(StreamIterator<T>) - Static method in class org.davidmoten.kool.internal.util.StreamUtils

nextElement() - Method in class org.davidmoten.kool.internal.util.EvictingQueue

nextNullChecked() - Method in interface org.davidmoten.kool.StreamIterator

node() - Method in class org.davidmoten.kool.json.Json

nodes() - Method in class org.davidmoten.kool.json.JsonArray

noneMatch(Predicate<? super T>) - Method in interface org.davidmoten.kool.Stream

not(Predicate<T>) - Static method in class org.davidmoten.kool.function.Predicates

Notification<T> - Class in org.davidmoten.kool

O

objectNode() - Method in class org.davidmoten.kool.json.Json

objectNodes() - Method in class org.davidmoten.kool.json.JsonArray

of(T) - Static method in interface org.davidmoten.kool.Maybe

of(T) - Static method in class org.davidmoten.kool.Notification

of(T) - Static method in interface org.davidmoten.kool.Single

of(T) - Static method in interface org.davidmoten.kool.Stream

of(T, T) - Static method in interface org.davidmoten.kool.Stream

of(T, T, T) - Static method in interface org.davidmoten.kool.Stream

of(T, T, T, T) - Static method in interface org.davidmoten.kool.Stream

of(T, T, T, T, T) - Static method in interface org.davidmoten.kool.Stream

of(T, T, T, T, T, T) - Static method in interface org.davidmoten.kool.Stream

of(T, T, T, T, T, T, T) - Static method in interface org.davidmoten.kool.Stream

of(T, T, T, T, T, T, T, T) - Static method in interface org.davidmoten.kool.Stream

offer(T) - Method in class org.davidmoten.kool.internal.util.RingBuffer

ofNoCopy(T...) - Static method in class org.davidmoten.kool.internal.util.Iterables

ofNullable(T) - Static method in interface org.davidmoten.kool.Maybe

onComplete() - Method in interface org.davidmoten.kool.Emitter

onError(Throwable) - Static method in class org.davidmoten.kool.Plugins

onNext(T) - Method in interface org.davidmoten.kool.Emitter

onNext(T) - Method in class org.davidmoten.kool.Publisher

ordinals() - Static method in interface org.davidmoten.kool.Stream

ordinalsLong() - Static method in interface org.davidmoten.kool.Stream

orElse(T) - Method in interface org.davidmoten.kool.Maybe

org.davidmoten.kool - package org.davidmoten.kool

org.davidmoten.kool.exceptions - package org.davidmoten.kool.exceptions

org.davidmoten.kool.function - package org.davidmoten.kool.function

org.davidmoten.kool.internal.operators.maybe - package org.davidmoten.kool.internal.operators.maybe

org.davidmoten.kool.internal.operators.single - package org.davidmoten.kool.internal.operators.single

org.davidmoten.kool.internal.operators.stream - package org.davidmoten.kool.internal.operators.stream

org.davidmoten.kool.internal.util - package org.davidmoten.kool.internal.util

org.davidmoten.kool.json - package org.davidmoten.kool.json

P

Permutations - Class in org.davidmoten.kool.internal.util

permutations(int) - Static method in interface org.davidmoten.kool.Stream

Permutations.Swap<T> - Class in org.davidmoten.kool.internal.util

Plugins - Class in org.davidmoten.kool

Plugins() - Constructor for class org.davidmoten.kool.Plugins

poll() - Method in class org.davidmoten.kool.internal.util.RingBuffer

PowerSet - Class in org.davidmoten.kool.internal.operators.stream

PowerSet(int) - Constructor for class org.davidmoten.kool.internal.operators.stream.PowerSet

powerSet(int) - Static method in interface org.davidmoten.kool.Stream

Predicate<T> - Interface in org.davidmoten.kool.function

Predicates - Class in org.davidmoten.kool.function

prepend(T) - Method in interface org.davidmoten.kool.Stream

prepend(T[]) - Method in interface org.davidmoten.kool.Stream

prepend(StreamIterable<? extends T>) - Method in interface org.davidmoten.kool.Stream

prepend(Iterable<? extends T>) - Method in interface org.davidmoten.kool.Stream

PrependOne<T> - Class in org.davidmoten.kool.internal.operators.stream

PrependOne(T, StreamIterable<T>) - Constructor for class org.davidmoten.kool.internal.operators.stream.PrependOne

println() - Method in interface org.davidmoten.kool.Maybe

println() - Method in interface org.davidmoten.kool.Single

println() - Method in interface org.davidmoten.kool.Stream

printStackTrace() - Method in exception org.davidmoten.kool.exceptions.CompositeException

All of the following printStackTrace functionality is derived from JDK Throwable printStackTrace.

printStackTrace(PrintStream) - Method in exception org.davidmoten.kool.exceptions.CompositeException

printStackTrace(PrintWriter) - Method in exception org.davidmoten.kool.exceptions.CompositeException

printStackTrace() - Method in interface org.davidmoten.kool.Stream

publish() - Method in interface org.davidmoten.kool.Stream

Publisher<T> - Class in org.davidmoten.kool

Publisher(StreamIterable<T>) - Constructor for class org.davidmoten.kool.Publisher

R

Range - Class in org.davidmoten.kool.internal.operators.stream

Range(int, int) - Constructor for class org.davidmoten.kool.internal.operators.stream.Range

range() - Method in class org.davidmoten.kool.Statistics

range(int, int) - Static method in interface org.davidmoten.kool.Stream

RangeLong - Class in org.davidmoten.kool.internal.operators.stream

RangeLong(long, long) - Constructor for class org.davidmoten.kool.internal.operators.stream.RangeLong

rangeLong(long, long) - Static method in interface org.davidmoten.kool.Stream

ReaderFactory - Interface in org.davidmoten.kool.json

reduce(BiFunction<? super T, ? super T, ? extends T>) - Method in interface org.davidmoten.kool.Stream

reduce(R, BiFunction<? super R, ? super T, ? extends R>) - Method in interface org.davidmoten.kool.Stream

ReduceNoInitialValue<T> - Class in org.davidmoten.kool.internal.operators.stream

ReduceNoInitialValue(BiFunction<? super T, ? super T, ? extends T>, StreamIterable<T>) - Constructor for class org.davidmoten.kool.internal.operators.stream.ReduceNoInitialValue

reduceWithFactory(Callable<? extends R>, BiFunction<? super R, ? super T, ? extends R>) - Method in interface org.davidmoten.kool.Stream

ReduceWithInitialValueSupplier<R,T> - Class in org.davidmoten.kool.internal.operators.stream

ReduceWithInitialValueSupplier(Callable<? extends R>, BiFunction<? super R, ? super T, ? extends R>, StreamIterable<T>) - Constructor for class org.davidmoten.kool.internal.operators.stream.ReduceWithInitialValueSupplier

Repeat<T> - Class in org.davidmoten.kool.internal.operators.stream

Repeat(long, Stream<T>) - Constructor for class org.davidmoten.kool.internal.operators.stream.Repeat

repeat() - Method in interface org.davidmoten.kool.Single

repeat(long) - Method in interface org.davidmoten.kool.Stream

repeat() - Method in interface org.davidmoten.kool.Stream

RepeatElement<T> - Class in org.davidmoten.kool.internal.operators.stream

RepeatElement(T, long) - Constructor for class org.davidmoten.kool.internal.operators.stream.RepeatElement

repeatElement(T) - Static method in interface org.davidmoten.kool.Stream

repeatElement(T, long) - Static method in interface org.davidmoten.kool.Stream

RepeatLast<T> - Class in org.davidmoten.kool.internal.operators.stream

RepeatLast(Stream<T>, long) - Constructor for class org.davidmoten.kool.internal.operators.stream.RepeatLast

repeatLast(long) - Method in interface org.davidmoten.kool.Stream

repeatLast() - Method in interface org.davidmoten.kool.Stream

replay(int) - Method in class org.davidmoten.kool.internal.operators.stream.ReplayableStreamIterator

replay(int) - Method in class org.davidmoten.kool.internal.util.RingBuffer

ReplayableStreamIterator<T> - Class in org.davidmoten.kool.internal.operators.stream

ReplayableStreamIterator(StreamIterator<T>, int) - Constructor for class org.davidmoten.kool.internal.operators.stream.ReplayableStreamIterator

rethrow(Throwable) - Static method in class org.davidmoten.kool.internal.util.Exceptions

rethrow(Callable<? extends Throwable>) - Static method in class org.davidmoten.kool.internal.util.Exceptions

RetryWhen<T> - Class in org.davidmoten.kool.internal.operators.stream

RetryWhen(Stream<T>, Function<? super Throwable, ? extends Single<?>>) - Constructor for class org.davidmoten.kool.internal.operators.stream.RetryWhen

retryWhen(Function<? super Throwable, ? extends Single<?>>) - Method in interface org.davidmoten.kool.Maybe

retryWhen() - Method in interface org.davidmoten.kool.Maybe

retryWhen(Function<? super Throwable, ? extends Single<?>>) - Method in interface org.davidmoten.kool.Single

retryWhen() - Method in interface org.davidmoten.kool.Single

retryWhen(Function<? super Throwable, ? extends Single<?>>) - Method in interface org.davidmoten.kool.Stream

retryWhen() - Method in interface org.davidmoten.kool.Stream

RetryWhenBuilder<T> - Class in org.davidmoten.kool

RetryWhenBuilder(Stream<T>) - Constructor for class org.davidmoten.kool.RetryWhenBuilder

RetryWhenBuilderMaybe<T> - Class in org.davidmoten.kool

RetryWhenBuilderMaybe(Maybe<T>) - Constructor for class org.davidmoten.kool.RetryWhenBuilderMaybe

RetryWhenBuilderSingle<T> - Class in org.davidmoten.kool

RetryWhenBuilderSingle(Single<T>) - Constructor for class org.davidmoten.kool.RetryWhenBuilderSingle

Reverse<T> - Class in org.davidmoten.kool.internal.operators.stream

Reverse(Stream<T>) - Constructor for class org.davidmoten.kool.internal.operators.stream.Reverse

reverse() - Method in interface org.davidmoten.kool.Stream

right() - Method in class org.davidmoten.kool.internal.util.Permutations.Swap

RingBuffer<T> - Class in org.davidmoten.kool.internal.util

RingBuffer(int) - Constructor for class org.davidmoten.kool.internal.util.RingBuffer

S

scan(R, BiFunction<? super R, ? super T, ? extends R>) - Method in interface org.davidmoten.kool.Stream

set(int, T) - Method in class org.davidmoten.kool.internal.util.RingBuffer

Single<T> - Interface in org.davidmoten.kool

single() - Method in interface org.davidmoten.kool.Stream

SingleDoOnError<T> - Class in org.davidmoten.kool.internal.operators.single

SingleDoOnError(Consumer<? super Throwable>, Single<T>) - Constructor for class org.davidmoten.kool.internal.operators.single.SingleDoOnError

SingleDoOnValue<T> - Class in org.davidmoten.kool.internal.operators.single

SingleDoOnValue(Consumer<? super T>, Single<T>) - Constructor for class org.davidmoten.kool.internal.operators.single.SingleDoOnValue

SingleError<T> - Class in org.davidmoten.kool.internal.operators.single

SingleError(Callable<? extends Throwable>) - Constructor for class org.davidmoten.kool.internal.operators.single.SingleError

SingleFlatMap<T,R> - Class in org.davidmoten.kool.internal.operators.single

SingleFlatMap(Single<T>, Function<? super T, ? extends StreamIterable<? extends R>>) - Constructor for class org.davidmoten.kool.internal.operators.single.SingleFlatMap

SingleFlatMapMaybe<T,R> - Class in org.davidmoten.kool.internal.operators.single

SingleFlatMapMaybe(Single<T>, Function<? super T, ? extends Maybe<? extends R>>) - Constructor for class org.davidmoten.kool.internal.operators.single.SingleFlatMapMaybe

SingleFromCallable<T> - Class in org.davidmoten.kool.internal.operators.single

SingleFromCallable(Callable<? extends T>) - Constructor for class org.davidmoten.kool.internal.operators.single.SingleFromCallable

SingleIterator<T> - Class in org.davidmoten.kool.internal.operators.single

SingleIterator(Single<T>) - Constructor for class org.davidmoten.kool.internal.operators.single.SingleIterator

SingleOf<T> - Class in org.davidmoten.kool.internal.operators.single

SingleOf(T) - Constructor for class org.davidmoten.kool.internal.operators.single.SingleOf

SingleSwitchOnError<T> - Class in org.davidmoten.kool.internal.operators.single

SingleSwitchOnError(Single<T>, Function<? super Throwable, ? extends Single<? extends T>>) - Constructor for class org.davidmoten.kool.internal.operators.single.SingleSwitchOnError

SingleTester<T> - Class in org.davidmoten.kool

SingleToStream<T> - Class in org.davidmoten.kool.internal.operators.single

SingleToStream(Single<T>) - Constructor for class org.davidmoten.kool.internal.operators.single.SingleToStream

size() - Method in exception org.davidmoten.kool.exceptions.CompositeException

Returns the number of suppressed exceptions.

size() - Method in class org.davidmoten.kool.internal.util.RingBuffer

skewness() - Method in class org.davidmoten.kool.Statistics

Skip<T> - Class in org.davidmoten.kool.internal.operators.stream

Skip(long, Stream<T>) - Constructor for class org.davidmoten.kool.internal.operators.stream.Skip

skip(long) - Method in interface org.davidmoten.kool.Stream

SkipLast<T> - Class in org.davidmoten.kool.internal.operators.stream

SkipLast(int, Stream<T>) - Constructor for class org.davidmoten.kool.internal.operators.stream.SkipLast

skipLast(int) - Method in interface org.davidmoten.kool.Stream

SkipUntil<T> - Class in org.davidmoten.kool.internal.operators.stream

SkipUntil(Stream<T>, Predicate<? super T>, boolean) - Constructor for class org.davidmoten.kool.internal.operators.stream.SkipUntil

skipUntil(Predicate<? super T>) - Method in interface org.davidmoten.kool.Stream

skipWhile(Predicate<? super T>) - Method in interface org.davidmoten.kool.Stream

Sorted<T> - Class in org.davidmoten.kool.internal.operators.stream

Sorted(Comparator<? super T>, Stream<T>) - Constructor for class org.davidmoten.kool.internal.operators.stream.Sorted

sorted(Comparator<? super T>) - Method in interface org.davidmoten.kool.Stream

sorted() - Method in interface org.davidmoten.kool.Stream

Split - Class in org.davidmoten.kool.internal.operators.stream

Split(String, Stream<?>) - Constructor for class org.davidmoten.kool.internal.operators.stream.Split

split(String) - Method in interface org.davidmoten.kool.Stream

standardDeviation() - Method in class org.davidmoten.kool.Statistics

start() - Method in interface org.davidmoten.kool.Maybe

start() - Method in interface org.davidmoten.kool.Single

start() - Method in interface org.davidmoten.kool.Stream

Statistics - Class in org.davidmoten.kool

statistics(Function<? super T, ? extends R>) - Method in interface org.davidmoten.kool.Stream

statistics(Stream<T>) - Static method in interface org.davidmoten.kool.Stream

step(int) - Method in class org.davidmoten.kool.BufferBuilder.BuilderHasAccumulator

step(Function<? super S, Integer>) - Method in class org.davidmoten.kool.BufferBuilder.BuilderHasAccumulator

stream(InputStreamFactory) - Static method in class org.davidmoten.kool.json.Json

stream(ReaderFactory) - Static method in class org.davidmoten.kool.json.Json

stream(InputStream) - Static method in class org.davidmoten.kool.json.Json

stream(Reader) - Static method in class org.davidmoten.kool.json.Json

stream(String) - Static method in class org.davidmoten.kool.json.Json

stream(Function<? super JsonFactory, ? extends JsonParser>) - Static method in class org.davidmoten.kool.json.Json

Stream<T> - Interface in org.davidmoten.kool

StreamImpl<T> - Class in org.davidmoten.kool.internal.util

StreamImpl(Iterable<? extends T>) - Constructor for class org.davidmoten.kool.internal.util.StreamImpl

StreamIterable<T> - Interface in org.davidmoten.kool

StreamIterator<T> - Interface in org.davidmoten.kool

StreamUtils - Class in org.davidmoten.kool.internal.util

StreamUtils.EmptyHolder - Class in org.davidmoten.kool.internal.util

StreamUtils.FunctionIdentityHolder - Class in org.davidmoten.kool.internal.util

strings(Stream<? extends byte[]>, Charset, int) - Static method in interface org.davidmoten.kool.Stream

strings(Stream<? extends byte[]>, Charset) - Static method in interface org.davidmoten.kool.Stream

strings(Stream<? extends byte[]>) - Static method in interface org.davidmoten.kool.Stream

sumDouble(Function<? super T, Double>) - Method in interface org.davidmoten.kool.Stream

sumInt(Function<? super T, Integer>) - Method in interface org.davidmoten.kool.Stream

sumLong(Function<? super T, Long>) - Method in interface org.davidmoten.kool.Stream

SwitchOnEmpty<T> - Class in org.davidmoten.kool.internal.operators.stream

SwitchOnEmpty(Stream<T>, Callable<? extends Stream<T>>) - Constructor for class org.davidmoten.kool.internal.operators.stream.SwitchOnEmpty

switchOnEmpty(Callable<? extends Stream<T>>) - Method in interface org.davidmoten.kool.Stream

SwitchOnError<T> - Class in org.davidmoten.kool.internal.operators.stream

SwitchOnError(Function<? super Throwable, ? extends StreamIterable<? extends T>>, Stream<T>) - Constructor for class org.davidmoten.kool.internal.operators.stream.SwitchOnError

switchOnError(Function<? super Throwable, ? extends Maybe<? extends T>>) - Method in interface org.davidmoten.kool.Maybe

switchOnError(Function<? super Throwable, ? extends Single<? extends T>>) - Method in interface org.davidmoten.kool.Single

switchOnError(Function<? super Throwable, ? extends Stream<? extends T>>) - Method in interface org.davidmoten.kool.Stream

T

Take<T> - Class in org.davidmoten.kool.internal.operators.stream

Take(long, StreamIterable<T>) - Constructor for class org.davidmoten.kool.internal.operators.stream.Take

take(long) - Method in interface org.davidmoten.kool.Stream

TakeLast<T> - Class in org.davidmoten.kool.internal.operators.stream

TakeLast(Stream<T>, long) - Constructor for class org.davidmoten.kool.internal.operators.stream.TakeLast

takeLast(long) - Method in interface org.davidmoten.kool.Stream

takeUntil(Predicate<? super T>) - Method in interface org.davidmoten.kool.Stream

takeWhile(Predicate<? super T>) - Method in interface org.davidmoten.kool.Stream

TakeWithPredicate<T> - Class in org.davidmoten.kool.internal.operators.stream

TakeWithPredicate(Predicate<? super T>, Stream<T>, boolean) - Constructor for class org.davidmoten.kool.internal.operators.stream.TakeWithPredicate

test(T, R) - Method in interface org.davidmoten.kool.function.BiPredicate

test(T) - Method in interface org.davidmoten.kool.function.Predicate

test() - Method in interface org.davidmoten.kool.Maybe

test() - Method in interface org.davidmoten.kool.Single

test() - Method in interface org.davidmoten.kool.Stream

testChecked(T) - Method in interface org.davidmoten.kool.function.Predicate

Tester<T> - Class in org.davidmoten.kool

Tester(Stream<T>) - Constructor for class org.davidmoten.kool.Tester

testUnchecked(T, R) - Method in interface org.davidmoten.kool.function.BiPredicate

timer(long, TimeUnit) - Static method in interface org.davidmoten.kool.Single

timer(T, long, TimeUnit) - Static method in interface org.davidmoten.kool.Single

to(Function<? super Maybe<T>, R>) - Method in interface org.davidmoten.kool.Maybe

to(Function<? super Single<T>, R>) - Method in interface org.davidmoten.kool.Single

to(Function<? super Stream<T>, R>) - Method in interface org.davidmoten.kool.Stream

toInputStream(Stream<? extends byte[]>) - Static method in class org.davidmoten.kool.internal.util.StreamUtils

toList() - Method in interface org.davidmoten.kool.Stream

toList(int) - Method in interface org.davidmoten.kool.Stream

toMap(Function<? super T, ? extends K>, Function<? super T, ? extends V>) - Method in interface org.davidmoten.kool.Stream

ToMaybe<T> - Class in org.davidmoten.kool.internal.operators.stream

ToMaybe(Stream<T>) - Constructor for class org.davidmoten.kool.internal.operators.stream.ToMaybe

toSet() - Method in interface org.davidmoten.kool.Stream

toSet(int) - Method in interface org.davidmoten.kool.Stream

ToSingle<T> - Class in org.davidmoten.kool.internal.operators.stream

ToSingle(Stream<T>) - Constructor for class org.davidmoten.kool.internal.operators.stream.ToSingle

toStream() - Method in interface org.davidmoten.kool.Maybe

toStream() - Method in interface org.davidmoten.kool.Single

toStreamJava() - Method in interface org.davidmoten.kool.Stream

toString() - Method in class org.davidmoten.kool.Indexed

toString() - Method in class org.davidmoten.kool.internal.util.Permutations.Swap

toString(String, String) - Method in class org.davidmoten.kool.Statistics

toString() - Method in class org.davidmoten.kool.Statistics

Transform<T,R> - Class in org.davidmoten.kool.internal.operators.stream

Transform(Function<? super Stream<T>, ? extends Stream<? extends R>>, Stream<T>) - Constructor for class org.davidmoten.kool.internal.operators.stream.Transform

transform(Function<? super Stream<T>, ? extends Stream<? extends R>>) - Method in interface org.davidmoten.kool.Stream

TransformMaybe<T,R> - Class in org.davidmoten.kool.internal.operators.stream

TransformMaybe(Function<? super Stream<T>, ? extends Maybe<? extends R>>, Stream<T>) - Constructor for class org.davidmoten.kool.internal.operators.stream.TransformMaybe

transformMaybe(Function<? super Stream<T>, ? extends Maybe<? extends R>>) - Method in interface org.davidmoten.kool.Stream

TransformSingle<T,R> - Class in org.davidmoten.kool.internal.operators.stream

TransformSingle(Function<? super Stream<T>, ? extends Single<? extends R>>, Stream<T>) - Constructor for class org.davidmoten.kool.internal.operators.stream.TransformSingle

transformSingle(Function<? super Stream<T>, ? extends Single<? extends R>>) - Method in interface org.davidmoten.kool.Stream

U

UncheckedException - Exception in org.davidmoten.kool.exceptions

UncheckedException(Throwable) - Constructor for exception org.davidmoten.kool.exceptions.UncheckedException

Using<R,T> - Class in org.davidmoten.kool.internal.operators.stream

Using(Callable<? extends R>, Function<? super R, ? extends Stream<? extends T>>, Consumer<? super R>) - Constructor for class org.davidmoten.kool.internal.operators.stream.Using

using(Callable<? extends R>, Function<? super R, ? extends Stream<? extends T>>, Consumer<? super R>) - Static method in interface org.davidmoten.kool.Stream

using(Callable<? extends R>, Function<? super R, ? extends Stream<? extends T>>) - Static method in interface org.davidmoten.kool.Stream

Util - Class in org.davidmoten.kool.json

V

value() - Method in class org.davidmoten.kool.Indexed

value() - Method in class org.davidmoten.kool.Notification

valueNode() - Method in class org.davidmoten.kool.json.Json

valueNodes() - Method in class org.davidmoten.kool.json.JsonArray

values() - Method in class org.davidmoten.kool.json.LazyArrayNode

values(Class<T>) - Method in class org.davidmoten.kool.json.LazyArrayNode

variance() - Method in class org.davidmoten.kool.Statistics

W

withMapper(ObjectMapper) - Method in class org.davidmoten.kool.json.Json

Z

Zip<R,S,T> - Class in org.davidmoten.kool.internal.operators.stream

Zip(Stream<T>, Stream<? extends R>, BiFunction<T, R, S>) - Constructor for class org.davidmoten.kool.internal.operators.stream.Zip

zipWith(Stream<? extends R>, BiFunction<T, R, S>) - Method in interface org.davidmoten.kool.Stream

A B C D E F G H I J K L M N O P R S T U V W Z