org.immutables.criteria.repository.reactive

Interface ReactiveFetcher<T>

All Superinterfaces:

Fetcher<T>

All Known Implementing Classes:

ReactiveMapper1, ReactiveReader

public interface ReactiveFetcher<T>
extends Fetcher<T>

Method Summary

Modifier and Type	Method and Description
ReactiveFetcher<T>	changeQuery(UnaryOperator<Query> mapFn)
org.reactivestreams.Publisher<Long>	count()
org.reactivestreams.Publisher<Boolean>	exists()
org.reactivestreams.Publisher<T>	fetch()
<X> ReactiveFetcher<X>	map(Function<? super T,? extends X> mapFn)
static <T> ReactiveFetcher<T>	of(Query query, Backend.Session session)
org.reactivestreams.Publisher<T>	one()
org.reactivestreams.Publisher<T>	oneOrNone()

Method Detail

fetch

org.reactivestreams.Publisher<T> fetch()

one

org.reactivestreams.Publisher<T> one()

oneOrNone

org.reactivestreams.Publisher<T> oneOrNone()

exists

org.reactivestreams.Publisher<Boolean> exists()

count

org.reactivestreams.Publisher<Long> count()

map

<X> ReactiveFetcher<X> map(Function<? super T,? extends X> mapFn)

changeQuery

ReactiveFetcher<T> changeQuery(UnaryOperator<Query> mapFn)

of

static <T> ReactiveFetcher<T> of(Query query,
                                 Backend.Session session)