Interface FlowableOnSubscribe<T>

Type Parameters:
T - the value type pushed
Functional Interface:
This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
@FunctionalInterface public interface FlowableOnSubscribe<@NonNull T>
A functional interface that has a subscribe() method that receives a FlowableEmitter instance that allows pushing events in a backpressure-safe and cancellation-safe manner.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    subscribe(@NonNull FlowableEmitter<@NonNull T> emitter)
    Called for each
    invalid reference 
    Subscriber
    that subscribes.