griffon.javafx.collections

Interface ObservableStream<T>

public interface ObservableStream<T>

Since:

2.13.0

Author:

Andres Almiray

Method Summary

Modifier and Type	Method and Description
BooleanBinding	allMatch(ObservableValue<Predicate<? super T>> predicate)
BooleanBinding	allMatch(Predicate<? super T> predicate)
BooleanBinding	anyMatch(ObservableValue<Predicate<? super T>> predicate)
BooleanBinding	anyMatch(Predicate<? super T> predicate)
ObservableStream<T>	distinct()
ObservableStream<T>	filter(ObservableValue<Predicate<? super T>> predicate)
ObservableStream<T>	filter(Predicate<? super T> predicate)
ObjectBinding<T>	findAny()
ObjectBinding<T>	findAny(Supplier<T> supplier)
ObjectBinding<T>	findAny(T defaultValue)
ObjectBinding<T>	findFirst()
ObjectBinding<T>	findFirst(Supplier<T> supplier)
ObjectBinding<T>	findFirst(T defaultValue)
<R> ObservableStream<R>	flatMap(Function<? super T,? extends ObservableStream<? extends R>> mapper)
<R> ObservableStream<R>	flatMap(ObservableValue<Function<? super T,? extends ObservableStream<? extends R>>> mapper)
ObservableStream<T>	limit(long maxSize)
ObservableStream<T>	limit(ObservableLongValue maxSize)
<R> ObservableStream<R>	map(Function<? super T,? extends R> mapper)
<R> ObservableStream<R>	map(ObservableValue<Function<? super T,? extends R>> mapper)
ObjectBinding<T>	max(Comparator<? super T> comparator)
ObjectBinding<T>	max(ObservableValue<Comparator<? super T>> comparator)
ObjectBinding<T>	max(Supplier<T> supplier, Comparator<? super T> comparator)
ObjectBinding<T>	max(Supplier<T> supplier, ObservableValue<Comparator<? super T>> comparator)
ObjectBinding<T>	max(T defaultValue, Comparator<? super T> comparator)
ObjectBinding<T>	max(T defaultValue, ObservableValue<Comparator<? super T>> comparator)
ObjectBinding<T>	min(Comparator<? super T> comparator)
ObjectBinding<T>	min(ObservableValue<Comparator<? super T>> comparator)
ObjectBinding<T>	min(Supplier<T> supplier, Comparator<? super T> comparator)
ObjectBinding<T>	min(Supplier<T> supplier, ObservableValue<Comparator<? super T>> comparator)
ObjectBinding<T>	min(T defaultValue, Comparator<? super T> comparator)
ObjectBinding<T>	min(T defaultValue, ObservableValue<Comparator<? super T>> comparator)
BooleanBinding	noneMatch(ObservableValue<Predicate<? super T>> predicate)
BooleanBinding	noneMatch(Predicate<? super T> predicate)
ObjectBinding<T>	reduce(BinaryOperator<T> accumulator)
ObjectBinding<T>	reduce(ObservableValue<BinaryOperator<T>> accumulator)
<U> ObjectBinding<U>	reduce(ObservableValue<U> identity, ObservableValue<BiFunction<U,? super T,U>> accumulator, ObservableValue<BinaryOperator<U>> combiner)
ObjectBinding<T>	reduce(Supplier<T> supplier, BinaryOperator<T> accumulator)
ObjectBinding<T>	reduce(Supplier<T> supplier, ObservableValue<BinaryOperator<T>> accumulator)
ObjectBinding<T>	reduce(T defaultValue, BinaryOperator<T> accumulator)
ObjectBinding<T>	reduce(T defaultValue, ObservableValue<BinaryOperator<T>> accumulator)
<U> ObjectBinding<U>	reduce(U identity, BiFunction<U,? super T,U> accumulator, BinaryOperator<U> combiner)
ObservableStream<T>	skip(long n)
ObservableStream<T>	skip(ObservableLongValue n)
ObservableStream<T>	sorted()
ObservableStream<T>	sorted(Comparator<? super T> comparator)
ObservableStream<T>	sorted(ObservableValue<Comparator<? super T>> comparator)

Method Detail

limit

@Nonnull
ObservableStream<T> limit(long maxSize)

limit

@Nonnull
ObservableStream<T> limit(@Nonnull
                                   ObservableLongValue maxSize)

skip

@Nonnull
ObservableStream<T> skip(long n)

skip

@Nonnull
ObservableStream<T> skip(@Nonnull
                                  ObservableLongValue n)

distinct

@Nonnull
ObservableStream<T> distinct()

sorted

@Nonnull
ObservableStream<T> sorted()

sorted

@Nonnull
ObservableStream<T> sorted(@Nonnull
                                    Comparator<? super T> comparator)

sorted

@Nonnull
ObservableStream<T> sorted(@Nonnull
                                    ObservableValue<Comparator<? super T>> comparator)

filter

@Nonnull
ObservableStream<T> filter(@Nonnull
                                    Predicate<? super T> predicate)

map

@Nonnull
<R> ObservableStream<R> map(@Nonnull
                                     Function<? super T,? extends R> mapper)

flatMap

@Nonnull
<R> ObservableStream<R> flatMap(@Nonnull
                                         Function<? super T,? extends ObservableStream<? extends R>> mapper)

filter

