Package org.reactfx

Class LatestNStream<T>

    • Field Detail

      • n

        private final int n
      • first

        private java.util.List<T> first
      • second

        private java.util.List<T> second
      • concatView

        private java.util.List<T> concatView
    • Constructor Detail

      • LatestNStream

        public LatestNStream​(EventStream<T> source,
                             int n)
    • Method Detail

      • observeInputs

        protected Subscription observeInputs()
        Description copied from class: ObservableBase
        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 ObservableBase.newObserver(Object) is called for the first observer.
        Specified by:
        observeInputs in class ObservableBase<java.util.function.Consumer<? super java.util.List<T>>,​java.util.List<T>>
        Returns:
        subscription used to stop observing inputs. The subscription is unsubscribed (i.e. input observation stops) when the number of observers goes down to 0.
      • onEvent

        private void onEvent​(T event)