hu.akarnokd.reactive4java.base

Interface Observable<T>

Type Parameters:

T - the type of the values to send

All Known Subinterfaces:

CloseableObservable<T>, ConnectableObservable<T>, GroupedObservable<Key,Value>, Subject<T,U>

All Known Implementing Classes:

AddTimeInterval, Aggregate.Projected, Aggregate.Scan, Aggregate.ScanSeeded, Aggregate.Seeded, Aggregate.SeededIndexedProjected, Aggregate.Simple, Ambiguous, AsyncSubject, Buffer.WithBoundary, Buffer.WithClosing, Buffer.WithOpenClose, Buffer.WithSizeOrTime, Buffer.WithSizeSkip, Buffer.WithTime, CombineLatest.NullStart, CombineLatest.Sent, Concat.FromIterable.IndexedSelector, Concat.FromIterable.Selector, Concat.FromObservable.IndexedSelector, Concat.FromObservable.Selector, Containment.All, Containment.Any, Count.AsInt, Count.AsLong, DefaultConnectableObservable, DefaultGroupedObservable, DefaultObservable, Delay.ByObservable, Delay.ByTime, Delay.Registration, Distinct, GroupBy, GroupByUntil.Default, GroupByUntil.WithComparer, GroupJoin, HybridSubject, Invoke.OnNext, Invoke.OnNextError, Invoke.OnNextErrorFinish, Invoke.OnNextFinish, Invoke.OnObserver, Join, ObservableActionListener, ObservableAdjustmentListener, ObservableBuilder, ObservableChangeListener, ObservableDocumentListener, ObservableItemListener, ObservableKeyListener, ObservableListDataListener, ObservableListSelectionListener, ObservableMouseListener, ObservableWindowListener, OriginalObservableWrapper, Producer, Range.AsBigDecimal, Range.AsBigInteger, Range.AsDouble, Range.AsFloat, Range.AsInt, Range.AsLong, ReactiveObservableWrapper, RefCount, RefCountObservable, Repeat.DoWhile, Repeat.RepeatValue, Repeat.WhileDo, Resume.Always, Resume.Conditionally, Resume.OnError, Resume.Retry, Resume.RetryCount, Sample.ByObservable, Sample.ByTime, Select.Cast, Select.CastToken, Select.DefaultIfEmptyFunc, Select.Indexed, Select.LongIndexed, Select.Simple, SelectMany.Paired, SelectMany.WithIterable, Skip.First, Skip.FirstTimed, Skip.Last, Skip.LastTimed, Skip.Until, Skip.While, Skip.WhileIndexed, Skip.WhileLongIndexed, Take.First, Take.FirstTimed, Take.Last, Take.LastBuffer, Take.LastBufferTimed, Take.LastScheduled, Take.LastTimed, Take.Until, Take.While, Take.WhileIndexed, Take.WhileLongIndexed, Throttle.ByObservable, Throttle.ByTime, Timeout.ByObservables, Timeout.Switch, Where.Indexed, Where.IndexedFactory, Where.LongIndexed, Where.OfType, Where.Simple, Windowing.WithBoundary, Windowing.WithClosing, Windowing.WithOpenClose, Windowing.WithSizeSkip, Windowing.WithTime, Windowing.WithTimeOrSize, Zip.ManyObservables, Zip.ObservableAndIterable, Zip.TwoObservable

public interface Observable<T>

Defines a provider for a push based value streaming. Based on Rx.

Method Summary

Modifier and Type	Method and Description
java.io.Closeable	register(Observer<? super T> observer) Registers an observer for the notification of Ts.

Method Detail

register

@Nonnull
java.io.Closeable register(@Nonnull
                                     Observer<? super T> observer)

Registers an observer for the notification of Ts.

Parameters:

observer - the observer of Ts or any supertype of it

Returns:

the way of deregister the observer from this provider