@Nonnull
ObservableStream<T> filter(@Nonnull
                                    ObservableValue<Predicate<? super T>> predicate)

map

@Nonnull
<R> ObservableStream<R> map(@Nonnull
                                     ObservableValue<Function<? super T,? extends R>> mapper)

flatMap

@Nonnull
<R> ObservableStream<R> flatMap(@Nonnull
                                         ObservableValue<Function<? super T,? extends ObservableStream<? extends R>>> mapper)

reduce

@Nonnull
ObjectBinding<T> reduce(@Nonnull
                                 BinaryOperator<T> accumulator)

reduce

@Nonnull
ObjectBinding<T> reduce(@Nullable
                                 T defaultValue,
                                 @Nonnull
                                 BinaryOperator<T> accumulator)

reduce

@Nonnull
ObjectBinding<T> reduce(@Nonnull
                                 Supplier<T> supplier,
                                 @Nonnull
                                 BinaryOperator<T> accumulator)

reduce

@Nonnull
<U> ObjectBinding<U> reduce(@Nullable
                                     U identity,
                                     @Nonnull
                                     BiFunction<U,? super T,U> accumulator,
                                     @Nonnull
                                     BinaryOperator<U> combiner)

reduce

@Nonnull
ObjectBinding<T> reduce(@Nonnull
                                 ObservableValue<BinaryOperator<T>> accumulator)

reduce

@Nonnull
ObjectBinding<T> reduce(@Nullable
                                 T defaultValue,
                                 @Nonnull
                                 ObservableValue<BinaryOperator<T>> accumulator)

reduce

@Nonnull
ObjectBinding<T> reduce(@Nonnull
                                 Supplier<T> supplier,
                                 @Nonnull
                                 ObservableValue<BinaryOperator<T>> accumulator)

reduce

@Nonnull
<U> ObjectBinding<U> reduce(@Nonnull
                                     ObservableValue<U> identity,
                                     @Nonnull
                                     ObservableValue<BiFunction<U,? super T,U>> accumulator,
                                     @Nonnull
                                     ObservableValue<BinaryOperator<U>> combiner)

min

@Nonnull
ObjectBinding<T> min(@Nonnull
                              Comparator<? super T> comparator)

max

@Nonnull
ObjectBinding<T> max(@Nonnull
                              Comparator<? super T> comparator)

min

@Nonnull
ObjectBinding<T> min(@Nullable
                              T defaultValue,
                              @Nonnull
                              Comparator<? super T> comparator)

max

@Nonnull
ObjectBinding<T> max(@Nullable
                              T defaultValue,
                              @Nonnull
                              Comparator<? super T> comparator)

min

@Nonnull
ObjectBinding<T> min(@Nonnull
                              Supplier<T> supplier,
                              @Nonnull
                              Comparator<? super T> comparator)

max

@Nonnull
ObjectBinding<T> max(@Nonnull
                              Supplier<T> supplier,
                              @Nonnull
                              Comparator<? super T> comparator)

anyMatch

@Nonnull
BooleanBinding anyMatch(@Nonnull
                                 Predicate<? super T> predicate)

allMatch

@Nonnull
BooleanBinding allMatch(@Nonnull
                                 Predicate<? super T> predicate)

noneMatch

@Nonnull
BooleanBinding noneMatch(@Nonnull
                                  Predicate<? super T> predicate)

min

@Nonnull
ObjectBinding<T> min(@Nonnull
                              ObservableValue<Comparator<? super T>> comparator)

max

@Nonnull
ObjectBinding<T> max(@Nonnull
                              ObservableValue<Comparator<? super T>> comparator)

min

@Nonnull
ObjectBinding<T> min(@Nullable
                              T defaultValue,
                              @Nonnull
                              ObservableValue<Comparator<? super T>> comparator)

max

@Nonnull
ObjectBinding<T> max(@Nullable
                              T defaultValue,
                              @Nonnull
                              ObservableValue<Comparator<? super T>> comparator)

min

@Nonnull
ObjectBinding<T> min(@Nonnull
                              Supplier<T> supplier,
                              @Nonnull
                              ObservableValue<Comparator<? super T>> comparator)

max

@Nonnull
ObjectBinding<T> max(@Nonnull
                              Supplier<T> supplier,
                              @Nonnull
                              ObservableValue<Comparator<? super T>> comparator)

anyMatch

@Nonnull
BooleanBinding anyMatch(@Nonnull
                                 ObservableValue<Predicate<? super T>> predicate)

allMatch

@Nonnull
BooleanBinding allMatch(@Nonnull
                                 ObservableValue<Predicate<? super T>> predicate)

noneMatch

@Nonnull
BooleanBinding noneMatch(@Nonnull
                                  ObservableValue<Predicate<? super T>> predicate)

findFirst

@Nonnull
ObjectBinding<T> findFirst()

findFirst

@Nonnull
ObjectBinding<T> findFirst(@Nullable
                                    T defaultValue)

findFirst

@Nonnull
ObjectBinding<T> findFirst(@Nonnull
                                    Supplier<T> supplier)

findAny

@Nonnull
ObjectBinding<T> findAny()

findAny

@Nonnull
ObjectBinding<T> findAny(@Nullable
                                  T defaultValue)

findAny

@Nonnull
ObjectBinding<T> findAny(@Nonnull
                                  Supplier<T> supplier)