public interface

FlowableOperator

io.reactivex.FlowableOperator<Downstream, Upstream>

Class Overview

Interface to map/wrap a downstream subscriber to an upstream subscriber.

Summary

Public Methods
abstract Subscriber<? super Upstream> apply(Subscriber<? super Downstream> observer)
Applies a function to the child Subscriber and returns a new parent Subscriber.

Public Methods

public abstract Subscriber<? super Upstream> apply (Subscriber<? super Downstream> observer)

Applies a function to the child Subscriber and returns a new parent Subscriber.

Parameters
observer the child Subscriber instance
Returns
  • the parent Subscriber instance
Throws
Exception on failure