Top Fields Constructors Methods
org.reactfx

pack-priv Class FilterMapStream<T, U>

extends EventStreamBase<U>
Class Inheritance
Imports
java.util.function.Function, .Predicate

Field Summary

Modifier and TypeField and Description
private final Function<? super T, ? extends U>
f

private final Predicate<? super T>
predicate

private final EventStream<T>
source

Constructor Summary

AccessConstructor and Description
public
FilterMapStream(EventStream<T> source, Predicate<? super T> predicate, Function<? super T, ? extends 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

fback to summary
private final Function<? super T, ? extends U> f
predicateback to summary
private final Predicate<? super T> predicate
sourceback to summary
private final EventStream<T> source

Constructor Detail

FilterMapStreamback to summary
public FilterMapStream(EventStream<T> source, Predicate<? super T> predicate, Function<? super T, ? extends 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