Top Description Fields Constructors Methods
org.reactfx

pack-priv Class EmitBothOnEachStream<A, I>

extends EventStreamBase<Tuple2<A, I>>
Class Inheritance
Static Imports
org.reactfx.util.Tuples.*
EventStream#emitBothOnEach(EventStream)

Field Summary

Modifier and TypeField and Description
private A
a

private boolean
hasValue

private final EventStream<I>
impulse

private final EventStream<A>
source

Constructor Summary

AccessConstructor and Description
public
EmitBothOnEachStream(EventStream<A> source, EventStream<I> impulse)

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

aback to summary
private A a
hasValueback to summary
private boolean hasValue
impulseback to summary
private final EventStream<I> impulse
sourceback to summary
private final EventStream<A> source

Constructor Detail

EmitBothOnEachStreamback to summary
public EmitBothOnEachStream(EventStream<A> source, EventStream<I> impulse)

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