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 0: aload 0
invokespecial java.lang.Object.<init>:()V
return
end local 0 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 start local 1 0: aload 1
invokevirtual io.vertx.reactivex.kafka.client.consumer.KafkaConsumer.toObservable:()Lio/reactivex/Observable;
astore 2
start local 2 1: aload 2
2: 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: sipush 256
invokevirtual io.reactivex.Observable.buffer:(I)Lio/reactivex/Observable;
4: 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: invokevirtual io.reactivex.Observable.map:(Lio/reactivex/functions/Function;)Lio/reactivex/Observable;
6: 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: return
end local 2 end local 1 end local 0 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 0: aload 0
invokevirtual io.vertx.reactivex.kafka.client.consumer.KafkaConsumerRecord.value:()Ljava/lang/Object;
checkcast java.lang.Long
areturn
end local 0 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 0: aload 0
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 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 0: return
end local 0 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 0: aload 0
invokevirtual java.lang.Long.longValue:()J
l2d
dreturn
end local 0 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()