Package org.reactfx

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 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 Details

MappedToTaskStream

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