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) {
  }
}

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 ) { } }
subscribes to an observable , printing all its emissions . blocks until the observable calls oncompleted or onerror .
