Package io.reactivex.rxjava3.core
Interface MaybeSource<T>
- Type Parameters:
T- the element type
- All Known Implementing Classes:
AbstractMaybeWithUpstream,CompletableOnErrorReturn,FlowableElementAtMaybe,FlowableElementAtMaybePublisher,FlowableLastMaybe,FlowableReduceMaybe,FlowableSingleMaybe,Maybe,MaybeAmb,MaybeCache,MaybeCreate,MaybeDefer,MaybeDelay,MaybeDelayOtherPublisher,MaybeDelaySubscriptionOtherPublisher,MaybeDelayWithCompletable,MaybeDematerialize,MaybeDetach,MaybeDoAfterSuccess,MaybeDoFinally,MaybeDoOnEvent,MaybeDoOnLifecycle,MaybeDoOnTerminate,MaybeEmpty,MaybeError,MaybeErrorCallable,MaybeFilter,MaybeFilterSingle,MaybeFlatMapBiSelector,MaybeFlatMapNotification,MaybeFlatMapSingle,MaybeFlatten,MaybeFromAction,MaybeFromCallable,MaybeFromCompletable,MaybeFromCompletionStage,MaybeFromFuture,MaybeFromRunnable,MaybeFromSingle,MaybeFromSupplier,MaybeHide,MaybeIgnoreElement,MaybeIsEmpty,MaybeJust,MaybeLift,MaybeMap,MaybeMapOptional,MaybeNever,MaybeObserveOn,MaybeOnErrorComplete,MaybeOnErrorNext,MaybeOnErrorReturn,MaybePeek,MaybeSubject,MaybeSubscribeOn,MaybeSwitchIfEmpty,MaybeTakeUntilMaybe,MaybeTakeUntilPublisher,MaybeTimeInterval,MaybeTimeoutMaybe,MaybeTimeoutPublisher,MaybeTimer,MaybeUnsafeCreate,MaybeUnsubscribeOn,MaybeUsing,MaybeZipArray,MaybeZipIterable,ObservableElementAtMaybe,ObservableLastMaybe,ObservableReduceMaybe,ObservableSingleMaybe,SingleDematerialize,SingleFlatMapMaybe,SingleMapOptional,SingleOnErrorComplete
- Functional Interface:
- This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
Represents a basic
Maybe source base interface,
consumable via an MaybeObserver.
This class also serves the base type for custom operators wrapped into
Maybe via Maybe.create(MaybeOnSubscribe).
- Since:
- 2.0
-
Method Summary
Modifier and TypeMethodDescriptionvoidsubscribe(@NonNull MaybeObserver<? super @NonNull T> observer) Subscribes the givenMaybeObserverto thisMaybeSourceinstance.
-
Method Details
-
subscribe
Subscribes the givenMaybeObserverto thisMaybeSourceinstance.- Parameters:
observer- theMaybeObserver, notnull- Throws:
NullPointerException- ifobserverisnull
-