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

Constructors

Constructor	Description
MappedToCompletionStageStream(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)