Constructor and Description |
---|
VanillaQuery(Stream<E> stream) |
Modifier and Type | Method and Description |
---|---|
<R,A> R |
collect(Collector<? super E,A,R> collector) |
@NotNull Query<E> |
filter(net.openhft.chronicle.core.util.SerializablePredicate<? super E> predicate) |
<R> @NotNull Query<R> |
flatMap(@NotNull net.openhft.chronicle.core.util.SerializableFunction<? super E,? extends Query<? extends R>> mapper) |
void |
forEach(Consumer<? super E> action) |
<R> @NotNull Query<R> |
map(net.openhft.chronicle.core.util.SerializableFunction<? super E,? extends R> mapper) |
<R> @NotNull Query<R> |
project(Class<R> rClass) |
Stream<E> |
stream() |
@NotNull Subscription |
subscribe(Consumer<? super E> action) |
@NotNull public @NotNull Query<E> filter(net.openhft.chronicle.core.util.SerializablePredicate<? super E> predicate)
@NotNull public <R> @NotNull Query<R> map(net.openhft.chronicle.core.util.SerializableFunction<? super E,? extends R> mapper)
@NotNull public <R> @NotNull Query<R> flatMap(@NotNull @NotNull net.openhft.chronicle.core.util.SerializableFunction<? super E,? extends Query<? extends R>> mapper)
@NotNull public @NotNull Subscription subscribe(Consumer<? super E> action)
Copyright © 2021. All rights reserved.