docs: public ReactiveSeq<T> reactiveStream(){
          streamCreated = true;
  
  
          ReactiveSeq<T> result = Spouts.reactiveStream(getAction());
          if(complete)
              return ReactiveSeq.fromIterable(buffer);
          if(error!=null)
              throw ExceptionSoftener.throwSoftenedException(error);
          if(buffer.size()>0){
              return Spouts.concat(Spouts.fromIterable(buffer),result);
          }
  
  
  
          return result;
      }