public abstract class io.vertx.sqlclient.impl.RowDecoder<C, R>
minor version: 0
major version: 59
flags: flags: (0x0421) ACC_PUBLIC, ACC_SUPER, ACC_ABSTRACT
this_class: io.vertx.sqlclient.impl.RowDecoder
super_class: java.lang.Object
{
private final java.util.stream.Collector<io.vertx.sqlclient.Row, C, R> collector;
descriptor: Ljava/util/stream/Collector;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/stream/Collector<Lio/vertx/sqlclient/Row;TC;TR;>;
private java.util.function.BiConsumer<C, io.vertx.sqlclient.Row> accumulator;
descriptor: Ljava/util/function/BiConsumer;
flags: (0x0002) ACC_PRIVATE
Signature: Ljava/util/function/BiConsumer<TC;Lio/vertx/sqlclient/Row;>;
private int size;
descriptor: I
flags: (0x0002) ACC_PRIVATE
private C container;
descriptor: Ljava/lang/Object;
flags: (0x0002) ACC_PRIVATE
Signature: TC;
private java.lang.Throwable failure;
descriptor: Ljava/lang/Throwable;
flags: (0x0002) ACC_PRIVATE
private R result;
descriptor: Ljava/lang/Object;
flags: (0x0002) ACC_PRIVATE
Signature: TR;
protected void <init>(java.util.stream.Collector<io.vertx.sqlclient.Row, C, R>);
descriptor: (Ljava/util/stream/Collector;)V
flags: (0x0004) ACC_PROTECTED
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
aload 1
putfield io.vertx.sqlclient.impl.RowDecoder.collector:Ljava/util/stream/Collector;
2: aload 0
invokevirtual io.vertx.sqlclient.impl.RowDecoder.reset:()V
3: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/sqlclient/impl/RowDecoder<TC;TR;>;
0 4 1 collector Ljava/util/stream/Collector<Lio/vertx/sqlclient/Row;TC;TR;>;
Signature: (Ljava/util/stream/Collector<Lio/vertx/sqlclient/Row;TC;TR;>;)V
MethodParameters:
Name Flags
collector
public int size();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.sqlclient.impl.RowDecoder.size:I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/sqlclient/impl/RowDecoder<TC;TR;>;
protected abstract io.vertx.sqlclient.Row decodeRow(int, io.netty.buffer.ByteBuf);
descriptor: (ILio/netty/buffer/ByteBuf;)Lio/vertx/sqlclient/Row;
flags: (0x0404) ACC_PROTECTED, ACC_ABSTRACT
MethodParameters:
Name Flags
len
in
public void handleRow(int, io.netty.buffer.ByteBuf);
descriptor: (ILio/netty/buffer/ByteBuf;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=5, args_size=3
start local 0 start local 1 start local 2 0: aload 0
getfield io.vertx.sqlclient.impl.RowDecoder.failure:Ljava/lang/Throwable;
ifnull 2
1: return
2: StackMap locals:
StackMap stack:
aload 0
iload 1
aload 2
invokevirtual io.vertx.sqlclient.impl.RowDecoder.decodeRow:(ILio/netty/buffer/ByteBuf;)Lio/vertx/sqlclient/Row;
astore 3
start local 3 3: aload 0
getfield io.vertx.sqlclient.impl.RowDecoder.accumulator:Ljava/util/function/BiConsumer;
ifnonnull 9
4: aload 0
aload 0
getfield io.vertx.sqlclient.impl.RowDecoder.collector:Ljava/util/stream/Collector;
invokeinterface java.util.stream.Collector.accumulator:()Ljava/util/function/BiConsumer;
putfield io.vertx.sqlclient.impl.RowDecoder.accumulator:Ljava/util/function/BiConsumer;
5: goto 9
StackMap locals: io.vertx.sqlclient.impl.RowDecoder int io.netty.buffer.ByteBuf io.vertx.sqlclient.Row
StackMap stack: java.lang.Exception
6: astore 4
start local 4 7: aload 0
aload 4
putfield io.vertx.sqlclient.impl.RowDecoder.failure:Ljava/lang/Throwable;
8: return
end local 4 9: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.sqlclient.impl.RowDecoder.accumulator:Ljava/util/function/BiConsumer;
aload 0
getfield io.vertx.sqlclient.impl.RowDecoder.container:Ljava/lang/Object;
aload 3
invokeinterface java.util.function.BiConsumer.accept:(Ljava/lang/Object;Ljava/lang/Object;)V
10: goto 14
StackMap locals:
StackMap stack: java.lang.Exception
11: astore 4
start local 4 12: aload 0
aload 4
putfield io.vertx.sqlclient.impl.RowDecoder.failure:Ljava/lang/Throwable;
13: return
end local 4 14: StackMap locals:
StackMap stack:
aload 0
dup
getfield io.vertx.sqlclient.impl.RowDecoder.size:I
iconst_1
iadd
putfield io.vertx.sqlclient.impl.RowDecoder.size:I
15: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 16 0 this Lio/vertx/sqlclient/impl/RowDecoder<TC;TR;>;
0 16 1 len I
0 16 2 in Lio/netty/buffer/ByteBuf;
3 16 3 row Lio/vertx/sqlclient/Row;
7 9 4 e Ljava/lang/Exception;
12 14 4 e Ljava/lang/Exception;
Exception table:
from to target type
4 5 6 Class java.lang.Exception
9 10 11 Class java.lang.Exception
MethodParameters:
Name Flags
len
in
public R result();
descriptor: ()Ljava/lang/Object;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield io.vertx.sqlclient.impl.RowDecoder.result:Ljava/lang/Object;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lio/vertx/sqlclient/impl/RowDecoder<TC;TR;>;
Signature: ()TR;
public java.lang.Throwable complete();
descriptor: ()Ljava/lang/Throwable;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=1
start local 0 0: aload 0
aload 0
getfield io.vertx.sqlclient.impl.RowDecoder.collector:Ljava/util/stream/Collector;
invokeinterface java.util.stream.Collector.finisher:()Ljava/util/function/Function;
aload 0
getfield io.vertx.sqlclient.impl.RowDecoder.container:Ljava/lang/Object;
invokeinterface java.util.function.Function.apply:(Ljava/lang/Object;)Ljava/lang/Object;
putfield io.vertx.sqlclient.impl.RowDecoder.result:Ljava/lang/Object;
1: goto 4
StackMap locals:
StackMap stack: java.lang.Exception
2: astore 1
start local 1 3: aload 0
aload 1
putfield io.vertx.sqlclient.impl.RowDecoder.failure:Ljava/lang/Throwable;
end local 1 4: StackMap locals:
StackMap stack:
aload 0
getfield io.vertx.sqlclient.impl.RowDecoder.failure:Ljava/lang/Throwable;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lio/vertx/sqlclient/impl/RowDecoder<TC;TR;>;
3 4 1 e Ljava/lang/Exception;
Exception table:
from to target type
0 1 2 Class java.lang.Exception
public void reset();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
iconst_0
putfield io.vertx.sqlclient.impl.RowDecoder.size:I
1: aload 0
aconst_null
putfield io.vertx.sqlclient.impl.RowDecoder.failure:Ljava/lang/Throwable;
2: aload 0
aconst_null
putfield io.vertx.sqlclient.impl.RowDecoder.result:Ljava/lang/Object;
3: aload 0
aload 0
getfield io.vertx.sqlclient.impl.RowDecoder.collector:Ljava/util/stream/Collector;
invokeinterface java.util.stream.Collector.supplier:()Ljava/util/function/Supplier;
invokeinterface java.util.function.Supplier.get:()Ljava/lang/Object;
putfield io.vertx.sqlclient.impl.RowDecoder.container:Ljava/lang/Object;
4: goto 7
StackMap locals:
StackMap stack: java.lang.Exception
5: astore 1
start local 1 6: aload 0
aload 1
putfield io.vertx.sqlclient.impl.RowDecoder.failure:Ljava/lang/Throwable;
end local 1 7: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lio/vertx/sqlclient/impl/RowDecoder<TC;TR;>;
6 7 1 e Ljava/lang/Exception;
Exception table:
from to target type
3 4 5 Class java.lang.Exception
}
Signature: <C:Ljava/lang/Object;R:Ljava/lang/Object;>Ljava/lang/Object;
SourceFile: "RowDecoder.java"