Package org.reactfx

Class 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 Detail

      • MappedToCompletionStageStream

        public MappedToCompletionStageStream​(EventStream<T> input,
                                             java.util.function.Function<? super T,​java.util.concurrent.CompletionStage<U>> f)