public class WindowAction<T> extends BatchAction<T,Stream<T>>
batchSize, dispatcher, first, flush, flushConsumer, index, next, timer, timespan, unit
capacity, downstreamSubscription, NO_CAPACITY, RESERVED_SLOTS, upstreamSubscription
Constructor and Description |
---|
WindowAction(Environment environment,
Dispatcher dispatcher,
int backlog) |
WindowAction(Environment environment,
Dispatcher dispatcher,
int backlog,
long timespan,
TimeUnit unit,
Timer timer) |
Modifier and Type | Method and Description |
---|---|
protected Stream<T> |
createWindowStream() |
ReactiveSubscription<T> |
currentWindow() |
protected void |
doComplete() |
protected void |
doError(Throwable ev) |
protected void |
firstCallback(T event) |
protected void |
flushCallback(T event) |
Environment |
getEnvironment()
Get the assigned
Environment . |
protected void |
nextCallback(T event) |
createTrackingSubscription, doNext, getDispatcher, isReactivePull, toString
accept, addSubscription, broadcastComplete, broadcastError, broadcastNext, cancel, cancelSubscription, capacity, checkRequest, combine, control, createSubscription, createSubscription, debug, doOnSubscribe, doShutdown, doStart, downstreamSubscription, evaluateCapacity, findOldestUpstream, getCapacity, getSubscription, isPublishing, onComplete, onError, onNext, onOverflowBuffer, onSubscribe, recycle, requestAll, requestMore, requestUpstream, subscribe, subscribeWithSubscription, toBroadcastCompleteConsumer, toBroadcastErrorConsumer, toBroadcastNextConsumer
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, 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 WindowAction(Environment environment, Dispatcher dispatcher, int backlog)
public WindowAction(Environment environment, Dispatcher dispatcher, int backlog, long timespan, TimeUnit unit, Timer timer)
public ReactiveSubscription<T> currentWindow()
protected void doComplete()
doComplete
in class BatchAction<T,Stream<T>>
protected void firstCallback(T event)
firstCallback
in class BatchAction<T,Stream<T>>
protected void nextCallback(T event)
nextCallback
in class BatchAction<T,Stream<T>>
protected void flushCallback(T event)
flushCallback
in class BatchAction<T,Stream<T>>
public final Environment getEnvironment()
Stream
Environment
.getEnvironment
in class Stream<Stream<T>>
Environment
Copyright © 2017. All rights reserved.