org.immutables.criteria.repository.reactive

Class ReactiveMapper1<T1>

java.lang.Object

org.immutables.criteria.repository.reactive.ReactiveMapper1<T1>

All Implemented Interfaces:

Fetcher<T1>, ReactiveFetcher<T1>

public class ReactiveMapper1<T1>
extends Object
implements ReactiveFetcher<T1>

Constructor Summary

Constructors

Constructor and Description
ReactiveMapper1(Query query, Backend.Session session)

Method Summary

Modifier and Type	Method and Description
ReactiveMapper1<Optional<T1>>	asOptional()
ReactiveFetcher<T1>	changeQuery(UnaryOperator<Query> mapFn)
org.reactivestreams.Publisher<Long>	count()
org.reactivestreams.Publisher<Boolean>	exists()
org.reactivestreams.Publisher<T1>	fetch()
<X> ReactiveFetcher<X>	map(Function<? super T1,? extends X> mapFn)
org.reactivestreams.Publisher<T1>	one()
org.reactivestreams.Publisher<T1>	oneOrNone()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.immutables.criteria.repository.reactive.ReactiveFetcher

of

Constructor Detail

ReactiveMapper1

public ReactiveMapper1(Query query,
                       Backend.Session session)

Method Detail

asOptional

public ReactiveMapper1<Optional<T1>> asOptional()

fetch

public org.reactivestreams.Publisher<T1> fetch()

one

public org.reactivestreams.Publisher<T1> one()

oneOrNone

public org.reactivestreams.Publisher<T1> oneOrNone()

exists

public org.reactivestreams.Publisher<Boolean> exists()

count

public org.reactivestreams.Publisher<Long> count()

map

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

changeQuery

public ReactiveFetcher<T1> changeQuery(UnaryOperator<Query> mapFn)