question: public static < T > void blockingSubscribePrint ( Observable < T > observable , String name ) { CountDownLatch latch = new CountDownLatch ( 1 ) ; subscribePrint ( observable . finallyDo ( null ) , name ) ; try { latch . await ( ) ; } catch ( InterruptedException e ) { } }
target:  Subscribes to an observable, printing all its emissions. Blocks until the observable calls onCompleted or onError.