docs: public static <T> ReactiveSeq<T> connectToReactiveSeq(Observable<T> observable) {
          return Spouts.async(s->{
             observable.subscribe(s::onNext,e->{
                 s.onError(e);
                 s.onComplete();
             },s::onComplete);
  
          });
  
      }