@@ -0,0 +1,577 @@
+package org.davidmoten.rx.pool;%0A%0Aimport io.reactivex.functions.Consumer;%0A%0Apublic final class Consumers %7B%0A%0A    private Consumers() %7B%0A        // prevent instantiation%0A    %7D%0A%0A    static final class DoNothingHolder %7B%0A        static final Consumer%3CObject%3E value = new Consumer%3CObject%3E() %7B%0A%0A            @Override%0A            public void accept(Object arg0) throws Exception %7B%0A                // do nothing%0A            %7D%0A%0A        %7D;%0A    %7D%0A%0A    @SuppressWarnings(%22unchecked%22)%0A    public static %3CT%3E Consumer%3CT%3E doNothing() %7B%0A        return (Consumer%3CT%3E) DoNothingHolder.value;%0A    %7D%0A%0A%7D%0A

add Consumers class