Package org.reactfx

Class EmitBothOnEachStream<A,I>

java.lang.Object
org.reactfx.ObservableBase<Consumer<? super Tuple2<A,I>>,Tuple2<A,I>>
org.reactfx.EventStreamBase<Tuple2<A,I>>
org.reactfx.EmitBothOnEachStream<A,I>
All Implemented Interfaces:
EventStream<Tuple2<A,I>>, Observable<Consumer<? super Tuple2<A,I>>>, ProperEventStream<Tuple2<A,I>>, ProperObservable<Consumer<? super Tuple2<A,I>>,Tuple2<A,I>>

class EmitBothOnEachStream<A,I> extends EventStreamBase<Tuple2<A,I>>
  • Field Details

    • source

      private final EventStream<A> source
    • impulse

      private final EventStream<I> impulse
    • hasValue

      private boolean hasValue
    • a

      private A a
  • Constructor Details

  • Method Details

    • 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<Consumer<? super Tuple2<A,I>>,Tuple2<A,I>>
      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.