Class MappedToCompletionStageStream<T,U>

java.lang.Object

org.reactfx.ObservableBase<Consumer<? super CompletionStage<U>>, CompletionStage<U>>

org.reactfx.EventStreamBase<CompletionStage<U>>

org.reactfx.MappedStream<T, CompletionStage<U>>

org.reactfx.MappedToCompletionStageStream<T,U>

All Implemented Interfaces:

CompletionStageStream<U>, EventStream<CompletionStage<U>>, Observable<Consumer<? super CompletionStage<U>>>, ProperEventStream<CompletionStage<U>>, ProperObservable<Consumer<? super CompletionStage<U>>, CompletionStage<U>>

class MappedToCompletionStageStream<T,U>
extends MappedStream<T, CompletionStage<U>>
implements CompletionStageStream<U>

Constructor Summary

Constructors

Constructor	Description
MappedToCompletionStageStream(EventStream<T> input, Function<? super T, CompletionStage<U>> f)

Method Summary

Methods inherited from class MappedStream

observeInputs

Methods inherited from class ObservableBase

addObserver, enqueueNotifications, equals, forEachObserver, getObserverCount, hashCode, isObservingInputs, newObserver, notifyObservers, notifyObservers, observe, removeObserver, toString

Methods inherited from class Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface CompletionStageStream

await, await, awaitLatest, awaitLatest, awaitLatest, awaitLatest

Methods inherited from interface EventStream

accumulate, accumulate, accumulate, accumulateBetween, accumulateBetween, accumulateUntilLater, accumulateUntilLater, accumulateUntilLater, accumulateUntilLater, accumulateWhen, accumulateWhen, accumulative, accumulative, cast, conditionOn, conditionOnShowing, distinct, emitBothOnEach, emitOn, emitOnEach, feedTo, feedTo, filter, filter, filterMap, filterMap, flatMap, forgetful, fork, guardedBy, hook, latestN, map, mapToCompletionStage, mapToTask, onRecurseAccumulate, onRecurseAccumulate, onRecurseQueue, onRecurseReduce, onRecurseRetainLatest, or, pausable, pauseWhen, pin, queueBetween, queueUntilLater, queueUntilLater, reduceBetween, reduceSuccessions, reduceSuccessions, reduceSuccessions, reduceSuccessions, reduceSuccessions, reduceSuccessions, reduceUntilLater, reduceUntilLater, reduceWhen, reducible, repeatOn, retainLatestBetween, retainLatestUntilLater, retainLatestUntilLater, retainLatestWhen, splitBy, subscribe, subscribeFor, subscribeForOne, successionEnds, successionEnds, supply, supply, supplyCompletionStage, supplyTask, suppressible, suppressWhen, suspenderOf, thenAccumulateFor, thenAccumulateFor, thenAccumulateFor, thenAccumulateFor, thenIgnoreFor, thenIgnoreFor, thenReduceFor, thenReduceFor, thenRetainLatestFor, thenRetainLatestFor, threadBridge, threadBridgeFromFx, threadBridgeToFx, toBinding, withDefaultEvent

Methods inherited from interface Observable

addObserver, observe, removeObserver

Methods inherited from interface ProperEventStream

defaultNotificationAccumulator, emit

Methods inherited from interface ProperObservable

defaultEquals, defaultHashCode, defaultToString, notifyObservers

Constructor Details

MappedToCompletionStageStream

public MappedToCompletionStageStream(EventStream<T> input,
 Function<? super T, CompletionStage<U>> f)