code: @Override
    public Observable<String> helloUserStream(final String name, final int repeats) {
      return interval(100, TimeUnit.MILLISECONDS).map(i -> "Hello, " + name + "! (#" + i + ")").take(repeats);
    }
docs: Endpoint which receives username and repeats number,
  and returns stream of messages limited by the repeat number size
  
  @param name username (comes either from request body or as query param)
  @param repeats repeats (comes either from request body or as query param)
  @return stream of results (&gt;= repeats)