final class org.springframework.transaction.reactive.TransactionalOperatorImpl implements org.springframework.transaction.reactive.TransactionalOperator
  minor version: 0
  major version: 59
  flags: flags: (0x0030) ACC_FINAL, ACC_SUPER
  this_class: org.springframework.transaction.reactive.TransactionalOperatorImpl
  super_class: java.lang.Object
{
  private static final org.apache.commons.logging.Log logger;
    descriptor: Lorg/apache/commons/logging/Log;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL

  private final org.springframework.transaction.ReactiveTransactionManager transactionManager;
    descriptor: Lorg/springframework/transaction/ReactiveTransactionManager;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  private final org.springframework.transaction.TransactionDefinition transactionDefinition;
    descriptor: Lorg/springframework/transaction/TransactionDefinition;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  static void <clinit>();
    descriptor: ()V
    flags: (0x0008) ACC_STATIC
    Code:
      stack=1, locals=0, args_size=0
         0: .line 44
            ldc Lorg/springframework/transaction/reactive/TransactionalOperatorImpl;
            invokestatic org.apache.commons.logging.LogFactory.getLog:(Ljava/lang/Class;)Lorg/apache/commons/logging/Log;
            putstatic org.springframework.transaction.reactive.TransactionalOperatorImpl.logger:Lorg/apache/commons/logging/Log;
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  void <init>(org.springframework.transaction.ReactiveTransactionManager, org.springframework.transaction.TransactionDefinition);
    descriptor: (Lorg/springframework/transaction/ReactiveTransactionManager;Lorg/springframework/transaction/TransactionDefinition;)V
    flags: (0x0000) 
    Code:
      stack=2, locals=3, args_size=3
        start local 0 // org.springframework.transaction.reactive.TransactionalOperatorImpl this
        start local 1 // org.springframework.transaction.ReactiveTransactionManager transactionManager
        start local 2 // org.springframework.transaction.TransactionDefinition transactionDefinition
         0: .line 58
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 59
            aload 1 /* transactionManager */
            ldc "ReactiveTransactionManager must not be null"
            invokestatic org.springframework.util.Assert.notNull:(Ljava/lang/Object;Ljava/lang/String;)V
         2: .line 60
            aload 1 /* transactionManager */
            ldc "TransactionDefinition must not be null"
            invokestatic org.springframework.util.Assert.notNull:(Ljava/lang/Object;Ljava/lang/String;)V
         3: .line 61
            aload 0 /* this */
            aload 1 /* transactionManager */
            putfield org.springframework.transaction.reactive.TransactionalOperatorImpl.transactionManager:Lorg/springframework/transaction/ReactiveTransactionManager;
         4: .line 62
            aload 0 /* this */
            aload 2 /* transactionDefinition */
            putfield org.springframework.transaction.reactive.TransactionalOperatorImpl.transactionDefinition:Lorg/springframework/transaction/TransactionDefinition;
         5: .line 63
            return
        end local 2 // org.springframework.transaction.TransactionDefinition transactionDefinition
        end local 1 // org.springframework.transaction.ReactiveTransactionManager transactionManager
        end local 0 // org.springframework.transaction.reactive.TransactionalOperatorImpl this
      LocalVariableTable:
        Start  End  Slot                   Name  Signature
            0    6     0                   this  Lorg/springframework/transaction/reactive/TransactionalOperatorImpl;
            0    6     1     transactionManager  Lorg/springframework/transaction/ReactiveTransactionManager;
            0    6     2  transactionDefinition  Lorg/springframework/transaction/TransactionDefinition;
    MethodParameters:
                       Name  Flags
      transactionManager     
      transactionDefinition  

  public org.springframework.transaction.ReactiveTransactionManager getTransactionManager();
    descriptor: ()Lorg/springframework/transaction/ReactiveTransactionManager;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.springframework.transaction.reactive.TransactionalOperatorImpl this
         0: .line 70
            aload 0 /* this */
            getfield org.springframework.transaction.reactive.TransactionalOperatorImpl.transactionManager:Lorg/springframework/transaction/ReactiveTransactionManager;
            areturn
        end local 0 // org.springframework.transaction.reactive.TransactionalOperatorImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/springframework/transaction/reactive/TransactionalOperatorImpl;

  public <T> Mono<T> transactional(Mono<T>);
    descriptor: (LMono;)LMono;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // org.springframework.transaction.reactive.TransactionalOperatorImpl this
         0: .line 74
            new java.lang.Error
            dup
            ldc "Unresolved compilation problems: \n\tMono cannot be resolved to a type\n\tMono cannot be resolved to a type\n\tThe method currentContext() from the type TransactionContextManager refers to the missing type Mono\n\tThe method getOrCreateContext() from the type TransactionContextManager refers to the missing type Context\n\tThe method getOrCreateContextHolder() from the type TransactionContextManager refers to the missing type Context\n"
            invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
            athrow
        end local 0 // org.springframework.transaction.reactive.TransactionalOperatorImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/springframework/transaction/reactive/TransactionalOperatorImpl;
    Signature: <T:Ljava/lang/Object;>(LMono<TT;>;)LMono<TT;>;
    MethodParameters:
      Name  Flags
      mono  

  public <T> Flux<T> execute(org.springframework.transaction.reactive.TransactionCallback<T>);
    descriptor: (Lorg/springframework/transaction/reactive/TransactionCallback;)LFlux;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=2
        start local 0 // org.springframework.transaction.reactive.TransactionalOperatorImpl this
         0: .line 90
            new java.lang.Error
            dup
            ldc "Unresolved compilation problems: \n\tFlux cannot be resolved to a type\n\tThe method currentContext() from the type TransactionContextManager refers to the missing type Mono\n\tThe method getOrCreateContext() from the type TransactionContextManager refers to the missing type Context\n\tThe method getOrCreateContextHolder() from the type TransactionContextManager refers to the missing type Context\n"
            invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
            athrow
        end local 0 // org.springframework.transaction.reactive.TransactionalOperatorImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/springframework/transaction/reactive/TransactionalOperatorImpl;
    Exceptions:
      throws org.springframework.transaction.TransactionException
    Signature: <T:Ljava/lang/Object;>(Lorg/springframework/transaction/reactive/TransactionCallback<TT;>;)LFlux<TT;>;
    MethodParameters:
        Name  Flags
      action  

  private Mono<java.lang.Void> rollbackOnException(org.springframework.transaction.ReactiveTransaction, java.lang.Throwable);
    descriptor: (Lorg/springframework/transaction/ReactiveTransaction;Ljava/lang/Throwable;)LMono;
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=3, locals=3, args_size=3
        start local 0 // org.springframework.transaction.reactive.TransactionalOperatorImpl this
         0: .line 117
            new java.lang.Error
            dup
            ldc "Unresolved compilation problems: \n\tMono cannot be resolved to a type\n\tThe method rollback(ReactiveTransaction) from the type ReactiveTransactionManager refers to the missing type Mono\n"
            invokespecial java.lang.Error.<init>:(Ljava/lang/String;)V
            athrow
        end local 0 // org.springframework.transaction.reactive.TransactionalOperatorImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/springframework/transaction/reactive/TransactionalOperatorImpl;
    Exceptions:
      throws org.springframework.transaction.TransactionException
    Signature: (Lorg/springframework/transaction/ReactiveTransaction;Ljava/lang/Throwable;)LMono<Ljava/lang/Void;>;
    MethodParameters:
        Name  Flags
      status  
      ex      

  public boolean equals(java.lang.Object);
    descriptor: (Ljava/lang/Object;)Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // org.springframework.transaction.reactive.TransactionalOperatorImpl this
        start local 1 // java.lang.Object other
         0: .line 132
            aload 0 /* this */
            aload 1 /* other */
            if_acmpeq 3
            aload 0 /* this */
            aload 1 /* other */
            invokespecial java.lang.Object.equals:(Ljava/lang/Object;)Z
            ifeq 2
            aload 1 /* other */
            instanceof org.springframework.transaction.reactive.TransactionalOperatorImpl
            ifeq 3
         1: .line 133
            aload 0 /* this */
            invokevirtual org.springframework.transaction.reactive.TransactionalOperatorImpl.getTransactionManager:()Lorg/springframework/transaction/ReactiveTransactionManager;
            aload 1 /* other */
            checkcast org.springframework.transaction.reactive.TransactionalOperatorImpl
            invokevirtual org.springframework.transaction.reactive.TransactionalOperatorImpl.getTransactionManager:()Lorg/springframework/transaction/ReactiveTransactionManager;
            if_acmpeq 3
         2: .line 132
      StackMap locals:
      StackMap stack:
            iconst_0
            ireturn
      StackMap locals:
      StackMap stack:
         3: iconst_1
            ireturn
        end local 1 // java.lang.Object other
        end local 0 // org.springframework.transaction.reactive.TransactionalOperatorImpl this
      LocalVariableTable:
        Start  End  Slot   Name  Signature
            0    4     0   this  Lorg/springframework/transaction/reactive/TransactionalOperatorImpl;
            0    4     1  other  Ljava/lang/Object;
    RuntimeVisibleParameterAnnotations: 
      0:
        org.springframework.lang.Nullable()
    MethodParameters:
       Name  Flags
      other  

  public int hashCode();
    descriptor: ()I
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.springframework.transaction.reactive.TransactionalOperatorImpl this
         0: .line 138
            aload 0 /* this */
            invokevirtual org.springframework.transaction.reactive.TransactionalOperatorImpl.getTransactionManager:()Lorg/springframework/transaction/ReactiveTransactionManager;
            invokevirtual java.lang.Object.hashCode:()I
            ireturn
        end local 0 // org.springframework.transaction.reactive.TransactionalOperatorImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lorg/springframework/transaction/reactive/TransactionalOperatorImpl;

  public Flux execute(org.springframework.transaction.reactive.TransactionCallback);
    descriptor: (Lorg/springframework/transaction/reactive/TransactionCallback;)LFlux;
    flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
    Code:
      stack=2, locals=2, args_size=2
         0: .line 1
            aload 0
            aload 1
            checkcast org.springframework.transaction.reactive.TransactionCallback
            invokevirtual org.springframework.transaction.reactive.TransactionalOperatorImpl.execute:(Lorg/springframework/transaction/reactive/TransactionCallback;)LFlux;
            checkcast Flux
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    Exceptions:
      throws org.springframework.transaction.TransactionException
}
SourceFile: "TransactionalOperatorImpl.java"