org.immutables.criteria.repository

Class Publishers

java.lang.Object

org.immutables.criteria.repository.Publishers

public final class Publishers
extends Object

Method Summary

Modifier and Type	Method and Description
static <X> X	blockingGet(org.reactivestreams.Publisher<X> publisher)
static <X> List<X>	blockingListGet(org.reactivestreams.Publisher<X> publisher)
static <T,R> org.reactivestreams.Publisher<R>	flatMapIterable(org.reactivestreams.Publisher<T> publisher, Function<? super T,? extends Iterable<? extends R>> mapper)
static <X> org.reactivestreams.Publisher<X>	limit(org.reactivestreams.Publisher<X> publisher, long count)
static <T,R> org.reactivestreams.Publisher<R>	map(org.reactivestreams.Publisher<T> publisher, Function<? super T,? extends R> mapper)
static <X> CompletionStage<X>	toFuture(org.reactivestreams.Publisher<X> publisher)
static <X> org.reactivestreams.Publisher<List<X>>	toList(org.reactivestreams.Publisher<X> publisher)
static <X> CompletionStage<List<X>>	toListFuture(org.reactivestreams.Publisher<X> publisher)

Methods inherited from class java.lang.Object

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

Method Detail

toListFuture

public static <X> CompletionStage<List<X>> toListFuture(org.reactivestreams.Publisher<X> publisher)

blockingGet

public static <X> X blockingGet(org.reactivestreams.Publisher<X> publisher)

limit

public static <X> org.reactivestreams.Publisher<X> limit(org.reactivestreams.Publisher<X> publisher,
                                                         long count)

toList

public static <X> org.reactivestreams.Publisher<List<X>> toList(org.reactivestreams.Publisher<X> publisher)

map

public static <T,R> org.reactivestreams.Publisher<R> map(org.reactivestreams.Publisher<T> publisher,
                                                         Function<? super T,? extends R> mapper)

flatMapIterable

public static <T,R> org.reactivestreams.Publisher<R> flatMapIterable(org.reactivestreams.Publisher<T> publisher,
                                                                     Function<? super T,? extends Iterable<? extends R>> mapper)

blockingListGet

public static <X> List<X> blockingListGet(org.reactivestreams.Publisher<X> publisher)

toFuture

public static <X> CompletionStage<X> toFuture(org.reactivestreams.Publisher<X> publisher)