Package org.reactfx
Class MappedToCompletionStageStream<T,U>
- java.lang.Object
-
- org.reactfx.ObservableBase<java.util.function.Consumer<? super T>,T>
-
- org.reactfx.EventStreamBase<U>
-
- org.reactfx.MappedStream<T,java.util.concurrent.CompletionStage<U>>
-
- org.reactfx.MappedToCompletionStageStream<T,U>
-
- All Implemented Interfaces:
CompletionStageStream<U>
,EventStream<java.util.concurrent.CompletionStage<U>>
,Observable<java.util.function.Consumer<? super java.util.concurrent.CompletionStage<U>>>
,ProperEventStream<java.util.concurrent.CompletionStage<U>>
,ProperObservable<java.util.function.Consumer<? super java.util.concurrent.CompletionStage<U>>,java.util.concurrent.CompletionStage<U>>
class MappedToCompletionStageStream<T,U> extends MappedStream<T,java.util.concurrent.CompletionStage<U>> implements CompletionStageStream<U>
-
-
Constructor Summary
Constructors Constructor Description MappedToCompletionStageStream(EventStream<T> input, java.util.function.Function<? super T,java.util.concurrent.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 Detail
-
MappedToCompletionStageStream
public MappedToCompletionStageStream(EventStream<T> input, java.util.function.Function<? super T,java.util.concurrent.CompletionStage<U>> f)
-
-