Package org.reactfx

Interface ProperObservable<O,T>

Type Parameters:
O - observer type accepted by this Observable
T - notification type produced by this Observable
All Superinterfaces:
Observable<O>
All Known Subinterfaces:
ProperEventStream<T>, ProperLiveList<E>, ProperVal<T>
All Known Implementing Classes:
AbstractReducibleEventStream, AccumulateBetweenStream, AccumulateUntilLaterStream, AccumulatingStream, AccumulativeEventStream, AnimatedVal, Await, AwaitLatest, ConnectableEventSource, DefaultEventStream, DistinctStream, DynamicallyMappedList, EmitBothOnEachStream, EmitOnEachStream, EmitOnStream, EventSource, EventStreamBase, FilterMapStream, FilterStream, FlatMapOptStream, FlatMapped, FlatMappedVal, FlatMappedVar, FlatMapStream, ForgetfulEventStream, HookStream, LatestNStream, ListRangeReduction, ListReduction, LiveArrayList, LiveListBase, MappedList, MappedStream, MappedToCompletionStageStream, MappedToTaskStream, MappedVal, MemoizationListImpl, MemoizationListImpl.MemoizedView, ObservableBase, OrElse, OrElseConst, PausableEventStream, RecursiveStream, ReducibleEventStream, RepeatOnStream, SimpleVar, StatefulStream, StateStream, SuccessionReducingStream, SuppressibleEventStream, SuspendableBase, SuspendableBoolean, SuspendableEventStreamBase, SuspendableListWrapper, SuspendableNo, SuspendableValWrapper, SuspendableVarWrapper, SuspendableYes, SuspendedWhenStream, SuspenderBase, SuspenderStreamImpl, ThenAccumulateForStream, ThreadBridge, ValAsList, ValBase, ValWrapper, VarWrapper
public interface ProperObservable<O,T> extends Observable<O>
An Observable that maintains a collection of registered observers and notifies them when a change occurs. This is unlike ProxyObservable, which registers observers with an underlying Observable, and unlike RigidObservable, which does not produce any notifications.

  • Method Details

    • notifyObservers

      void notifyObservers(T event)

    • defaultNotificationAccumulator

      NotificationAccumulator<O,T,?> defaultNotificationAccumulator()

    • defaultHashCode

      default int defaultHashCode()

    • defaultEquals

      default boolean defaultEquals(Object o)

    • defaultToString

      default String defaultToString()