flowable

fun <T : Any> flowable(backPressureStrategy: BackpressureStrategy = BackpressureStrategy.LATEST, block: (FlowableEmitter<T>) -> Unit): Flowable<T>