reactor.rx.stream

Class LiftStream<O,V>

java.lang.Object

reactor.rx.Stream<V>

reactor.rx.stream.LiftStream<O,V>

All Implemented Interfaces:

org.reactivestreams.Publisher<V>, NonBlocking

public class LiftStream<O,V>
extends Stream<V>

A Stream wrapper that defers a parent stream subscription to the child action subscribe() call.

Since:

2.0

Author:

Stephane Maldini

Constructor Summary

Constructors

Constructor and Description
LiftStream(Stream<O> thiz, Supplier<? extends Action<O,V>> action)

Method Summary

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()

Methods inherited from class reactor.rx.Stream

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

LiftStream

public LiftStream(Stream<O> thiz,
                  Supplier<? extends Action<O,V>> action)

Method Detail

onLift

public final Action<O,V> onLift()

combine

public final <E> CompositeAction<E,V> combine()

Description copied from class: Stream

Combine the most ancient upstream action to act as the 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.

Overrides:

combine in class Stream<V>

Type Parameters:

E - the type of the most ancien action input.

Returns:

new Combined Action

getCapacity

public long getCapacity()

Description copied from interface: NonBlocking

Return defined element capacity, used to drive new Subscription request needs. This is the maximum in-flight data allowed to transit to this elements.

Specified by:

getCapacity in interface NonBlocking

Overrides:

getCapacity in class Stream<V>

Returns:

long capacity

getDispatcher

public Dispatcher getDispatcher()

Description copied from class: Stream

Get the dispatcher used to execute signals on this Stream instance.

Overrides:

getDispatcher in class Stream<V>

Returns:

assigned dispatcher

getEnvironment

public Environment getEnvironment()

Description copied from class: Stream

Get the assigned Environment.

Overrides:

getEnvironment in class Stream<V>

Returns:

current Environment

subscribe

public final void subscribe(org.reactivestreams.Subscriber<? super V> s)

toString

public final String toString()

Overrides:

toString in class Stream<V>