ObservableStream<T> |
ObservableStream.distinct() |
ObservableStream<T> |
ObservableStream.filter(ObservableValue<Predicate<? super T>> predicate) |
ObservableStream<T> |
ObservableStream.filter(Predicate<? super T> predicate) |
<R> ObservableStream<R> |
ObservableStream.flatMap(Function<? super T,? extends ObservableStream<? extends R>> mapper) |
<R> ObservableStream<R> |
ObservableStream.flatMap(ObservableValue<Function<? super T,? extends ObservableStream<? extends R>>> mapper) |
ObservableStream<T> |
ObservableStream.limit(long maxSize) |
ObservableStream<T> |
ObservableStream.limit(ObservableLongValue maxSize) |
<R> ObservableStream<R> |
ObservableStream.map(Function<? super T,? extends R> mapper) |
<R> ObservableStream<R> |
ObservableStream.map(ObservableValue<Function<? super T,? extends R>> mapper) |
static <E> ObservableStream<E> |
GriffonFXCollections.observableStream(ObservableList<E> list) |
static <K,V> ObservableStream<V> |
GriffonFXCollections.observableStream(ObservableMap<K,V> map) |
static <E> ObservableStream<E> |
GriffonFXCollections.observableStream(ObservableSet<E> set) |
ObservableStream<T> |
ObservableStream.skip(long n) |
ObservableStream<T> |
ObservableStream.skip(ObservableLongValue n) |
ObservableStream<T> |
ObservableStream.sorted() |
ObservableStream<T> |
ObservableStream.sorted(Comparator<? super T> comparator) |
ObservableStream<T> |
ObservableStream.sorted(ObservableValue<Comparator<? super T>> comparator) |