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 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 Type	Method	Description
void	subscribe(@NonNull MaybeObserver<? super @NonNull T> observer)	Subscribes the given MaybeObserver to this MaybeSource instance.

Method Detail

subscribe

void subscribe(@NonNull
               @NonNull MaybeObserver<? super @NonNull T> observer)

Subscribes the given MaybeObserver to this MaybeSource instance.

Parameters:

observer - the MaybeObserver, not null

Throws:

java.lang.NullPointerException - if observer is null