Package io.reactivex.rxjava3.internal.fuseable

Interface HasUpstreamMaybeSource<T>

Type Parameters:
T - the value type
All Known Implementing Classes:
AbstractMaybeWithUpstream, MaybeContains, MaybeCount, MaybeDelay, MaybeDelayOtherPublisher, MaybeDelaySubscriptionOtherPublisher, MaybeDematerialize, MaybeDetach, MaybeDoAfterSuccess, MaybeDoFinally, MaybeDoOnEvent, MaybeDoOnLifecycle, MaybeFilter, MaybeFlatMapBiSelector, MaybeFlatMapNotification, MaybeFlatten, MaybeHide, MaybeIgnoreElement, MaybeIsEmpty, MaybeIsEmptySingle, MaybeLift, MaybeMap, MaybeObserveOn, MaybeOnErrorComplete, MaybeOnErrorNext, MaybeOnErrorReturn, MaybePeek, MaybeSubscribeOn, MaybeSwitchIfEmpty, MaybeSwitchIfEmptySingle, MaybeTakeUntilMaybe, MaybeTakeUntilPublisher, MaybeTimeoutMaybe, MaybeTimeoutPublisher, MaybeToFlowable, MaybeToObservable, MaybeToSingle, MaybeUnsafeCreate, MaybeUnsubscribeOn
public interface HasUpstreamMaybeSource<@NonNull T>
Interface indicating the implementor has an upstream MaybeSource-like source available via source() method.

  • Method Summary

    Modifier and Type
    Method
    Description
    @NonNull MaybeSource<T>
    source()
    Returns the upstream source of this Maybe.

  • Method Details

    • source

      @NonNull @NonNull MaybeSource<T> source()
      Returns the upstream source of this Maybe.

      Allows discovering the chain of observables.

      Returns:
      the source MaybeSource