Package org.reactfx
Class MappedToTaskStream<T,U>
- java.lang.Object
-
- org.reactfx.ObservableBase<java.util.function.Consumer<? super T>,T>
-
- org.reactfx.EventStreamBase<U>
-
- org.reactfx.MappedStream<T,javafx.concurrent.Task<U>>
-
- org.reactfx.MappedToTaskStream<T,U>
-
- All Implemented Interfaces:
EventStream<javafx.concurrent.Task<U>>
,Observable<java.util.function.Consumer<? super javafx.concurrent.Task<U>>>
,ProperEventStream<javafx.concurrent.Task<U>>
,ProperObservable<java.util.function.Consumer<? super javafx.concurrent.Task<U>>,javafx.concurrent.Task<U>>
,TaskStream<U>
class MappedToTaskStream<T,U> extends MappedStream<T,javafx.concurrent.Task<U>> implements TaskStream<U>
-
-
Constructor Summary
Constructors Constructor Description MappedToTaskStream(EventStream<T> input, java.util.function.Function<? super T,javafx.concurrent.Task<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.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
-
Methods inherited from interface org.reactfx.TaskStream
await, awaitLatest, awaitLatest
-
-
-
-
Constructor Detail
-
MappedToTaskStream
public MappedToTaskStream(EventStream<T> input, java.util.function.Function<? super T,javafx.concurrent.Task<U>> f)
-
-