Top Description Methods
io.reactivex.rxjava3.internal.fuseable

public Interface HasUpstreamPublisher<T>

Known Direct Implementers
io.reactivex.rxjava3.internal.operators.flowable.AbstractFlowableWithUpstream, io.reactivex.rxjava3.internal.operators.flowable.FlowablePublish, io.reactivex.rxjava3.internal.operators.flowable.FlowableReduceMaybe, io.reactivex.rxjava3.internal.operators.flowable.FlowableReplay
Type Parameters
<T>
the value type
Imports
org.reactivestreams.Publisher, io.reactivex.rxjava3.annotations.NonNull
Interface indicating the implementor has an upstream Publisher-like source available via source() method.

Method Summary

Modifier and TypeMethod and Description
public @NonNull Publisher<T>

Returns:

the source Publisher
source()

Returns the source Publisher.

Method Detail

sourceback to summary
public @NonNull Publisher<T> source()

Returns the source Publisher.

This method is intended to discover the assembly graph of sequences.

Returns:@NonNull Publisher<T>

the source Publisher

Annotations
@NonNull