hu.akarnokd.reactive4java.base

Interface BaseObserver

All Known Subinterfaces:

CloseableObserver<T>, DoubleObserver, IntObserver, Observer<T>, Subject<T,U>

All Known Implementing Classes:

AsyncSubject, DefaultCloseableObserver, DefaultGroupedObservable, DefaultObservable, DefaultObserver, DefaultObserverEx, DefaultSink, HybridSubject, LockedObserver, ObservableActionListener, ObservableAdjustmentListener, ObservableChangeListener, ObservableDocumentListener, ObservableItemListener, ObservableKeyListener, ObservableListDataListener, ObservableListSelectionListener, ObservableMouseListener, ObservableWindowListener, ObserverAdapter, ObserverToIteratorSink, OriginalObserverWrapper, SafeObserver, SynchronizedObserver, Zip.ManyObservables.ItemObserver

public interface BaseObserver

Common superclass for all observers defining the error and finish methods.

Since:

0.97

Method Summary

Modifier and Type	Method and Description
void	error(java.lang.Throwable ex) An exception is received.
void	finish() No more values to expect.

Method Detail

error

void error(@Nonnull
           java.lang.Throwable ex)

An exception is received.

Parameters:

ex - the exception

finish

void finish()

No more values to expect.