public class examples.KafkaClientExamples
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: examples.KafkaClientExamples
  super_class: java.lang.Object
{
  public void <init>();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // examples.KafkaClientExamples this
         0: .line 25
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
            return
        end local 0 // examples.KafkaClientExamples this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lexamples/KafkaClientExamples;

  public void consumer(io.vertx.reactivex.kafka.client.consumer.KafkaConsumer<java.lang.String, java.lang.Long>);
    descriptor: (Lio/vertx/reactivex/kafka/client/consumer/KafkaConsumer;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // examples.KafkaClientExamples this
        start local 1 // io.vertx.reactivex.kafka.client.consumer.KafkaConsumer consumer
         0: .line 29
            aload 1 /* consumer */
            invokevirtual io.vertx.reactivex.kafka.client.consumer.KafkaConsumer.toObservable:()Lio/reactivex/Observable;
            astore 2 /* observable */
        start local 2 // io.reactivex.Observable observable
         1: .line 31
            aload 2 /* observable */
         2: .line 32
            invokedynamic apply()Lio/reactivex/functions/Function;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)Ljava/lang/Object;
                  examples/KafkaClientExamples.lambda$0(Lio/vertx/reactivex/kafka/client/consumer/KafkaConsumerRecord;)Ljava/lang/Long; (6)
                  (Lio/vertx/reactivex/kafka/client/consumer/KafkaConsumerRecord;)Ljava/lang/Long;
            invokevirtual io.reactivex.Observable.map:(Lio/reactivex/functions/Function;)Lio/reactivex/Observable;
         3: .line 33
            sipush 256
            invokevirtual io.reactivex.Observable.buffer:(I)Lio/reactivex/Observable;
         4: .line 35
            invokedynamic apply()Lio/reactivex/functions/Function;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)Ljava/lang/Object;
                  examples/KafkaClientExamples.lambda$1(Ljava/util/List;)Ljava/util/OptionalDouble; (6)
                  (Ljava/util/List;)Ljava/util/OptionalDouble;
         5: .line 34
            invokevirtual io.reactivex.Observable.map:(Lio/reactivex/functions/Function;)Lio/reactivex/Observable;
         6: .line 36
            invokedynamic accept()Lio/reactivex/functions/Consumer;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)V
                  examples/KafkaClientExamples.lambda$3(Ljava/util/OptionalDouble;)V (6)
                  (Ljava/util/OptionalDouble;)V
            invokevirtual io.reactivex.Observable.subscribe:(Lio/reactivex/functions/Consumer;)Lio/reactivex/disposables/Disposable;
            pop
         7: .line 41
            return
        end local 2 // io.reactivex.Observable observable
        end local 1 // io.vertx.reactivex.kafka.client.consumer.KafkaConsumer consumer
        end local 0 // examples.KafkaClientExamples this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    8     0        this  Lexamples/KafkaClientExamples;
            0    8     1    consumer  Lio/vertx/reactivex/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/Long;>;
            1    8     2  observable  Lio/reactivex/Observable<Lio/vertx/reactivex/kafka/client/consumer/KafkaConsumerRecord<Ljava/lang/String;Ljava/lang/Long;>;>;
    Signature: (Lio/vertx/reactivex/kafka/client/consumer/KafkaConsumer<Ljava/lang/String;Ljava/lang/Long;>;)V
    MethodParameters:
          Name  Flags
      consumer  

  private static java.lang.Long lambda$0(io.vertx.reactivex.kafka.client.consumer.KafkaConsumerRecord);
    descriptor: (Lio/vertx/reactivex/kafka/client/consumer/KafkaConsumerRecord;)Ljava/lang/Long;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.vertx.reactivex.kafka.client.consumer.KafkaConsumerRecord record
         0: .line 32
            aload 0 /* record */
            invokevirtual io.vertx.reactivex.kafka.client.consumer.KafkaConsumerRecord.value:()Ljava/lang/Object;
            checkcast java.lang.Long
            areturn
        end local 0 // io.vertx.reactivex.kafka.client.consumer.KafkaConsumerRecord record
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    1     0  record  Lio/vertx/reactivex/kafka/client/consumer/KafkaConsumerRecord<Ljava/lang/String;Ljava/lang/Long;>;
    Exceptions:
      throws java.lang.Exception

  private static java.util.OptionalDouble lambda$1(java.util.List);
    descriptor: (Ljava/util/List;)Ljava/util/OptionalDouble;
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // java.util.List list
         0: .line 35
            aload 0 /* list */
            invokeinterface java.util.List.stream:()Ljava/util/stream/Stream;
            invokedynamic applyAsDouble()Ljava/util/function/ToDoubleFunction;
              Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.metafactory:(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
                Method arguments:
                  (Ljava/lang/Object;)D
                  examples/KafkaClientExamples.lambda$2(Ljava/lang/Long;)D (6)
                  (Ljava/lang/Long;)D
            invokeinterface java.util.stream.Stream.mapToDouble:(Ljava/util/function/ToDoubleFunction;)Ljava/util/stream/DoubleStream;
            invokeinterface java.util.stream.DoubleStream.average:()Ljava/util/OptionalDouble;
            areturn
        end local 0 // java.util.List list
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  list  Ljava/util/List<Ljava/lang/Long;>;
    Exceptions:
      throws java.lang.Exception

  private static void lambda$3(java.util.OptionalDouble);
    descriptor: (Ljava/util/OptionalDouble;)V
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=0, locals=1, args_size=1
        start local 0 // java.util.OptionalDouble val
         0: .line 40
            return
        end local 0 // java.util.OptionalDouble val
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0   val  Ljava/util/OptionalDouble;
    Exceptions:
      throws java.lang.Exception

  private static double lambda$2(java.lang.Long);
    descriptor: (Ljava/lang/Long;)D
    flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // java.lang.Long n
         0: .line 35
            aload 0 /* n */
            invokevirtual java.lang.Long.longValue:()J
            l2d
            dreturn
        end local 0 // java.lang.Long n
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0     n  Ljava/lang/Long;
}
SourceFile: "KafkaClientExamples.java"
InnerClasses:
  public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
    RuntimeInvisibleAnnotations: 
      io.vertx.docgen.Source()