Implement this method in subclasses to handle the incoming MaybeObservers. There is no need to call any of the plugin hooks on the current Maybe instance or the MaybeObserver; all hooks and basic safeguards have been applied by #subscribe(MaybeObserver) before this
(@NonNull MaybeObserver<? super T> observer)
| 5393 | * @param observer the {@code MaybeObserver} to handle, not {@code null} |
| 5394 | */ |
| 5395 | protected abstract void subscribeActual(@NonNull MaybeObserver<? super T> observer); |
| 5396 | |
| 5397 | /** |
| 5398 | * Asynchronously subscribes subscribers to this {@code Maybe} on the specified {@link Scheduler}. |