Modifier and Type | Method and Description |
---|---|
static <KEY,VALUE> |
reduceByKey(org.reactivestreams.Publisher<Tuple2<KEY,VALUE>> publisher,
BiFunction<VALUE,VALUE,VALUE> accumulator) |
static <KEY,VALUE> |
reduceByKey(org.reactivestreams.Publisher<Tuple2<KEY,VALUE>> publisher,
Map<KEY,VALUE> store,
org.reactivestreams.Publisher<? extends MapStream.Signal<KEY,VALUE>> listener,
BiFunction<VALUE,VALUE,VALUE> accumulator) |
static <KEY,VALUE> |
reduceByKey(org.reactivestreams.Publisher<Tuple2<KEY,VALUE>> publisher,
MapStream<KEY,VALUE> mapStream,
BiFunction<VALUE,VALUE,VALUE> accumulator) |
static <KEY,VALUE> |
reduceByKeyOn(org.reactivestreams.Publisher<Tuple2<KEY,VALUE>> publisher,
Map<KEY,VALUE> store,
org.reactivestreams.Publisher<? extends MapStream.Signal<KEY,VALUE>> listener,
BiFunction<VALUE,VALUE,VALUE> accumulator) |
static <KEY,VALUE> |
scanByKey(org.reactivestreams.Publisher<Tuple2<KEY,VALUE>> publisher,
BiFunction<VALUE,VALUE,VALUE> accumulator) |
static <KEY,VALUE> |
scanByKey(org.reactivestreams.Publisher<Tuple2<KEY,VALUE>> publisher,
Map<KEY,VALUE> store,
org.reactivestreams.Publisher<? extends MapStream.Signal<KEY,VALUE>> listener,
BiFunction<VALUE,VALUE,VALUE> accumulator) |
static <KEY,VALUE> |
scanByKey(org.reactivestreams.Publisher<Tuple2<KEY,VALUE>> publisher,
MapStream<KEY,VALUE> mapStream,
BiFunction<VALUE,VALUE,VALUE> accumulator) |
static <KEY,VALUE> |
scanByKeyOn(org.reactivestreams.Publisher<Tuple2<KEY,VALUE>> publisher,
Map<KEY,VALUE> store,
org.reactivestreams.Publisher<? extends MapStream.Signal<KEY,VALUE>> listener,
BiFunction<VALUE,VALUE,VALUE> accumulator) |
await, await, await, await, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, concat, concat, concat, concat, concat, concat, concat, concat, concat, create, createWith, createWith, createWith, defer, empty, fail, from, from, from, from, generate, join, join, join, join, join, join, join, join, join, just, just, just, just, just, just, just, just, merge, merge, merge, merge, merge, merge, merge, merge, merge, never, period, period, period, period, period, period, period, period, range, switchOnNext, switchOnNext, switchOnNext, switchOnNext, timer, timer, timer, timer, wrap, zip, zip, zip, zip, zip, zip, zip, zip, zip
public static <KEY,VALUE> Stream<Tuple2<KEY,VALUE>> reduceByKey(org.reactivestreams.Publisher<Tuple2<KEY,VALUE>> publisher, BiFunction<VALUE,VALUE,VALUE> accumulator)
KEY
- VALUE
- publisher
- accumulator
- public static <KEY,VALUE> Stream<Tuple2<KEY,VALUE>> reduceByKey(org.reactivestreams.Publisher<Tuple2<KEY,VALUE>> publisher, MapStream<KEY,VALUE> mapStream, BiFunction<VALUE,VALUE,VALUE> accumulator)
KEY
- VALUE
- publisher
- mapStream
- accumulator
- public static <KEY,VALUE> Stream<Tuple2<KEY,VALUE>> reduceByKey(org.reactivestreams.Publisher<Tuple2<KEY,VALUE>> publisher, Map<KEY,VALUE> store, org.reactivestreams.Publisher<? extends MapStream.Signal<KEY,VALUE>> listener, BiFunction<VALUE,VALUE,VALUE> accumulator)
KEY
- VALUE
- publisher
- store
- listener
- accumulator
- public static <KEY,VALUE> Stream<Tuple2<KEY,VALUE>> reduceByKeyOn(org.reactivestreams.Publisher<Tuple2<KEY,VALUE>> publisher, Map<KEY,VALUE> store, org.reactivestreams.Publisher<? extends MapStream.Signal<KEY,VALUE>> listener, BiFunction<VALUE,VALUE,VALUE> accumulator)
KEY
- VALUE
- publisher
- store
- listener
- accumulator
- public static <KEY,VALUE> Stream<Tuple2<KEY,VALUE>> scanByKey(org.reactivestreams.Publisher<Tuple2<KEY,VALUE>> publisher, BiFunction<VALUE,VALUE,VALUE> accumulator)
KEY
- VALUE
- publisher
- accumulator
- public static <KEY,VALUE> Stream<Tuple2<KEY,VALUE>> scanByKey(org.reactivestreams.Publisher<Tuple2<KEY,VALUE>> publisher, MapStream<KEY,VALUE> mapStream, BiFunction<VALUE,VALUE,VALUE> accumulator)
KEY
- VALUE
- publisher
- mapStream
- accumulator
- public static <KEY,VALUE> Stream<Tuple2<KEY,VALUE>> scanByKey(org.reactivestreams.Publisher<Tuple2<KEY,VALUE>> publisher, Map<KEY,VALUE> store, org.reactivestreams.Publisher<? extends MapStream.Signal<KEY,VALUE>> listener, BiFunction<VALUE,VALUE,VALUE> accumulator)
KEY
- VALUE
- publisher
- store
- listener
- accumulator
- public static <KEY,VALUE> Stream<Tuple2<KEY,VALUE>> scanByKeyOn(org.reactivestreams.Publisher<Tuple2<KEY,VALUE>> publisher, Map<KEY,VALUE> store, org.reactivestreams.Publisher<? extends MapStream.Signal<KEY,VALUE>> listener, BiFunction<VALUE,VALUE,VALUE> accumulator)
KEY
- VALUE
- publisher
- store
- listener
- accumulator
- Copyright © 2017. All rights reserved.