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