code: public Observable<Integer> run(InputStream is, Charset charset, String delimiter) {
          return Strings.split(Strings.from(new InputStreamReader(is, charset)), ";") //
                  .compose(run());
      }
docs: Returns an {@link Observable} that is the result of running a sequence of
  update commands (insert/update/delete, ddl) commands read from an
  {@link InputStream} with the given {@link Charset} using the given
  delimiter as the statement delimiter (for example semicolon).
  
  @param is
  @param delimiter
  @return