anchor.diff:  
   import java.math.BigDecimal;
   import java.math.RoundingMode;
  +import java.time.Duration;
   import java.time.Instant;
   import java.util.Arrays;
   import java.util.Collections;
   import java.util.List;
   import java.util.Random;
  -import java.util.concurrent.TimeUnit;
  -import java.util.stream.Collectors;
   
   import javax.enterprise.context.ApplicationScoped;
   
  +import io.smallrye.mutiny.Multi;
  +import io.smallrye.reactive.messaging.kafka.Record;
   import org.eclipse.microprofile.reactive.messaging.Outgoing;
   import org.jboss.logging.Logger;
  -
  -import io.reactivex.Flowable;
  -import io.smallrye.reactive.messaging.kafka.KafkaRecord;
   
   /**
    * A bean producing random temperature data every second.
  
positive.code:                     new WeatherStation(9, "Marrakesh", 20)
              ));
  
  
      @Outgoing("temperature-values")                             // <1>
      public Flowable<KafkaRecord<Integer, String>> generate() {
  
          return Flowable.interval(500, TimeUnit.MILLISECONDS)    // <2>
                  .onBackpressureDrop()
                  .map(tick -> {
                      WeatherStation station = stations.get(random.nextInt(stations.size()));
                      double temperature = BigDecimal.valueOf(random.nextGaussian() * 15 + station.averageTemperature)
  
negative.code:     }
  }
  ----
  <1> Instruct Reactive Messaging to dispatch the items from the returned `Multi` to `temperature-values`.
  <2> The method returns a Mutiny _stream_ (`Multi`) emitting a random temperature value every 0.5 seconds.
  <3> Instruct Reactive Messaging to dispatch the items from the returned `Multi` (static list of weather stations) to `weather-stations`.
  
  The two methods each return a _reactive stream_ whose items are sent to the streams named `temperature-values` and `weather-stations`, respectively.
  
  