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.
@FunctionalInterface public interface MaybeSource<@NonNull T>
Represents a basicMaybe
source base interface, consumable via anMaybeObserver
.This class also serves the base type for custom operators wrapped into Maybe via
Maybe.create(MaybeOnSubscribe)
.- Since:
- 2.0
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
subscribe(@NonNull MaybeObserver<? super @NonNull T> observer)
Subscribes the givenMaybeObserver
to thisMaybeSource
instance.
-
-
-
Method Detail
-
subscribe
void subscribe(@NonNull @NonNull MaybeObserver<? super @NonNull T> observer)
Subscribes the givenMaybeObserver
to thisMaybeSource
instance.- Parameters:
observer
- theMaybeObserver
, notnull
- Throws:
java.lang.NullPointerException
- ifobserver
isnull
-
-