cyclops.streams

Class ReactorOperators

java.lang.Object

cyclops.streams.ReactorOperators

public class ReactorOperators
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
ReactorOperators()

Method Summary

Modifier and Type	Method and Description
static <T,R> java.util.function.Function<ReactiveSeq<T>,ReactiveSeq<R>>	flux(java.util.function.Function<? super reactor.core.publisher.Flux<? super T>,? extends reactor.core.publisher.Flux<? extends R>> fn)
static <T,R> java.util.function.Function<reactor.core.publisher.Mono<T>,reactor.core.publisher.Mono<R>>	future(java.util.function.Function<? super Future<? super T>,? extends Future<? extends R>> fn)
static <T,R> java.util.function.Function<Future<T>,Future<R>>	mono(java.util.function.Function<? super reactor.core.publisher.Mono<? super T>,? extends reactor.core.publisher.Mono<? extends R>> fn)
static <T,R> java.util.function.Function<reactor.core.publisher.Flux<T>,reactor.core.publisher.Flux<R>>	seq(java.util.function.Function<? super ReactiveSeq<? super T>,? extends ReactiveSeq<? extends R>> fn)

Methods inherited from class java.lang.Object

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

Constructor Detail

ReactorOperators

public ReactorOperators()

Method Detail

flux

public static <T,R> java.util.function.Function<ReactiveSeq<T>,ReactiveSeq<R>> flux(java.util.function.Function<? super reactor.core.publisher.Flux<? super T>,? extends reactor.core.publisher.Flux<? extends R>> fn)

seq

public static <T,R> java.util.function.Function<reactor.core.publisher.Flux<T>,reactor.core.publisher.Flux<R>> seq(java.util.function.Function<? super ReactiveSeq<? super T>,? extends ReactiveSeq<? extends R>> fn)

mono

public static <T,R> java.util.function.Function<Future<T>,Future<R>> mono(java.util.function.Function<? super reactor.core.publisher.Mono<? super T>,? extends reactor.core.publisher.Mono<? extends R>> fn)

future

public static <T,R> java.util.function.Function<reactor.core.publisher.Mono<T>,reactor.core.publisher.Mono<R>> future(java.util.function.Function<? super Future<? super T>,? extends Future<? extends R>> fn)