public class LiftStream<O,V> extends Stream<V>
Constructor and Description |
---|
LiftStream(Stream<O> thiz,
Supplier<? extends Action<O,V>> action) |
Modifier and Type | Method and Description |
---|---|
<E> CompositeAction<E,V> |
combine()
Combine the most ancient upstream action to act as the
Subscriber input component and
the current stream to act as the Publisher . |
long |
getCapacity()
Return defined element capacity, used to drive new
Subscription
request needs. |
Dispatcher |
getDispatcher()
Get the dispatcher used to execute signals on this Stream instance.
|
Environment |
getEnvironment()
Get the assigned
Environment . |
Action<O,V> |
onLift() |
void |
subscribe(org.reactivestreams.Subscriber<? super V> s) |
String |
toString() |
adaptiveConsume, adaptiveConsumeOn, after, batchConsume, batchConsumeOn, broadcast, broadcastOn, broadcastTo, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, cache, cancelSubscription, capacity, cast, concatMap, concatWith, consume, consume, consume, consume, consume, consumeLater, consumeOn, consumeOn, consumeOn, count, count, decode, defaultIfEmpty, dematerialize, dispatchOn, dispatchOn, dispatchOn, distinct, distinct, distinctUntilChanged, distinctUntilChanged, downstreamSubscription, 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, 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 final <E> CompositeAction<E,V> combine()
Stream
Subscriber
input component and
the current stream to act as the Publisher
.
Useful to share and ship a full stream whilst hiding the staging actions in the middle.
Default behavior, e.g. a single stream, will raise an IllegalStateException
as there would not
be any Subscriber (Input) side to combine. Action.combine()
is the usual reference
implementation used.
public long getCapacity()
NonBlocking
Subscription
request needs. This is the maximum in-flight data allowed to transit to this elements.getCapacity
in interface NonBlocking
getCapacity
in class Stream<V>
public Dispatcher getDispatcher()
Stream
getDispatcher
in class Stream<V>
public Environment getEnvironment()
Stream
Environment
.getEnvironment
in class Stream<V>
Environment
public final void subscribe(org.reactivestreams.Subscriber<? super V> s)
Copyright © 2016. All rights reserved.