T
- K
- public class GroupByAction<T,K> extends Action<T,GroupedStream<K,T>>
capacity, downstreamSubscription, NO_CAPACITY, RESERVED_SLOTS, upstreamSubscription
Constructor and Description |
---|
GroupByAction(Environment environment,
Function<? super T,? extends K> fn,
Dispatcher dispatcher) |
Modifier and Type | Method and Description |
---|---|
protected void |
doComplete() |
protected void |
doNext(T value) |
Dispatcher |
getDispatcher()
Get the dispatcher used to execute signals on this Stream instance.
|
Environment |
getEnvironment()
Get the assigned
Environment . |
Map<K,ReactiveSubscription<T>> |
groupByMap() |
void |
requestMore(long n)
Request the next n elements from the source
|
accept, addSubscription, broadcastComplete, broadcastError, broadcastNext, cancel, cancelSubscription, capacity, checkRequest, combine, control, createSubscription, createSubscription, createTrackingSubscription, debug, doError, doOnSubscribe, doShutdown, doStart, downstreamSubscription, evaluateCapacity, findOldestUpstream, getCapacity, getSubscription, isPublishing, onComplete, onError, onNext, onOverflowBuffer, onSubscribe, recycle, requestAll, requestUpstream, subscribe, 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, 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
public GroupByAction(Environment environment, Function<? super T,? extends K> fn, Dispatcher dispatcher)
public Map<K,ReactiveSubscription<T>> groupByMap()
protected void doComplete()
doComplete
in class Action<T,GroupedStream<K,T>>
public void requestMore(long n)
Control
requestMore
in interface Control
requestMore
in class Action<T,GroupedStream<K,T>>
n
- the number of elements to requestpublic final Dispatcher getDispatcher()
Stream
getDispatcher
in class Stream<GroupedStream<K,T>>
public final Environment getEnvironment()
Stream
Environment
.getEnvironment
in class Stream<GroupedStream<K,T>>
Environment
Copyright © 2017. All rights reserved.