Package io.reactivex.rxjava3.core

Interface SingleSource<T>

Type Parameters:

T - the element type

All Known Implementing Classes:

CompletableMaterialize, CompletableToSingle, FlowableAllSingle, FlowableAnySingle, FlowableCollectSingle, FlowableCollectWithCollectorSingle, FlowableCountSingle, FlowableElementAtSingle, FlowableLastSingle, FlowableReduceSeedSingle, FlowableReduceWithSingle, FlowableSequenceEqualSingle, FlowableSingleSingle, FlowableToListSingle, MaybeContains, MaybeCount, MaybeEqualSingle, MaybeIsEmptySingle, MaybeMaterialize, MaybeSwitchIfEmptySingle, MaybeToSingle, ObservableAllSingle, ObservableAnySingle, ObservableCollectSingle, ObservableCollectWithCollectorSingle, ObservableCountSingle, ObservableElementAtSingle, ObservableLastSingle, ObservableReduceSeedSingle, ObservableReduceWithSingle, ObservableSequenceEqualSingle, ObservableSingleSingle, ObservableToListSingle, Single, SingleAmb, SingleCache, SingleContains, SingleCreate, SingleDefer, SingleDelay, SingleDelayWithCompletable, SingleDelayWithObservable, SingleDelayWithPublisher, SingleDelayWithSingle, SingleDetach, SingleDoAfterSuccess, SingleDoAfterTerminate, SingleDoFinally, SingleDoOnDispose, SingleDoOnError, SingleDoOnEvent, SingleDoOnLifecycle, SingleDoOnSubscribe, SingleDoOnSuccess, SingleDoOnTerminate, SingleEquals, SingleError, SingleFlatMap, SingleFlatMapBiSelector, SingleFlatMapNotification, SingleFromCallable, SingleFromCompletionStage, SingleFromPublisher, SingleFromSupplier, SingleFromUnsafeSource, SingleHide, SingleJust, SingleLift, SingleMap, SingleMaterialize, SingleNever, SingleObserveOn, SingleOnErrorReturn, SingleResumeNext, SingleSubject, SingleSubscribeOn, SingleTakeUntil, SingleTimeInterval, SingleTimeout, SingleTimer, SingleUnsubscribeOn, SingleUsing, SingleZipArray, SingleZipIterable

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 SingleSource<@NonNull T>

Represents a basic Single source base interface, consumable via an SingleObserver.

This class also serves the base type for custom operators wrapped into Single via Single.create(SingleOnSubscribe).

Since:

2.0

Method Summary

Modifier and Type	Method	Description
void	subscribe(@NonNull SingleObserver<? super @NonNull T> observer)	Subscribes the given SingleObserver to this SingleSource instance.

Method Detail

subscribe

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

Subscribes the given SingleObserver to this SingleSource instance.

Parameters:

observer - the SingleObserver, not null

Throws:

java.lang.NullPointerException - if observer is null