Type Parameters:

T - the value type pushed

public interface FlowableOnSubscribe<T>

• Method Summary

  All Methods

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

• Method Detail

  • subscribe

    void subscribe(@NonNull
     FlowableEmitter<T> emitter)
     throws Exception 

    Called for each Subscriber that subscribes.

    Parameters:

    emitter - the safe emitter instance, never null

    Throws:

    Exception - on error