public static <T> FlowableTransformer<T,T> doOnNextCount(Consumer<Integer> onNext) {
        return obs -> obs.lift(new FlowableEmissionCounter<>(new CountObserver(onNext,null,null)));
    }
public static < T > FlowableTransformer < T , T > doOnNextCount ( Consumer < Integer > onNext ) { return obs -> obs . lift ( new FlowableEmissionCounter < > ( new CountObserver ( onNext , null , null ) ) ) ; }
Performs an action on onNext with the provided emission count
@param onNext
@param <T>