code: public static <T> LatchedObserver<T> create(Action1<? super T> onNext, Action1<? super Throwable> onError) {
          return create(onNext, onError, new CountDownLatch(1));
      }
docs: Create a LatchedObserver with the given callback function(s).