Top Description Fields Constructors Methods
org.reactfx

pack-priv Class FlatMapStream<T, U>

Additional top-level class in compilation unit: FlatMapOptStream.

extends EventStreamBase<U>
Class Inheritance
Imports
java.util.Optional, java.util.function.Function
See EventStream#flatMap(Function)

Field Summary

Modifier and TypeField and Description
private Subscription
mappedSubscription

private final Function<? super T, ? extends EventStream<U>>
mapper

private final EventStream<T>
source

Constructor Summary

AccessConstructor and Description
public
FlatMapStream(EventStream<T> src, Function<? super T, ? extends EventStream<U>> f)

Method Summary

Modifier and TypeMethod and Description
protected Subscription
observeInputs()

Implements abstract org.reactfx.ObservableBase.observeInputs.

Starts observing this observable's input(s), if any.

Field Detail

mappedSubscriptionback to summary
private Subscription mappedSubscription
mapperback to summary
private final Function<? super T, ? extends EventStream<U>> mapper
sourceback to summary
private final EventStream<T> source

Constructor Detail

FlatMapStreamback to summary
public FlatMapStream(EventStream<T> src, Function<? super T, ? extends EventStream<U>> f)

Method Detail

observeInputsback to summary
protected Subscription observeInputs()

Implements abstract org.reactfx.ObservableBase.observeInputs.

Doc from org.reactfx.ObservableBase.observeInputs.

Starts observing this observable's input(s), if any. This method is called when the number of observers goes from 0 to 1. This method is called before newObserver(Object) is called for the first observer.

Annotations
@Override