public class WindowShiftWhenAction<T> extends Action<T,Stream<T>>
capacity, downstreamSubscription, NO_CAPACITY, RESERVED_SLOTS, upstreamSubscription
Constructor and Description |
---|
WindowShiftWhenAction(Environment environment,
Dispatcher dispatcher,
org.reactivestreams.Publisher<?> bucketOpenings,
Supplier<? extends org.reactivestreams.Publisher<?>> boundarySupplier) |
Modifier and Type | Method and Description |
---|---|
protected Broadcaster<T> |
createWindowStream(T first) |
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 WindowShiftWhenAction(Environment environment, Dispatcher dispatcher, org.reactivestreams.Publisher<?> bucketOpenings, Supplier<? extends org.reactivestreams.Publisher<?>> boundarySupplier)
protected void doOnSubscribe(org.reactivestreams.Subscription subscription)
doOnSubscribe
in class Action<T,Stream<T>>
protected void doComplete()
doComplete
in class Action<T,Stream<T>>
public final Environment getEnvironment()
Stream
Environment
.getEnvironment
in class Stream<Stream<T>>
Environment
public final Dispatcher getDispatcher()
Stream
getDispatcher
in class Stream<Stream<T>>
protected Broadcaster<T> createWindowStream(T first)
Copyright © 2017. All rights reserved.