Hierarchy For All Packages

Package Hierarchies:

• hu.akarnokd.reactive4java.base,
• hu.akarnokd.reactive4java.interactive,
• hu.akarnokd.reactive4java.query,
• hu.akarnokd.reactive4java.reactive,
• hu.akarnokd.reactive4java.scheduler,
• hu.akarnokd.reactive4java.swing,
• hu.akarnokd.reactive4java.util

Class Hierarchy

• java.lang.Object
  • hu.akarnokd.reactive4java.util.Actions
  • hu.akarnokd.reactive4java.reactive.AddTimeInterval<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Aggregate
  • hu.akarnokd.reactive4java.reactive.Aggregate.Projected<V,T,U> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Aggregate.Scan<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Aggregate.ScanSeeded<U,T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Aggregate.Seeded<U,T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Aggregate.SeededIndexedProjected<V,T,U> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Aggregate.Simple<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Ambiguous<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.util.AsyncSubject<T> (implements hu.akarnokd.reactive4java.base.Subject<T,U>)
  • hu.akarnokd.reactive4java.util.Atomics
  • hu.akarnokd.reactive4java.reactive.Buffer
  • hu.akarnokd.reactive4java.reactive.Buffer.WithBoundary<T,U> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Buffer.WithClosing<T,U> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Buffer.WithOpenClose<T,U,V> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Buffer.WithSizeOrTime<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Buffer.WithSizeSkip<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Buffer.WithTime<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.scheduler.CachedThreadPoolScheduler (implements hu.akarnokd.reactive4java.base.Scheduler)
  • hu.akarnokd.reactive4java.util.CircularBuffer<T>
  • hu.akarnokd.reactive4java.util.Closeables
  • hu.akarnokd.reactive4java.reactive.Collect<U,T> (implements hu.akarnokd.reactive4java.base.CloseableIterable<T>)
  • hu.akarnokd.reactive4java.reactive.CombineLatest
  • hu.akarnokd.reactive4java.reactive.CombineLatest.NullStart<T,U,V> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.CombineLatest.Sent<V,T,U> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.util.ComparingHashMap<T,U>
  • hu.akarnokd.reactive4java.util.ComparingHashMap.Entry
  • hu.akarnokd.reactive4java.util.ComparingHashSet<T>
  • hu.akarnokd.reactive4java.util.ComparingHashSet.Entry
  • hu.akarnokd.reactive4java.util.CompositeCloseable (implements hu.akarnokd.reactive4java.base.Cancelable, java.io.Closeable)
  • hu.akarnokd.reactive4java.reactive.Concat
  • hu.akarnokd.reactive4java.reactive.Concat.FromIterable
  • hu.akarnokd.reactive4java.reactive.Concat.FromIterable.IndexedSelector<T,U> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Concat.FromIterable.Selector<T,U> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Concat.FromObservable
  • hu.akarnokd.reactive4java.reactive.Concat.FromObservable.IndexedSelector<T,U> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Concat.FromObservable.Selector<T,U> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Containment
  • hu.akarnokd.reactive4java.reactive.Containment.All<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Containment.Any<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Count
  • hu.akarnokd.reactive4java.reactive.Count.AsInt<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Count.AsLong<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.scheduler.CurrentThreadScheduler (implements hu.akarnokd.reactive4java.base.Scheduler)
  • hu.akarnokd.reactive4java.util.DefaultCloseableObserver<T> (implements hu.akarnokd.reactive4java.base.Cancelable, hu.akarnokd.reactive4java.base.CloseableObserver<T>)
  • hu.akarnokd.reactive4java.util.DefaultConnectableObservable<T,U> (implements hu.akarnokd.reactive4java.base.ConnectableObservable<T>)
  • hu.akarnokd.reactive4java.util.DefaultConnectableObservable.InnerConnection (implements java.io.Closeable)
  • hu.akarnokd.reactive4java.swing.DefaultEdtScheduler (implements hu.akarnokd.reactive4java.base.Scheduler)
  • hu.akarnokd.reactive4java.util.DefaultGroupedIterable<K,V> (implements hu.akarnokd.reactive4java.base.GroupedIterable<K,V>)
  • hu.akarnokd.reactive4java.util.DefaultObservable<T> (implements hu.akarnokd.reactive4java.base.CloseableObservable<T>, hu.akarnokd.reactive4java.base.Subject<T,U>)
    • hu.akarnokd.reactive4java.util.DefaultGroupedObservable<Key,Value> (implements hu.akarnokd.reactive4java.base.GroupedObservable<Key,Value>)
    • hu.akarnokd.reactive4java.swing.ObservableActionListener (implements java.awt.event.ActionListener)
    • hu.akarnokd.reactive4java.swing.ObservableAdjustmentListener (implements java.awt.event.AdjustmentListener)
    • hu.akarnokd.reactive4java.swing.ObservableChangeListener (implements javax.swing.event.ChangeListener)
    • hu.akarnokd.reactive4java.swing.ObservableDocumentListener (implements javax.swing.event.DocumentListener)
    • hu.akarnokd.reactive4java.swing.ObservableItemListener (implements java.awt.event.ItemListener)
    • hu.akarnokd.reactive4java.swing.ObservableKeyListener (implements java.awt.event.KeyListener)
    • hu.akarnokd.reactive4java.swing.ObservableListDataListener (implements javax.swing.event.ListDataListener)
    • hu.akarnokd.reactive4java.swing.ObservableListSelectionListener (implements javax.swing.event.ListSelectionListener)
    • hu.akarnokd.reactive4java.swing.ObservableMouseListener (implements java.awt.event.MouseListener, java.awt.event.MouseMotionListener, java.awt.event.MouseWheelListener)
    • hu.akarnokd.reactive4java.swing.ObservableWindowListener (implements java.awt.event.WindowFocusListener, java.awt.event.WindowListener, java.awt.event.WindowStateListener)
  • hu.akarnokd.reactive4java.util.DefaultObserver<T> (implements java.io.Closeable, hu.akarnokd.reactive4java.base.Observer<T>)
    • hu.akarnokd.reactive4java.util.DefaultObserverEx<T>
      • hu.akarnokd.reactive4java.reactive.Zip.ManyObservables.ItemObserver<T>
  • hu.akarnokd.reactive4java.util.DefaultRunnable (implements java.lang.Runnable)
    • hu.akarnokd.reactive4java.reactive.Delay.DelayedObservation<T>
      • hu.akarnokd.reactive4java.reactive.Delay.OnError<T>
      • hu.akarnokd.reactive4java.reactive.Delay.OnFinish<T>
      • hu.akarnokd.reactive4java.reactive.Delay.OnNext<T>
  • hu.akarnokd.reactive4java.scheduler.DefaultScheduler (implements hu.akarnokd.reactive4java.base.Scheduler)
  • hu.akarnokd.reactive4java.reactive.Delay
  • hu.akarnokd.reactive4java.reactive.Delay.ByTime<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Delay.Registration<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Distinct<T,U> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.swing.Dynamic
  • hu.akarnokd.reactive4java.util.Func0Builder<T> (implements hu.akarnokd.reactive4java.base.Func0<Return>)
  • hu.akarnokd.reactive4java.util.Func1Builder<T,U> (implements hu.akarnokd.reactive4java.base.Func1<Param1,Return>)
  • hu.akarnokd.reactive4java.util.Func2Builder<T,U,V> (implements hu.akarnokd.reactive4java.base.Func2<Param1,Param2,Return>)
  • hu.akarnokd.reactive4java.util.Functions
  • hu.akarnokd.reactive4java.reactive.GroupBy<Key,U,T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.GroupByUntil
  • hu.akarnokd.reactive4java.reactive.GroupByUntil.Default<K,V,T,D> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.GroupByUntil.WithComparer<K,V,T,D> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.interactive.Interactive
  • hu.akarnokd.reactive4java.interactive.Interactive.LinkedBuffer<T>
  • hu.akarnokd.reactive4java.interactive.Interactive.LinkedBuffer.N<T>
  • hu.akarnokd.reactive4java.reactive.Invoke
  • hu.akarnokd.reactive4java.reactive.Invoke.OnNext<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Invoke.OnNextError<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Invoke.OnNextErrorFinish<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Invoke.OnNextFinish<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Invoke.OnObserver<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.query.IterableBuilder<T> (implements java.lang.Iterable<T>)
  • hu.akarnokd.reactive4java.util.Lambdas
  • hu.akarnokd.reactive4java.util.LockedObserver<T> (implements java.io.Closeable, hu.akarnokd.reactive4java.base.Observer<T>)
  • hu.akarnokd.reactive4java.scheduler.NewThreadScheduler (implements hu.akarnokd.reactive4java.base.Scheduler)
  • java.util.Observable
    • hu.akarnokd.reactive4java.util.HybridSubject<T> (implements hu.akarnokd.reactive4java.base.CloseableObservable<T>, java.util.Observer, hu.akarnokd.reactive4java.base.Subject<T,U>)
    • hu.akarnokd.reactive4java.util.OriginalObservableWrapper<T> (implements hu.akarnokd.reactive4java.base.CloseableObservable<T>)
    • hu.akarnokd.reactive4java.util.ReactiveObservableWrapper<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.query.ObservableBuilder<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.util.Observables
  • hu.akarnokd.reactive4java.util.ObservableToIterableAdapter<T,U> (implements hu.akarnokd.reactive4java.base.CloseableIterable<T>)
    • hu.akarnokd.reactive4java.reactive.Latest<T>
    • hu.akarnokd.reactive4java.reactive.MostRecent<T>
    • hu.akarnokd.reactive4java.reactive.Next<T>
    • hu.akarnokd.reactive4java.reactive.ToIterable<T>
  • hu.akarnokd.reactive4java.util.ObserverAdapter<T> (implements hu.akarnokd.reactive4java.base.Observer<T>)
  • hu.akarnokd.reactive4java.util.Observers
  • hu.akarnokd.reactive4java.util.ObserverToIteratorSink<T,U> (implements hu.akarnokd.reactive4java.base.CloseableIterator<T>, hu.akarnokd.reactive4java.base.Observer<T>)
  • hu.akarnokd.reactive4java.base.Option<T>
    • hu.akarnokd.reactive4java.base.Option.Error<T>
    • hu.akarnokd.reactive4java.base.Option.None<T>
    • hu.akarnokd.reactive4java.base.Option.Some<T>
  • hu.akarnokd.reactive4java.util.OriginalObserverWrapper (implements hu.akarnokd.reactive4java.base.Observer<T>)
  • hu.akarnokd.reactive4java.base.Pair<T,U>
  • hu.akarnokd.reactive4java.util.Producer<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
    • hu.akarnokd.reactive4java.reactive.Delay.ByObservable<T,U,V>
    • hu.akarnokd.reactive4java.reactive.GroupJoin<Result,Left,Right,LeftDuration,RightDuration>
    • hu.akarnokd.reactive4java.reactive.Join<Left,Right,LeftDuration,RightDuration,Result>
    • hu.akarnokd.reactive4java.util.RefCountObservable<T>
  • hu.akarnokd.reactive4java.util.Producer.State<U> (implements hu.akarnokd.reactive4java.base.Action1<T>)
  • hu.akarnokd.reactive4java.util.R4JConfigManager
  • hu.akarnokd.reactive4java.reactive.Range
  • hu.akarnokd.reactive4java.reactive.Range.AsBigDecimal (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Range.AsBigInteger (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Range.AsDouble (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Range.AsFloat (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Range.AsInt (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Range.AsLong (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Reactive
  • hu.akarnokd.reactive4java.base.Ref<T>
  • hu.akarnokd.reactive4java.reactive.RefCount<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.util.RefCountCloseable (implements hu.akarnokd.reactive4java.base.Cancelable, java.io.Closeable)
  • hu.akarnokd.reactive4java.util.RefCountCloseable.InnerCloseable (implements java.io.Closeable)
  • hu.akarnokd.reactive4java.reactive.Repeat
  • hu.akarnokd.reactive4java.reactive.Repeat.DoWhile<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Repeat.RepeatValue<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Repeat.WhileDo<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Resume
  • hu.akarnokd.reactive4java.reactive.Resume.Always<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Resume.Conditionally<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Resume.OnError<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Resume.Retry<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Resume.RetryCount<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.util.RunOnce
  • hu.akarnokd.reactive4java.util.SafeObserver<T> (implements hu.akarnokd.reactive4java.base.Observer<T>)
  • hu.akarnokd.reactive4java.reactive.Sample
  • hu.akarnokd.reactive4java.reactive.Sample.ByObservable<T,U> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Sample.ByTime<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.util.ScheduledCloseable (implements hu.akarnokd.reactive4java.base.Cancelable, java.io.Closeable)
  • hu.akarnokd.reactive4java.util.Schedulers
  • hu.akarnokd.reactive4java.reactive.Select
  • hu.akarnokd.reactive4java.reactive.Select.Cast<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Select.CastToken<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Select.DefaultIfEmptyFunc<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Select.Indexed<T,U> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Select.LongIndexed<T,U> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Select.Simple<T,U> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.SelectMany
  • hu.akarnokd.reactive4java.reactive.SelectMany.Paired<T,U,V> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.SelectMany.WithIterable<T,U,V> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.util.SequentialCloseable (implements hu.akarnokd.reactive4java.base.Cancelable, java.io.Closeable)
  • hu.akarnokd.reactive4java.util.SingleCloseable (implements hu.akarnokd.reactive4java.base.Cancelable, java.io.Closeable)
  • hu.akarnokd.reactive4java.util.SingleContainer<T>
  • hu.akarnokd.reactive4java.scheduler.SingleLaneExecutor<T> (implements java.io.Closeable)
  • hu.akarnokd.reactive4java.util.SingleOption<T>
  • hu.akarnokd.reactive4java.util.Sink<T> (implements java.io.Closeable)
    • hu.akarnokd.reactive4java.util.DefaultSink<T> (implements hu.akarnokd.reactive4java.base.Observer<T>)
  • hu.akarnokd.reactive4java.reactive.Skip
  • hu.akarnokd.reactive4java.reactive.Skip.First<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Skip.FirstTimed<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Skip.Last<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Skip.LastTimed<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Skip.Until<T,U> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Skip.While<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Skip.WhileIndexed<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Skip.WhileLongIndexed<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.util.Subjects
  • hu.akarnokd.reactive4java.swing.SwingObservables
  • hu.akarnokd.reactive4java.util.SynchronizedObserver<T> (implements java.io.Closeable, hu.akarnokd.reactive4java.base.Observer<T>)
  • hu.akarnokd.reactive4java.util.TaggedCompositeCloseable (implements hu.akarnokd.reactive4java.base.Cancelable, java.io.Closeable)
  • hu.akarnokd.reactive4java.reactive.Take
  • hu.akarnokd.reactive4java.reactive.Take.First<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Take.FirstTimed<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Take.Last<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Take.LastBuffer<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Take.LastBufferTimed<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Take.LastScheduled<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Take.LastTimed<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Take.Until<T,U> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Take.While<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Take.WhileIndexed<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Take.WhileLongIndexed<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Throttle
  • hu.akarnokd.reactive4java.reactive.Throttle.ByObservable<T,U> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Throttle.ByTime<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • java.lang.Throwable (implements java.io.Serializable)
    • java.lang.Exception
      • java.io.IOException
        • hu.akarnokd.reactive4java.base.MultiIOException
      • java.lang.RuntimeException
        • hu.akarnokd.reactive4java.base.TooManyElementsException
  • hu.akarnokd.reactive4java.util.Throwables
  • hu.akarnokd.reactive4java.base.TimeInterval<T>
  • hu.akarnokd.reactive4java.reactive.Timeout
  • hu.akarnokd.reactive4java.reactive.Timeout.ByObservables<T,U,V> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Timeout.Switch<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.base.Timestamped<T> (implements java.lang.Comparable<T>)
  • hu.akarnokd.reactive4java.reactive.ToPrimitive
  • hu.akarnokd.reactive4java.reactive.ToPrimitive.ToDouble (implements hu.akarnokd.reactive4java.base.DoubleObservable)
  • hu.akarnokd.reactive4java.reactive.ToPrimitive.ToInt (implements hu.akarnokd.reactive4java.base.IntObservable)
  • hu.akarnokd.reactive4java.reactive.ToPrimitive.ToLong (implements hu.akarnokd.reactive4java.base.LongObservable)
  • hu.akarnokd.reactive4java.util.Unique<T>
  • hu.akarnokd.reactive4java.reactive.Where
  • hu.akarnokd.reactive4java.reactive.Where.Indexed<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Where.IndexedFactory<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Where.LongIndexed<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Where.OfType<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Where.Simple<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Windowing
  • hu.akarnokd.reactive4java.reactive.Windowing.WithBoundary<T,U> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Windowing.WithClosing<T,U> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Windowing.WithOpenClose<T,U,V> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Windowing.WithSizeSkip<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Windowing.WithTime<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Windowing.WithTimeOrSize<T> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Zip
  • hu.akarnokd.reactive4java.reactive.Zip.ManyObservables<T,U> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Zip.ObservableAndIterable<T,U,V> (implements hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.reactive.Zip.TwoObservable<T,U,V> (implements hu.akarnokd.reactive4java.base.Observable<T>)

Interface Hierarchy

• hu.akarnokd.reactive4java.base.Action0
• hu.akarnokd.reactive4java.base.Action0E<E>
• hu.akarnokd.reactive4java.base.Action1<T>
• hu.akarnokd.reactive4java.base.Action1E<T,E>
• hu.akarnokd.reactive4java.base.Action2<T,V>
• hu.akarnokd.reactive4java.base.Action2E<T,V,E>
• java.lang.AutoCloseable
  • java.io.Closeable
    • hu.akarnokd.reactive4java.base.CloseableIterator<T> (also extends java.util.Iterator<E>)
    • hu.akarnokd.reactive4java.base.CloseableObservable<T> (also extends hu.akarnokd.reactive4java.base.Observable<T>)
    • hu.akarnokd.reactive4java.base.CloseableObserver<T> (also extends hu.akarnokd.reactive4java.base.Observer<T>)
• hu.akarnokd.reactive4java.base.BaseObserver
  • hu.akarnokd.reactive4java.base.CloseableObserver<T> (also extends java.io.Closeable, hu.akarnokd.reactive4java.base.Observer<T>)
  • hu.akarnokd.reactive4java.base.DoubleObserver
  • hu.akarnokd.reactive4java.base.IntObserver
  • hu.akarnokd.reactive4java.base.Observer<T>
    • hu.akarnokd.reactive4java.base.CloseableObserver<T> (also extends java.io.Closeable)
    • hu.akarnokd.reactive4java.base.Subject<T,U> (also extends hu.akarnokd.reactive4java.base.Observable<T>)
  • hu.akarnokd.reactive4java.base.Subject<T,U> (also extends hu.akarnokd.reactive4java.base.Observable<T>, hu.akarnokd.reactive4java.base.Observer<T>)
• hu.akarnokd.reactive4java.base.Cancelable
• hu.akarnokd.reactive4java.base.DoubleObservable
• hu.akarnokd.reactive4java.base.Enumerable<T>
• hu.akarnokd.reactive4java.base.Enumerator<T>
• hu.akarnokd.reactive4java.base.Func0<Return>
  • hu.akarnokd.reactive4java.base.Pred0
• hu.akarnokd.reactive4java.base.Func1<Param1,Return>
  • hu.akarnokd.reactive4java.base.Pred1<T>
• hu.akarnokd.reactive4java.base.Func1E<Param1,Return,E>
• hu.akarnokd.reactive4java.base.Func2<Param1,Param2,Return>
  • hu.akarnokd.reactive4java.base.Pred2<T,U>
• hu.akarnokd.reactive4java.base.Func2E<Param1,Param2,Return,E>
• hu.akarnokd.reactive4java.base.IntObservable
• java.lang.Iterable<T>
  • hu.akarnokd.reactive4java.base.CloseableIterable<T>
  • hu.akarnokd.reactive4java.base.GroupedIterable<K,V>
• java.util.Iterator<E>
  • hu.akarnokd.reactive4java.base.CloseableIterator<T> (also extends java.io.Closeable)
• hu.akarnokd.reactive4java.base.LongObservable
• hu.akarnokd.reactive4java.base.LongObserver
• hu.akarnokd.reactive4java.base.Observable<T>
  • hu.akarnokd.reactive4java.base.CloseableObservable<T> (also extends java.io.Closeable)
  • hu.akarnokd.reactive4java.base.ConnectableObservable<T>
  • hu.akarnokd.reactive4java.base.GroupedObservable<Key,Value>
  • hu.akarnokd.reactive4java.base.Subject<T,U> (also extends hu.akarnokd.reactive4java.base.Observer<T>)
• hu.akarnokd.reactive4java.base.R4JConfig
• hu.akarnokd.reactive4java.base.Scheduler

Annotation Type Hierarchy

• hu.akarnokd.reactive4java.util.SuppressAnimalSniffer (implements java.lang.annotation.Annotation)

Enum Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
    • hu.akarnokd.reactive4java.base.ObservationKind
    • hu.akarnokd.reactive4java.reactive.Reactive.ObserverState