The documentation just says
protected abstract void subscribeActual(Observer<? super T> observer)
Operator implementations (both source and intermediate) should implement this method that performs the necessary business logic.
There is no need to call any of the plugin hooks on the current Observable
instance or the Subscriber
.
Observable.subscribe
comes from the base interface definition inObservableSource
and is the main subscription method forObservable
s: internal and external components use it to run a flow in a standard way.However, certain actions may be necessary for all kinds of
Observable
s to be executed before the operator's business logic gains access to the incomingObserver
, for example, applying plugin hooks and protecting against crashing subscribe implementations. So instead of requiring every operator to duplicate this preparation logic, they are in a single place and a new abstract method is present to deal with the customization of anObservable
.