public class ScanByKeyAction<K,V> extends Action<Tuple2<K,V>,Tuple2<K,V>>
Modifier and Type | Field and Description |
---|---|
protected BiFunction<? super V,? super V,V> |
fn |
protected org.reactivestreams.Publisher<? extends MapStream.Signal<K,V>> |
mapListener |
protected Map<K,V> |
store |
capacity, downstreamSubscription, NO_CAPACITY, RESERVED_SLOTS, upstreamSubscription
Constructor and Description |
---|
ScanByKeyAction(BiFunction<? super V,? super V,V> fn,
Map<K,V> store,
org.reactivestreams.Publisher<? extends MapStream.Signal<K,V>> mapListener) |
ScanByKeyAction(BiFunction<? super V,? super V,V> fn,
MapStream<K,V> mapStream) |
Modifier and Type | Method and Description |
---|---|
protected void |
doNext(PushSubscription<Tuple2<K,V>> subscriber,
Tuple2<K,V> ev) |
protected void |
doNext(Tuple2<K,V> ev) |
void |
subscribe(org.reactivestreams.Subscriber<? super Tuple2<K,V>> subscriber)
--------------------------------------------------------------------------------------------------------
ACTION SIGNAL HANDLING
--------------------------------------------------------------------------------------------------------
|
accept, addSubscription, broadcastComplete, broadcastError, broadcastNext, cancel, cancelSubscription, capacity, checkRequest, combine, control, createSubscription, createSubscription, createTrackingSubscription, debug, doComplete, doError, doOnSubscribe, doShutdown, doStart, downstreamSubscription, evaluateCapacity, findOldestUpstream, getCapacity, getSubscription, isPublishing, onComplete, onError, onNext, onOverflowBuffer, onSubscribe, recycle, requestAll, requestMore, requestUpstream, subscribeWithSubscription, toBroadcastCompleteConsumer, toBroadcastErrorConsumer, toBroadcastNextConsumer, toString
adaptiveConsume, adaptiveConsumeOn, after, batchConsume, batchConsumeOn, broadcast, broadcastOn, broadcastTo, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, cache, cast, concatMap, concatWith, consume, consume, consume, consume, consume, consumeLater, consumeOn, consumeOn, consumeOn, count, count, decode, defaultIfEmpty, dematerialize, dispatchOn, dispatchOn, dispatchOn, distinct, distinct, distinctUntilChanged, distinctUntilChanged, elapsed, elementAt, elementAtOrDefault, encode, env, exists, fanIn, filter, filter, finallyDo, flatMap, getDispatcher, getEnvironment, getTimer, groupBy, ignoreError, ignoreError, isReactivePull, join, joinWith, keepAlive, last, lift, log, log, map, materialize, merge, mergeWith, nest, next, observe, observeCancel, observeComplete, observeError, observeStart, observeSubscribe, onErrorResumeNext, onErrorResumeNext, onErrorReturn, onErrorReturn, onOverflowBuffer, onOverflowDrop, partition, partition, process, recover, reduce, reduce, repeat, repeat, repeatWhen, requestWhen, retry, retry, retry, retry, retryWhen, sample, sample, sample, sample, sample, sample, sampleFirst, sampleFirst, sampleFirst, sampleFirst, sampleFirst, sampleFirst, scan, scan, skip, skip, skip, skipWhile, skipWhile, sort, sort, sort, sort, split, split, startWith, startWith, startWith, subscribe, subscribeOn, subscribeOn, subscribeOn, switchMap, take, take, take, takeWhile, tap, throttle, throttle, timeout, timeout, timeout, timeout, timestamp, toBlockingQueue, toBlockingQueue, toList, toList, unbounded, when, window, window, window, window, window, window, window, window, window, window, window, zip, zipWith, zipWith
protected final BiFunction<? super V,? super V,V> fn
protected final org.reactivestreams.Publisher<? extends MapStream.Signal<K,V>> mapListener
public ScanByKeyAction(BiFunction<? super V,? super V,V> fn, MapStream<K,V> mapStream)
public ScanByKeyAction(BiFunction<? super V,? super V,V> fn, Map<K,V> store, org.reactivestreams.Publisher<? extends MapStream.Signal<K,V>> mapListener)
public void subscribe(org.reactivestreams.Subscriber<? super Tuple2<K,V>> subscriber)
Action
Copyright © 2017. All rights reserved.