@CompileStatic public class StreamExtensions extends Object implements groovy.lang.GroovyObject
Constructor and Description |
---|
StreamExtensions() |
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>> |
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>> |
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) |
public groovy.lang.MetaClass getMetaClass()
getMetaClass
in interface groovy.lang.GroovyObject
public void setMetaClass(groovy.lang.MetaClass mc)
setMetaClass
in interface groovy.lang.GroovyObject
public Object invokeMethod(String method, Object arguments)
invokeMethod
in interface groovy.lang.GroovyObject
public Object getProperty(String property)
getProperty
in interface groovy.lang.GroovyObject
public void setProperty(String property, Object value)
setProperty
in interface groovy.lang.GroovyObject
public static <K,V> Stream<Tuple2<K,V>> reduceByKey(org.reactivestreams.Publisher<? extends Tuple2<K,V>> selfType, BiFunction<V,V,V> accumulator)
public static <K,V> Stream<Tuple2<K,V>> scanByKey(org.reactivestreams.Publisher<? extends Tuple2<K,V>> selfType, BiFunction<V,V,V> accumulator)
public static <SRC,IN> Stream<IN> decode(org.reactivestreams.Publisher<? extends SRC> publisher, Codec<SRC,IN,?> codec)
public static <T> Stream<T> mod(Stream<T> selfType, BiFunction<T,T,T> other)
public static <O,E extends org.reactivestreams.Subscriber<? super O>> E or(Stream<O> selfType, E other)
public static <T,P extends org.reactivestreams.Processor<?,T>> P leftShift(P selfType, T value)
Copyright © 2017. All rights reserved.