public static < T > ObservableTransformer < T , T > doOnErrorCountFx ( Consumer < Integer > onError ) { return obs -> obs . compose ( doOnErrorCount ( i -> runOnFx ( i , onError ) ) ) ; }
Performs an action on FX thread on onError with the provided emission count