title: RxJava and parallel execution of observer code
body: <p>I am having the following code using RxJava Observable api :</p>
  
  <pre><code>Observable&lt;Info&gt; observable = fileProcessor.processFileObservable(processedFile.getAbsolutePath());
      observable
        .buffer(10000)
        .observeOn(Schedulers.computation())
        .subscribe(recordInfo -&gt; {
          _logger.info("Running stage2 on thread with id : " + Thread.currentThread().getId());
            for(Info info : recordInfo) {
              // some I/O operation logic
           }
        }, 
        exception -&gt; {
        }, 
        () -&gt; {
        });
  </code></pre>
  
  <p>My expectation was that the observation code i.e. code inside the subscribe() method will be executed in parallel after I have specified the computation scheduler. Instead the code is still being executed sequentially on single thread. How can make the code run in parallel using RxJava api.</p>