RemoteQuery (ChronicleEnterprise/Chronicle-Datagrid 2.20.83-SNAPSHOT API)

public final class RemoteQuery<E>
extends Object
implements Query<E>

Nested Classes
Modifier and Type	Class and Description
`static interface`	`RemoteQuery.Subscribable<E>`

Constructors
Constructor and Description
`RemoteQuery(RemoteQuery.Subscribable<E> eSubscribable)`

All Methods Instance Methods Concrete Methods
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> project(Class<R> rClass)

@NotNull
public <R> @NotNull Query<R> flatMap(net.openhft.chronicle.core.util.SerializableFunction<? super E,? extends Query<? extends R>> mapper)

@NotNull
public @NotNull Stream<E> stream()

@NotNull
public @NotNull Subscription subscribe(@NotNull
                                                @NotNull Consumer<? super E> action)

public void forEach(@NotNull
                    @NotNull Consumer<? super E> action)

public <R,A> R collect(@NotNull
                       @NotNull Collector<? super E,A,R> collector)

Class RemoteQuery<E>