abstract class reactor.core.publisher.FluxCreate$NoOverflowBaseAsyncSink<T> extends reactor.core.publisher.FluxCreate$BaseSink<T>
  minor version: 0
  major version: 59
  flags: flags: (0x0420) ACC_SUPER, ACC_ABSTRACT
  this_class: reactor.core.publisher.FluxCreate$NoOverflowBaseAsyncSink
  super_class: reactor.core.publisher.FluxCreate$BaseSink
{
  void <init>(reactor.core.CoreSubscriber<? super T>);
    descriptor: (Lreactor/core/CoreSubscriber;)V
    flags: (0x0000) 
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // reactor.core.publisher.FluxCreate$NoOverflowBaseAsyncSink this
        start local 1 // reactor.core.CoreSubscriber actual
         0: .line 637
            aload 0 /* this */
            aload 1 /* actual */
            invokespecial reactor.core.publisher.FluxCreate$BaseSink.<init>:(Lreactor/core/CoreSubscriber;)V
         1: .line 638
            return
        end local 1 // reactor.core.CoreSubscriber actual
        end local 0 // reactor.core.publisher.FluxCreate$NoOverflowBaseAsyncSink this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    2     0    this  Lreactor/core/publisher/FluxCreate$NoOverflowBaseAsyncSink<TT;>;
            0    2     1  actual  Lreactor/core/CoreSubscriber<-TT;>;
    Signature: (Lreactor/core/CoreSubscriber<-TT;>;)V
    MethodParameters:
        Name  Flags
      actual  

  public final reactor.core.publisher.FluxSink<T> next(T);
    descriptor: (Ljava/lang/Object;)Lreactor/core/publisher/FluxSink;
    flags: (0x0011) ACC_PUBLIC, ACC_FINAL
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // reactor.core.publisher.FluxCreate$NoOverflowBaseAsyncSink this
        start local 1 // java.lang.Object t
         0: .line 642
            aload 0 /* this */
            invokevirtual reactor.core.publisher.FluxCreate$NoOverflowBaseAsyncSink.isTerminated:()Z
            ifeq 3
         1: .line 643
            aload 1 /* t */
            aload 0 /* this */
            getfield reactor.core.publisher.FluxCreate$NoOverflowBaseAsyncSink.ctx:Lreactor/util/context/Context;
            invokestatic reactor.core.publisher.Operators.onNextDropped:(Ljava/lang/Object;Lreactor/util/context/Context;)V
         2: .line 644
            aload 0 /* this */
            areturn
         3: .line 647
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield reactor.core.publisher.FluxCreate$NoOverflowBaseAsyncSink.requested:J
            lconst_0
            lcmp
            ifeq 7
         4: .line 648
            aload 0 /* this */
            getfield reactor.core.publisher.FluxCreate$NoOverflowBaseAsyncSink.actual:Lreactor/core/CoreSubscriber;
            aload 1 /* t */
            invokeinterface reactor.core.CoreSubscriber.onNext:(Ljava/lang/Object;)V
         5: .line 649
            getstatic reactor.core.publisher.FluxCreate$NoOverflowBaseAsyncSink.REQUESTED:Ljava/util/concurrent/atomic/AtomicLongFieldUpdater;
            aload 0 /* this */
            lconst_1
            invokestatic reactor.core.publisher.Operators.produced:(Ljava/util/concurrent/atomic/AtomicLongFieldUpdater;Ljava/lang/Object;J)J
            pop2
         6: .line 650
            goto 9
         7: .line 652
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            invokevirtual reactor.core.publisher.FluxCreate$NoOverflowBaseAsyncSink.onOverflow:()V
         8: .line 653
            aload 1 /* t */
            aload 0 /* this */
            getfield reactor.core.publisher.FluxCreate$NoOverflowBaseAsyncSink.ctx:Lreactor/util/context/Context;
            invokestatic reactor.core.publisher.Operators.onDiscard:(Ljava/lang/Object;Lreactor/util/context/Context;)V
         9: .line 655
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            areturn
        end local 1 // java.lang.Object t
        end local 0 // reactor.core.publisher.FluxCreate$NoOverflowBaseAsyncSink this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0   10     0  this  Lreactor/core/publisher/FluxCreate$NoOverflowBaseAsyncSink<TT;>;
            0   10     1     t  TT;
    Signature: (TT;)Lreactor/core/publisher/FluxSink<TT;>;
    MethodParameters:
      Name  Flags
      t     

  abstract void onOverflow();
    descriptor: ()V
    flags: (0x0400) ACC_ABSTRACT
}
Signature: <T:Ljava/lang/Object;>Lreactor/core/publisher/FluxCreate$BaseSink<TT;>;
SourceFile: "FluxCreate.java"
NestHost: reactor.core.publisher.FluxCreate
InnerClasses:
  abstract BaseSink = reactor.core.publisher.FluxCreate$BaseSink of reactor.core.publisher.FluxCreate
  abstract NoOverflowBaseAsyncSink = reactor.core.publisher.FluxCreate$NoOverflowBaseAsyncSink of reactor.core.publisher.FluxCreate