Class MappedToTaskStream<T,U>

java.lang.Object

org.reactfx.ObservableBase<Consumer<? super javafx.concurrent.Task<U>>, javafx.concurrent.Task<U>>

org.reactfx.EventStreamBase<javafx.concurrent.Task<U>>

org.reactfx.MappedStream<T, javafx.concurrent.Task<U>>

org.reactfx.MappedToTaskStream<T,U>

All Implemented Interfaces:

EventStream<javafx.concurrent.Task<U>>, Observable<Consumer<? super javafx.concurrent.Task<U>>>, ProperEventStream<javafx.concurrent.Task<U>>, ProperObservable<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, Function<? super T, javafx.concurrent.Task<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 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

Methods inherited from interface TaskStream

await, awaitLatest, awaitLatest

Constructor Details

MappedToTaskStream

public MappedToTaskStream(EventStream<T> input,
 Function<? super T, javafx.concurrent.Task<U>> f)