public static < T > ObservableTransformer < T , T > doOnNextFx ( Consumer < T > onNext ) { return obs -> obs . doOnNext ( t -> runOnFx ( t , onNext ) ) ; }
Performs a given action for each item on the FX thread