Class AbstractFlowableWithUpstream<T,​R>

    • Field Detail

      • source

        protected final Flowable<T> source
        The upstream source Publisher.
    • Constructor Detail

      • AbstractFlowableWithUpstream

        AbstractFlowableWithUpstream​(Flowable<T> source)
        Constructs a FlowableSource wrapping the given non-null (verified) source Publisher.
        Parameters:
        source - the source (upstream) Publisher instance, not null (verified)
    • Method Detail

      • source

        public final org.reactivestreams.Publisher<T> source()
        Description copied from interface: HasUpstreamPublisher
        Returns the source Publisher.

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

        Specified by:
        source in interface HasUpstreamPublisher<T>
        Returns:
        the source Publisher