code: 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);
  
          });
  
      }
docs: Convert an Observable to a cyclops-react ReactiveSeq
  
  @param observable To conver
  @return ReactiveSeq