@@ -0,0 +1,375 @@
+package com.github.davidmoten.rx.jdbc;%0A%0Aimport java.util.concurrent.CountDownLatch;%0A%0Aimport rx.functions.Action0;%0A%0Apublic final class  TestingUtil %7B%0A    %0A    public static Action0 countDown(final CountDownLatch latch) %7B%0A        return new Action0() %7B%0A%0A            @Override%0A            public void call() %7B%0A                latch.countDown();%0A            %7D%0A        %7D;%0A    %7D%0A%7D%0A

use junit-extras