public static < T > Flowable < T > toFlowable ( EventPublisher < T > eventPublisher ) { PublishProcessor < T > publishProcessor = PublishProcessor . create ( ) ; FlowableProcessor < T > flowableProcessor = publishProcessor . toSerialized ( ) ; eventPublisher . onEvent ( flowableProcessor :: onNext ) ; return flowableProcessor ; }
Converts the EventPublisher into a Flowable .