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