public class io.vertx.rxjava.ext.sql.impl.InTransactionCompletable implements rx.Completable$Transformer
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: io.vertx.rxjava.ext.sql.impl.InTransactionCompletable
super_class: java.lang.Object
{
private final io.vertx.rxjava.ext.sql.SQLConnection sqlConnection;
descriptor: Lio/vertx/rxjava/ext/sql/SQLConnection;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
public void <init>(io.vertx.rxjava.ext.sql.SQLConnection);
descriptor: (Lio/vertx/rxjava/ext/sql/SQLConnection;)V
flags: (0x0001) ACC_PUBLIC
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.rxjava.ext.sql.impl.InTransactionCompletable.sqlConnection:Lio/vertx/rxjava/ext/sql/SQLConnection;
2: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/rxjava/ext/sql/impl/InTransactionCompletable;
0 3 1 sqlConnection Lio/vertx/rxjava/ext/sql/SQLConnection;
MethodParameters:
Name Flags
sqlConnection
public rx.Completable call(rx.Completable);
descriptor: (Lrx/Completable;)Lrx/Completable;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.rxjava.ext.sql.impl.InTransactionCompletable.sqlConnection:Lio/vertx/rxjava/ext/sql/SQLConnection;
iconst_0
invokevirtual io.vertx.rxjava.ext.sql.SQLConnection.rxSetAutoCommit:(Z)Lrx/Single;
invokevirtual rx.Single.toCompletable:()Lrx/Completable;
1: aload 1
invokevirtual rx.Completable.andThen:(Lrx/Completable;)Lrx/Completable;
2: aload 0
getfield io.vertx.rxjava.ext.sql.impl.InTransactionCompletable.sqlConnection:Lio/vertx/rxjava/ext/sql/SQLConnection;
invokevirtual io.vertx.rxjava.ext.sql.SQLConnection.rxCommit:()Lrx/Single;
invokevirtual rx.Single.toCompletable:()Lrx/Completable;
invokevirtual rx.Completable.andThen:(Lrx/Completable;)Lrx/Completable;
3: aload 0
invokedynamic call(Lio/vertx/rxjava/ext/sql/impl/InTransactionCompletable;)Lrx/functions/Func1;
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;
io/vertx/rxjava/ext/sql/impl/InTransactionCompletable.lambda$0(Ljava/lang/Throwable;)Lrx/Completable; (7)
(Ljava/lang/Throwable;)Lrx/Completable;
invokevirtual rx.Completable.onErrorResumeNext:(Lrx/functions/Func1;)Lrx/Completable;
4: aload 0
getfield io.vertx.rxjava.ext.sql.impl.InTransactionCompletable.sqlConnection:Lio/vertx/rxjava/ext/sql/SQLConnection;
iconst_1
invokevirtual io.vertx.rxjava.ext.sql.SQLConnection.rxSetAutoCommit:(Z)Lrx/Single;
invokevirtual rx.Single.toCompletable:()Lrx/Completable;
invokevirtual rx.Completable.andThen:(Lrx/Completable;)Lrx/Completable;
5: areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/vertx/rxjava/ext/sql/impl/InTransactionCompletable;
0 6 1 upstream Lrx/Completable;
MethodParameters:
Name Flags
upstream
public java.lang.Object call(java.lang.Object);
descriptor: (Ljava/lang/Object;)Ljava/lang/Object;
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
checkcast rx.Completable
invokevirtual io.vertx.rxjava.ext.sql.impl.InTransactionCompletable.call:(Lrx/Completable;)Lrx/Completable;
areturn
LocalVariableTable:
Start End Slot Name Signature
private rx.Completable lambda$0(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)Lrx/Completable;
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.rxjava.ext.sql.impl.InTransactionCompletable.sqlConnection:Lio/vertx/rxjava/ext/sql/SQLConnection;
invokevirtual io.vertx.rxjava.ext.sql.SQLConnection.rxRollback:()Lrx/Single;
invokevirtual rx.Single.toCompletable:()Lrx/Completable;
invokevirtual rx.Completable.onErrorComplete:()Lrx/Completable;
1: aload 0
getfield io.vertx.rxjava.ext.sql.impl.InTransactionCompletable.sqlConnection:Lio/vertx/rxjava/ext/sql/SQLConnection;
iconst_1
invokevirtual io.vertx.rxjava.ext.sql.SQLConnection.rxSetAutoCommit:(Z)Lrx/Single;
invokevirtual rx.Single.toCompletable:()Lrx/Completable;
invokevirtual rx.Completable.onErrorComplete:()Lrx/Completable;
invokevirtual rx.Completable.andThen:(Lrx/Completable;)Lrx/Completable;
2: aload 1
invokestatic rx.Completable.error:(Ljava/lang/Throwable;)Lrx/Completable;
invokevirtual rx.Completable.andThen:(Lrx/Completable;)Lrx/Completable;
3: areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/rxjava/ext/sql/impl/InTransactionCompletable;
0 4 1 throwable Ljava/lang/Throwable;
}
SourceFile: "InTransactionCompletable.java"
InnerClasses:
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
public abstract Transformer = rx.Completable$Transformer of rx.Completable