title: Project Reactor - How to handle OverflowException from Flux.interval?
body: <p>I am building a spring boot application using Spring Webflux and I want to make the application fully non-blocking. The application itself has some REST endpoints and a batch job that needs to run every few seconds. For the batch job, I am trying to <code>Flux.interval(Duration.ofMillis(1000))</code> to generate long values which I ignore and run my scheduled job.</p>
  
  <pre><code>Flux.interval(Duration.ofMillis(1000))
      .flatMap(ignore -&gt; doSomething())
      .subscribe();
  </code></pre>
  
  <p>However after some time I get the error </p>
  
  <p><code>reactor.core.Exceptions$ErrorCallbackNotImplemented: reactor.core.Exceptions$OverflowException: Could not emit tick 257 due to lack of requests (interval doesn't support small downstream requests that replenish slower than the ticks)</code></p>
  
  <p>Can someone tell me how to overcome this issue ?</p>