software.chronicle.datagrid.internal.query

Class VanillaQuery<E>

java.lang.Object

software.chronicle.datagrid.internal.query.VanillaQuery<E>

All Implemented Interfaces:

Query<E>

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

Constructor Summary

Constructors

Constructor and Description
VanillaQuery(Stream<E> stream)

Method Summary

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)

Methods inherited from class java.lang.Object

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

Constructor Detail

VanillaQuery

public VanillaQuery(Stream<E> stream)

Method Detail

filter

@NotNull
public @NotNull Query<E> filter(net.openhft.chronicle.core.util.SerializablePredicate<? super E> predicate)

Specified by:

filter in interface Query<E>

map

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

Specified by:

map in interface Query<E>

project

@NotNull
public <R> @NotNull Query<R> project(Class<R> rClass)

Specified by:

project in interface Query<E>

flatMap

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

Specified by:

flatMap in interface Query<E>

stream

public Stream<E> stream()

Specified by:

stream in interface Query<E>

subscribe

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

Specified by:

subscribe in interface Query<E>

collect

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

Specified by:

collect in interface Query<E>

forEach

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

Specified by:

forEach in interface Query<E>