reactor.groovy.ext

Class StreamExtensions

java.lang.Object

reactor.groovy.ext.StreamExtensions

All Implemented Interfaces:

groovy.lang.GroovyObject

@CompileStatic
public class StreamExtensions
extends Object
implements groovy.lang.GroovyObject

Constructor Summary

Constructors

Constructor and Description
StreamExtensions()

Method Summary

Modifier and Type	Method and Description
static <T> Stream<T>	and(Promise<T> selfType, Predicate<T> other)
static <T> Stream<T>	and(Stream<T> selfType, Predicate<T> other)
static <SRC,IN> Stream<IN>	decode(org.reactivestreams.Publisher<? extends SRC> publisher, Codec<SRC,IN,?> codec)
groovy.lang.MetaClass	getMetaClass()
Object	getProperty(String property)
Object	invokeMethod(String method, Object arguments)
static <T> Promise<T>	leftShift(Promise<T> selfType, Consumer<T> other)
static <T,P extends org.reactivestreams.Processor<?,T>> P	leftShift(P selfType, T value)
static <T> Control	leftShift(Stream<T> selfType, Consumer<T> other)
static <T> Stream<T>	mod(Stream<T> selfType, BiFunction<T,T,T> other)
static <T,V> Stream<V>	or(Promise<T> selfType, Function<T,V> other)
static <O,E extends org.reactivestreams.Subscriber<? super O>> E	or(Stream<O> selfType, E other)
static <T,V> Stream<V>	or(Stream<T> selfType, Function<T,V> other)
static <K,V> Stream<Tuple2<K,V>>	reduceByKey(org.reactivestreams.Publisher<? extends Tuple2<K,V>> selfType, BiFunction<V,V,V> accumulator)
static <K,V> Stream<Tuple2<K,V>>	scanByKey(org.reactivestreams.Publisher<? extends Tuple2<K,V>> selfType, BiFunction<V,V,V> accumulator)
void	setMetaClass(groovy.lang.MetaClass mc)
void	setProperty(String property, Object value)

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamExtensions

public StreamExtensions()

Method Detail

getMetaClass

public groovy.lang.MetaClass getMetaClass()

Specified by:

getMetaClass in interface groovy.lang.GroovyObject

setMetaClass

public void setMetaClass(groovy.lang.MetaClass mc)

Specified by:

setMetaClass in interface groovy.lang.GroovyObject

invokeMethod

public Object invokeMethod(String method,
                           Object arguments)

Specified by:

invokeMethod in interface groovy.lang.GroovyObject

getProperty

public Object getProperty(String property)

Specified by:

getProperty in interface groovy.lang.GroovyObject

setProperty

public void setProperty(String property,
                        Object value)

Specified by:

setProperty in interface groovy.lang.GroovyObject

reduceByKey

public static <K,V> Stream<Tuple2<K,V>> reduceByKey(org.reactivestreams.Publisher<? extends Tuple2<K,V>> selfType,
                                                    BiFunction<V,V,V> accumulator)

scanByKey

public static <K,V> Stream<Tuple2<K,V>> scanByKey(org.reactivestreams.Publisher<? extends Tuple2<K,V>> selfType,
                                                  BiFunction<V,V,V> accumulator)

decode

public static <SRC,IN> Stream<IN> decode(org.reactivestreams.Publisher<? extends SRC> publisher,
                                         Codec<SRC,IN,?> codec)

mod

public static <T> Stream<T> mod(Stream<T> selfType,
                                BiFunction<T,T,T> other)

or

public static <O,E extends org.reactivestreams.Subscriber<? super O>> E or(Stream<O> selfType,
                                                                           E other)

or

public static <T,V> Stream<V> or(Stream<T> selfType,
                                 Function<T,V> other)

or

public static <T,V> Stream<V> or(Promise<T> selfType,
                                 Function<T,V> other)

and

public static <T> Stream<T> and(Stream<T> selfType,
                                Predicate<T> other)

and

public static <T> Stream<T> and(Promise<T> selfType,
                                Predicate<T> other)

leftShift

public static <T> Control leftShift(Stream<T> selfType,
                                    Consumer<T> other)

leftShift

public static <T> Promise<T> leftShift(Promise<T> selfType,
                                       Consumer<T> other)

leftShift

public static <T,P extends org.reactivestreams.Processor<?,T>> P leftShift(P selfType,
                                                                           T value)