Package org.reactfx
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
ConstructorsConstructorDescriptionMappedToCompletionStageStream
(EventStream<T> input, Function<? super T, CompletionStage<U>> f) -
Method Summary
Methods inherited from class org.reactfx.MappedStream
observeInputs
Methods inherited from class org.reactfx.ObservableBase
addObserver, enqueueNotifications, equals, forEachObserver, getObserverCount, hashCode, isObservingInputs, newObserver, notifyObservers, notifyObservers, observe, removeObserver, toString
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
Methods inherited from interface org.reactfx.CompletionStageStream
await, await, awaitLatest, awaitLatest, awaitLatest, awaitLatest
Methods inherited from interface org.reactfx.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 org.reactfx.Observable
addObserver, observe, removeObserver
Methods inherited from interface org.reactfx.ProperEventStream
defaultNotificationAccumulator, emit
Methods inherited from interface org.reactfx.ProperObservable
defaultEquals, defaultHashCode, defaultToString, notifyObservers
-
Constructor Details
-
MappedToCompletionStageStream
public MappedToCompletionStageStream(EventStream<T> input, Function<? super T, CompletionStage<U>> f)
-