pack-priv Class DistinctStream<T>

Class Inheritance

extends EventStreamBase<T>

Imports

java.util.Objects

See EventStream#distinct()

Field Summary

Modifier and Type	Field and Description
private final EventStream<T>	input
pack-priv static final Object	NONE
private Object	previous

Constructor Summary

Access	Constructor and Description
public	DistinctStream(EventStream<T> input)

Method Summary

Modifier and Type	Method and Description
protected Subscription	observeInputs() Implements abstract org.reactfx.ObservableBase.observeInputs. Starts observing this observable's input(s), if any.

Field Detail

input	back to summary
private final EventStream<T> input

NONE	back to summary
pack-priv static final Object NONE

previous	back to summary
private Object previous

Constructor Detail

DistinctStream	back to summary
public DistinctStream(EventStream<T> input)

Method Detail

observeInputs back to summary

observeInputs	back 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

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