title: How to iterate an object inside a Flux and do an operation on it?
body: <p>I'm using project reactor and I'd like to perform the following:</p>
  <pre class="lang-java prettyprint-override"><code>    @Override
      public void run(ApplicationArguments args) {
          Flux.from(KafkaReceiver.create(receiverOptions)
                          .receive()
                          .map(this::getObject)
                          .flatMap(this::iterateElasticWrites)
                          .flatMap(this::writeTheWholeObjectToS3)
          ).subscribe();
      }
  
      // What I'd like to do - but a non reactive code
      private Publisher&lt;MyObj&gt; iterateElasticWrites(MyObj message) {
          for (MyDoc file: message.getDocs()) {
              writeElasticDoc(file.getText());
          }
          return Mono.just(message);
      }
  </code></pre>
  <p>I'm struggling in finding out the equivalent of the <code>iterateElasticWrites</code> in Project Reactor. I'd like to perform an iteration of an object of mine (<code>MyObj</code>), and write each of its documents list's element into elasticsearch reactively.</p>