public class WindowWhenAction<T> extends Action<T,Stream<T>>
capacity, downstreamSubscription, NO_CAPACITY, RESERVED_SLOTS, upstreamSubscription
Constructor and Description |
---|
WindowWhenAction(Environment environment,
Dispatcher dispatcher,
Supplier<? extends org.reactivestreams.Publisher<?>> boundarySupplier) |
Modifier and Type | Method and Description |
---|---|
protected Stream<T> |
createWindowStream(T first) |
Broadcaster<T> |
currentWindow() |
protected void |
doComplete() |
protected void |
doError(Throwable ev) |
protected void |
doNext(T value) |
protected void |
doOnSubscribe(org.reactivestreams.Subscription subscription) |
Dispatcher |
getDispatcher()
Get the dispatcher used to execute signals on this Stream instance.
|
Environment |
getEnvironment()
Get the assigned
Environment . |
accept, addSubscription, broadcastComplete, broadcastError, broadcastNext, cancel, cancelSubscription, capacity, checkRequest, combine, control, createSubscription, createSubscription, createTrackingSubscription, debug, doShutdown, doStart, downstreamSubscription, evaluateCapacity, findOldestUpstream, getCapacity, getSubscription, isPublishing, onComplete, onError, onNext, onOverflowBuffer, onSubscribe, recycle, requestAll, requestMore, 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 WindowWhenAction(Environment environment, Dispatcher dispatcher, Supplier<? extends org.reactivestreams.Publisher<?>> boundarySupplier)
protected void doOnSubscribe(org.reactivestreams.Subscription subscription)
doOnSubscribe
in class Action<T,Stream<T>>
public Broadcaster<T> currentWindow()
protected void doComplete()
doComplete
in class Action<T,Stream<T>>
public final Environment getEnvironment()
Stream
Environment
.getEnvironment
in class Stream<Stream<T>>
Environment
public Dispatcher getDispatcher()
Stream
getDispatcher
in class Stream<Stream<T>>
Copyright © 2016. All rights reserved.