Add timeout to CoundDownLatch, ignore InterruptException and fix the test to be consistent with the new subscribeOn