dumb

gistfile1.txt

	private class CountingLogger<T> implements Function<T, T> {
		
		private int every;
		private int count;
		private Function<Integer,String> message;
		
		public CountingLogger(int every, Function<Integer,String> message) {
			this.every = every;
			this.message = message;
			this.count = 0;
		}
		
		@Override
		public T apply(T t) {
			if (count++ % every == 0) {
				info(message.apply(count));
			}
			return t;
		}
	}

(defn counting-logger [every message-fn]
  (let [count (atom 0)]
    (fn [x] (when-not (mod x every) (println (message-fn x))) (swap! count inc) x)))