public interface

FlowableOnSubscribe

io.reactivex.FlowableOnSubscribe<T>

Class Overview

A functional interface that has a subscribe() method that receives an instance of a FlowableEmitter instance that allows pushing events in a backpressure-safe and cancellation-safe manner.

Summary

Public Methods
abstract void subscribe(FlowableEmitter<T> e)
Called for each Subscriber that subscribes.

Public Methods

public abstract void subscribe (FlowableEmitter<T> e)

Called for each Subscriber that subscribes.

Parameters
e the safe emitter instance, never null
Throws
Exception on error