FlowableOnSubscribe

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

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	Description
`void`	`subscribe(@NonNull FlowableEmitter<@NonNull T> emitter)`	Called for each `Subscriber` that subscribes.

- Method Detail
  - subscribe
```
void subscribe(@NonNull
               @NonNull FlowableEmitter<@NonNull T> emitter)
        throws java.lang.Throwable
```
    Called for each Subscriber that subscribes.
    
    Parameters:
    
    emitter - the safe emitter instance, never null
    
    Throws:
    
    java.lang.Throwable - on error