Top Classes
[default module]

Package io.reactivex.rxjava3.internal.operators.single


Class Summary

Modifier and TypeClass and Description
public class
public class
public class
public class
public class
public class
public class
public class
public class
public class
public class
SingleDematerialize<
the element type of the source
T
,
the element type of the Notification and result
R
>

Maps the success value of the source to a Notification, then maps it back to the corresponding signal type.

public class
SingleDetach<
the value type
T
>

Breaks the references between the upstream and downstream when the Maybe terminates.

public class
SingleDoAfterSuccess<
the value type
T
>

Calls a consumer after pushing the current item to the downstream.

public class
SingleDoAfterTerminate<
the value type
T
>

Calls an action after pushing the current item or an error to the downstream.

public class
SingleDoFinally<
the value type
T
>

Execute an action after an onSuccess, onError or a dispose event.

public class
public class
public class
public class
SingleDoOnLifecycle<
the element type of the flow
T
>

Invokes callbacks upon onSubscribe from upstream and dispose from downstream.

public class
SingleDoOnSubscribe<
the value type
T
>

Calls a callback when the upstream calls onSubscribe with a disposable.

public class
public class
public class
public class
public class
public class
SingleFlatMapBiSelector<
the main value type
T
,
the second value type
U
,
the result value type
R
>

Maps a source item to another SingleSource then calls a BiFunction with the original item and the secondary item to generate the final result.

public class
SingleFlatMapCompletable<
the value type of the source SingleSource
T
>

Maps the success value of the source SingleSource into a Completable.

public class
SingleFlatMapIterableFlowable<
the source value type
T
,
the element type of the Iterable
R
>

Maps a success value into an Iterable and streams it back as a Flowable.

public class
SingleFlatMapIterableObservable<
the source value type
T
,
the element type of the Iterable
R
>

Maps a success value into an Iterable and streams it back as an Observable.

public class
public class
SingleFlatMapNotification<
the source value type
T
,
the result value type
R
>

Maps a value into a SingleSource and relays its signal.

public class
SingleFlatMapPublisher<
the source value type
T
,
the result value type
R
>

A Flowable that emits items based on applying a specified function to the item emitted by the source Single, where that function returns a Publisher.

public class
public class
public class
SingleFromSupplier<
the value type returned
T
>

Calls a supplier and emits its value or exception to the incoming SingleObserver.

public class
public class
public class
SingleInternalHelper

Helper utility class to support Single with inner classes.

public class
public class
SingleLift<T, R>

public class
SingleMap<T, R>

public class
SingleMaterialize<
the element type of the source
T
>

Turn the signal types of a Single source into a single Notification of equal kind.

public class
public class
public class
SingleOnErrorComplete<
the value type
T
>

Emits an onComplete if the source emits an onError and the predicate returns true for that Throwable.

public class
public class
public class
public class
SingleTakeUntil<
the main value type
T
,
the other value type
U
>

Signals the events of the source Single or signals a CancellationException if the other Publisher signalled first.

public class
SingleTimeInterval<
the element type of the sequence
T
>

Measures the time between subscription and the success item emission from the upstream and emits this as a Timed success value.

public class
public class
SingleTimer

Signals a 0L after the specified delay.

public class
SingleToFlowable<
the value type
T
>

Wraps a Single and exposes it as a Flowable.

public class
SingleToObservable<
the value type
T
>

Wraps a Single and exposes it as an Observable.

public class
SingleUnsubscribeOn<
the value type
T
>

Makes sure a dispose() call from downstream happens on the specified scheduler.

public class
public class
public class