final class reactor.core.publisher.SinksSpecs$RootSpecImpl implements reactor.core.publisher.Sinks$RootSpec, reactor.core.publisher.Sinks$ManySpec, reactor.core.publisher.Sinks$MulticastSpec, reactor.core.publisher.Sinks$MulticastReplaySpec
  minor version: 0
  major version: 59
  flags: flags: (0x0030) ACC_FINAL, ACC_SUPER
  this_class: reactor.core.publisher.SinksSpecs$RootSpecImpl
  super_class: java.lang.Object
{
  final boolean serialized;
    descriptor: Z
    flags: (0x0010) ACC_FINAL

  final reactor.core.publisher.Sinks$UnicastSpec unicastSpec;
    descriptor: Lreactor/core/publisher/Sinks$UnicastSpec;
    flags: (0x0010) ACC_FINAL

  void <init>(boolean);
    descriptor: (Z)V
    flags: (0x0000) 
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // reactor.core.publisher.SinksSpecs$RootSpecImpl this
        start local 1 // boolean serialized
         0: .line 56
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 57
            aload 0 /* this */
            iload 1 /* serialized */
            putfield reactor.core.publisher.SinksSpecs$RootSpecImpl.serialized:Z
         2: .line 59
            aload 0 /* this */
            new reactor.core.publisher.SinksSpecs$UnicastSpecImpl
            dup
            iload 1 /* serialized */
            invokespecial reactor.core.publisher.SinksSpecs$UnicastSpecImpl.<init>:(Z)V
            putfield reactor.core.publisher.SinksSpecs$RootSpecImpl.unicastSpec:Lreactor/core/publisher/Sinks$UnicastSpec;
         3: .line 60
            return
        end local 1 // boolean serialized
        end local 0 // reactor.core.publisher.SinksSpecs$RootSpecImpl this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    4     0        this  Lreactor/core/publisher/SinksSpecs$RootSpecImpl;
            0    4     1  serialized  Z
    MethodParameters:
            Name  Flags
      serialized  

  <T, EMPTY extends reactor.core.publisher.Sinks$Empty<T>, reactor.core.publisher.ContextHolder> reactor.core.publisher.Sinks$Empty<T> wrapEmpty(EMPTY);
    descriptor: (Lreactor/core/publisher/Sinks$Empty;)Lreactor/core/publisher/Sinks$Empty;
    flags: (0x0000) 
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // reactor.core.publisher.SinksSpecs$RootSpecImpl this
        start local 1 // reactor.core.publisher.Sinks$Empty original
         0: .line 63
            aload 0 /* this */
            getfield reactor.core.publisher.SinksSpecs$RootSpecImpl.serialized:Z
            ifeq 2
         1: .line 64
            new reactor.core.publisher.SinkEmptySerialized
            dup
            aload 1 /* original */
            aload 1 /* original */
            checkcast reactor.core.publisher.ContextHolder
            invokespecial reactor.core.publisher.SinkEmptySerialized.<init>:(Lreactor/core/publisher/Sinks$Empty;Lreactor/core/publisher/ContextHolder;)V
            areturn
         2: .line 66
      StackMap locals:
      StackMap stack:
            aload 1 /* original */
            areturn
        end local 1 // reactor.core.publisher.Sinks$Empty original
        end local 0 // reactor.core.publisher.SinksSpecs$RootSpecImpl this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    3     0      this  Lreactor/core/publisher/SinksSpecs$RootSpecImpl;
            0    3     1  original  TEMPTY;
    Signature: <T:Ljava/lang/Object;EMPTY::Lreactor/core/publisher/Sinks$Empty<TT;>;:Lreactor/core/publisher/ContextHolder;>(TEMPTY;)Lreactor/core/publisher/Sinks$Empty<TT;>;
    MethodParameters:
          Name  Flags
      original  

  <T, ONE extends reactor.core.publisher.Sinks$One<T>, reactor.core.publisher.ContextHolder> reactor.core.publisher.Sinks$One<T> wrapOne(ONE);
    descriptor: (Lreactor/core/publisher/Sinks$One;)Lreactor/core/publisher/Sinks$One;
    flags: (0x0000) 
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // reactor.core.publisher.SinksSpecs$RootSpecImpl this
        start local 1 // reactor.core.publisher.Sinks$One original
         0: .line 70
            aload 0 /* this */
            getfield reactor.core.publisher.SinksSpecs$RootSpecImpl.serialized:Z
            ifeq 2
         1: .line 71
            new reactor.core.publisher.SinkOneSerialized
            dup
            aload 1 /* original */
            aload 1 /* original */
            checkcast reactor.core.publisher.ContextHolder
            invokespecial reactor.core.publisher.SinkOneSerialized.<init>:(Lreactor/core/publisher/Sinks$One;Lreactor/core/publisher/ContextHolder;)V
            areturn
         2: .line 73
      StackMap locals:
      StackMap stack:
            aload 1 /* original */
            areturn
        end local 1 // reactor.core.publisher.Sinks$One original
        end local 0 // reactor.core.publisher.SinksSpecs$RootSpecImpl this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    3     0      this  Lreactor/core/publisher/SinksSpecs$RootSpecImpl;
            0    3     1  original  TONE;
    Signature: <T:Ljava/lang/Object;ONE::Lreactor/core/publisher/Sinks$One<TT;>;:Lreactor/core/publisher/ContextHolder;>(TONE;)Lreactor/core/publisher/Sinks$One<TT;>;
    MethodParameters:
          Name  Flags
      original  

  <T, MANY extends reactor.core.publisher.Sinks$Many<T>, reactor.core.publisher.ContextHolder> reactor.core.publisher.Sinks$Many<T> wrapMany(MANY);
    descriptor: (Lreactor/core/publisher/Sinks$Many;)Lreactor/core/publisher/Sinks$Many;
    flags: (0x0000) 
    Code:
      stack=4, locals=2, args_size=2
        start local 0 // reactor.core.publisher.SinksSpecs$RootSpecImpl this
        start local 1 // reactor.core.publisher.Sinks$Many original
         0: .line 77
            aload 0 /* this */
            getfield reactor.core.publisher.SinksSpecs$RootSpecImpl.serialized:Z
            ifeq 2
         1: .line 78
            new reactor.core.publisher.SinkManySerialized
            dup
            aload 1 /* original */
            aload 1 /* original */
            checkcast reactor.core.publisher.ContextHolder
            invokespecial reactor.core.publisher.SinkManySerialized.<init>:(Lreactor/core/publisher/Sinks$Many;Lreactor/core/publisher/ContextHolder;)V
            areturn
         2: .line 80
      StackMap locals:
      StackMap stack:
            aload 1 /* original */
            areturn
        end local 1 // reactor.core.publisher.Sinks$Many original
        end local 0 // reactor.core.publisher.SinksSpecs$RootSpecImpl this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    3     0      this  Lreactor/core/publisher/SinksSpecs$RootSpecImpl;
            0    3     1  original  TMANY;
    Signature: <T:Ljava/lang/Object;MANY::Lreactor/core/publisher/Sinks$Many<TT;>;:Lreactor/core/publisher/ContextHolder;>(TMANY;)Lreactor/core/publisher/Sinks$Many<TT;>;
    MethodParameters:
          Name  Flags
      original  

  public reactor.core.publisher.Sinks$ManySpec many();
    descriptor: ()Lreactor/core/publisher/Sinks$ManySpec;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // reactor.core.publisher.SinksSpecs$RootSpecImpl this
         0: .line 85
            aload 0 /* this */
            areturn
        end local 0 // reactor.core.publisher.SinksSpecs$RootSpecImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lreactor/core/publisher/SinksSpecs$RootSpecImpl;

  public <T> reactor.core.publisher.Sinks$Empty<T> empty();
    descriptor: ()Lreactor/core/publisher/Sinks$Empty;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=1, args_size=1
        start local 0 // reactor.core.publisher.SinksSpecs$RootSpecImpl this
         0: .line 90
            aload 0 /* this */
            new reactor.core.publisher.SinkEmptyMulticast
            dup
            invokespecial reactor.core.publisher.SinkEmptyMulticast.<init>:()V
            invokevirtual reactor.core.publisher.SinksSpecs$RootSpecImpl.wrapEmpty:(Lreactor/core/publisher/Sinks$Empty;)Lreactor/core/publisher/Sinks$Empty;
            areturn
        end local 0 // reactor.core.publisher.SinksSpecs$RootSpecImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lreactor/core/publisher/SinksSpecs$RootSpecImpl;
    Signature: <T:Ljava/lang/Object;>()Lreactor/core/publisher/Sinks$Empty<TT;>;

  public <T> reactor.core.publisher.Sinks$One<T> one();
    descriptor: ()Lreactor/core/publisher/Sinks$One;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=2, args_size=1
        start local 0 // reactor.core.publisher.SinksSpecs$RootSpecImpl this
         0: .line 95
            new reactor.core.publisher.NextProcessor
            dup
            aconst_null
            invokespecial reactor.core.publisher.NextProcessor.<init>:(Lreactor/core/CorePublisher;)V
            astore 1 /* original */
        start local 1 // reactor.core.publisher.NextProcessor original
         1: .line 96
            aload 0 /* this */
            aload 1 /* original */
            invokevirtual reactor.core.publisher.SinksSpecs$RootSpecImpl.wrapOne:(Lreactor/core/publisher/Sinks$One;)Lreactor/core/publisher/Sinks$One;
            areturn
        end local 1 // reactor.core.publisher.NextProcessor original
        end local 0 // reactor.core.publisher.SinksSpecs$RootSpecImpl this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    2     0      this  Lreactor/core/publisher/SinksSpecs$RootSpecImpl;
            1    2     1  original  Lreactor/core/publisher/NextProcessor<TT;>;
    Signature: <T:Ljava/lang/Object;>()Lreactor/core/publisher/Sinks$One<TT;>;

  public reactor.core.publisher.Sinks$UnicastSpec unicast();
    descriptor: ()Lreactor/core/publisher/Sinks$UnicastSpec;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // reactor.core.publisher.SinksSpecs$RootSpecImpl this
         0: .line 101
            aload 0 /* this */
            getfield reactor.core.publisher.SinksSpecs$RootSpecImpl.unicastSpec:Lreactor/core/publisher/Sinks$UnicastSpec;
            areturn
        end local 0 // reactor.core.publisher.SinksSpecs$RootSpecImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lreactor/core/publisher/SinksSpecs$RootSpecImpl;

  public reactor.core.publisher.Sinks$MulticastSpec multicast();
    descriptor: ()Lreactor/core/publisher/Sinks$MulticastSpec;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // reactor.core.publisher.SinksSpecs$RootSpecImpl this
         0: .line 106
            aload 0 /* this */
            areturn
        end local 0 // reactor.core.publisher.SinksSpecs$RootSpecImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lreactor/core/publisher/SinksSpecs$RootSpecImpl;

  public reactor.core.publisher.Sinks$MulticastReplaySpec replay();
    descriptor: ()Lreactor/core/publisher/Sinks$MulticastReplaySpec;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // reactor.core.publisher.SinksSpecs$RootSpecImpl this
         0: .line 111
            aload 0 /* this */
            areturn
        end local 0 // reactor.core.publisher.SinksSpecs$RootSpecImpl this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lreactor/core/publisher/SinksSpecs$RootSpecImpl;

  public <T> reactor.core.publisher.Sinks$Many<T> onBackpressureBuffer();
    descriptor: ()Lreactor/core/publisher/Sinks$Many;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // reactor.core.publisher.SinksSpecs$RootSpecImpl this
         0: .line 117
            invokestatic reactor.core.publisher.EmitterProcessor.create:()Lreactor/core/publisher/EmitterProcessor;
            astore 1 /* original */
        start local 1 // reactor.core.publisher.EmitterProcessor original
         1: .line 118
            aload 0 /* this */
            aload 1 /* original */
            invokevirtual reactor.core.publisher.SinksSpecs$RootSpecImpl.wrapMany:(Lreactor/core/publisher/Sinks$Many;)Lreactor/core/publisher/Sinks$Many;
            areturn
        end local 1 // reactor.core.publisher.EmitterProcessor original
        end local 0 // reactor.core.publisher.SinksSpecs$RootSpecImpl this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    2     0      this  Lreactor/core/publisher/SinksSpecs$RootSpecImpl;
            1    2     1  original  Lreactor/core/publisher/EmitterProcessor<TT;>;
    Signature: <T:Ljava/lang/Object;>()Lreactor/core/publisher/Sinks$Many<TT;>;

  public <T> reactor.core.publisher.Sinks$Many<T> onBackpressureBuffer(int);
    descriptor: (I)Lreactor/core/publisher/Sinks$Many;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // reactor.core.publisher.SinksSpecs$RootSpecImpl this
        start local 1 // int bufferSize
         0: .line 124
            iload 1 /* bufferSize */
            invokestatic reactor.core.publisher.EmitterProcessor.create:(I)Lreactor/core/publisher/EmitterProcessor;
            astore 2 /* original */
        start local 2 // reactor.core.publisher.EmitterProcessor original
         1: .line 125
            aload 0 /* this */
            aload 2 /* original */
            invokevirtual reactor.core.publisher.SinksSpecs$RootSpecImpl.wrapMany:(Lreactor/core/publisher/Sinks$Many;)Lreactor/core/publisher/Sinks$Many;
            areturn
        end local 2 // reactor.core.publisher.EmitterProcessor original
        end local 1 // int bufferSize
        end local 0 // reactor.core.publisher.SinksSpecs$RootSpecImpl this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    2     0        this  Lreactor/core/publisher/SinksSpecs$RootSpecImpl;
            0    2     1  bufferSize  I
            1    2     2    original  Lreactor/core/publisher/EmitterProcessor<TT;>;
    Signature: <T:Ljava/lang/Object;>(I)Lreactor/core/publisher/Sinks$Many<TT;>;
    MethodParameters:
            Name  Flags
      bufferSize  

  public <T> reactor.core.publisher.Sinks$Many<T> onBackpressureBuffer(int, boolean);
    descriptor: (IZ)Lreactor/core/publisher/Sinks$Many;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=4, args_size=3
        start local 0 // reactor.core.publisher.SinksSpecs$RootSpecImpl this
        start local 1 // int bufferSize
        start local 2 // boolean autoCancel
         0: .line 131
            iload 1 /* bufferSize */
            iload 2 /* autoCancel */
            invokestatic reactor.core.publisher.EmitterProcessor.create:(IZ)Lreactor/core/publisher/EmitterProcessor;
            astore 3 /* original */
        start local 3 // reactor.core.publisher.EmitterProcessor original
         1: .line 132
            aload 0 /* this */
            aload 3 /* original */
            invokevirtual reactor.core.publisher.SinksSpecs$RootSpecImpl.wrapMany:(Lreactor/core/publisher/Sinks$Many;)Lreactor/core/publisher/Sinks$Many;
            areturn
        end local 3 // reactor.core.publisher.EmitterProcessor original
        end local 2 // boolean autoCancel
        end local 1 // int bufferSize
        end local 0 // reactor.core.publisher.SinksSpecs$RootSpecImpl this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0    2     0        this  Lreactor/core/publisher/SinksSpecs$RootSpecImpl;
            0    2     1  bufferSize  I
            0    2     2  autoCancel  Z
            1    2     3    original  Lreactor/core/publisher/EmitterProcessor<TT;>;
    Signature: <T:Ljava/lang/Object;>(IZ)Lreactor/core/publisher/Sinks$Many<TT;>;
    MethodParameters:
            Name  Flags
      bufferSize  
      autoCancel  

  public <T> reactor.core.publisher.Sinks$Many<T> directAllOrNothing();
    descriptor: ()Lreactor/core/publisher/Sinks$Many;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // reactor.core.publisher.SinksSpecs$RootSpecImpl this
         0: .line 137
            invokestatic reactor.core.publisher.SinkManyBestEffort.createAllOrNothing:()Lreactor/core/publisher/SinkManyBestEffort;
            astore 1 /* original */
        start local 1 // reactor.core.publisher.SinkManyBestEffort original
         1: .line 138
            aload 0 /* this */
            aload 1 /* original */
            invokevirtual reactor.core.publisher.SinksSpecs$RootSpecImpl.wrapMany:(Lreactor/core/publisher/Sinks$Many;)Lreactor/core/publisher/Sinks$Many;
            areturn
        end local 1 // reactor.core.publisher.SinkManyBestEffort original
        end local 0 // reactor.core.publisher.SinksSpecs$RootSpecImpl this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    2     0      this  Lreactor/core/publisher/SinksSpecs$RootSpecImpl;
            1    2     1  original  Lreactor/core/publisher/SinkManyBestEffort<TT;>;
    Signature: <T:Ljava/lang/Object;>()Lreactor/core/publisher/Sinks$Many<TT;>;

  public <T> reactor.core.publisher.Sinks$Many<T> directBestEffort();
    descriptor: ()Lreactor/core/publisher/Sinks$Many;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // reactor.core.publisher.SinksSpecs$RootSpecImpl this
         0: .line 143
            invokestatic reactor.core.publisher.SinkManyBestEffort.createBestEffort:()Lreactor/core/publisher/SinkManyBestEffort;
            astore 1 /* original */
        start local 1 // reactor.core.publisher.SinkManyBestEffort original
         1: .line 144
            aload 0 /* this */
            aload 1 /* original */
            invokevirtual reactor.core.publisher.SinksSpecs$RootSpecImpl.wrapMany:(Lreactor/core/publisher/Sinks$Many;)Lreactor/core/publisher/Sinks$Many;
            areturn
        end local 1 // reactor.core.publisher.SinkManyBestEffort original
        end local 0 // reactor.core.publisher.SinksSpecs$RootSpecImpl this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    2     0      this  Lreactor/core/publisher/SinksSpecs$RootSpecImpl;
            1    2     1  original  Lreactor/core/publisher/SinkManyBestEffort<TT;>;
    Signature: <T:Ljava/lang/Object;>()Lreactor/core/publisher/Sinks$Many<TT;>;

  public <T> reactor.core.publisher.Sinks$Many<T> all();
    descriptor: ()Lreactor/core/publisher/Sinks$Many;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // reactor.core.publisher.SinksSpecs$RootSpecImpl this
         0: .line 151
            invokestatic reactor.core.publisher.ReplayProcessor.create:()Lreactor/core/publisher/ReplayProcessor;
            astore 1 /* original */
        start local 1 // reactor.core.publisher.ReplayProcessor original
         1: .line 152
            aload 0 /* this */
            aload 1 /* original */
            invokevirtual reactor.core.publisher.SinksSpecs$RootSpecImpl.wrapMany:(Lreactor/core/publisher/Sinks$Many;)Lreactor/core/publisher/Sinks$Many;
            areturn
        end local 1 // reactor.core.publisher.ReplayProcessor original
        end local 0 // reactor.core.publisher.SinksSpecs$RootSpecImpl this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    2     0      this  Lreactor/core/publisher/SinksSpecs$RootSpecImpl;
            1    2     1  original  Lreactor/core/publisher/ReplayProcessor<TT;>;
    Signature: <T:Ljava/lang/Object;>()Lreactor/core/publisher/Sinks$Many<TT;>;

  public <T> reactor.core.publisher.Sinks$Many<T> all(int);
    descriptor: (I)Lreactor/core/publisher/Sinks$Many;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // reactor.core.publisher.SinksSpecs$RootSpecImpl this
        start local 1 // int batchSize
         0: .line 158
            iload 1 /* batchSize */
            iconst_1
            invokestatic reactor.core.publisher.ReplayProcessor.create:(IZ)Lreactor/core/publisher/ReplayProcessor;
            astore 2 /* original */
        start local 2 // reactor.core.publisher.ReplayProcessor original
         1: .line 159
            aload 0 /* this */
            aload 2 /* original */
            invokevirtual reactor.core.publisher.SinksSpecs$RootSpecImpl.wrapMany:(Lreactor/core/publisher/Sinks$Many;)Lreactor/core/publisher/Sinks$Many;
            areturn
        end local 2 // reactor.core.publisher.ReplayProcessor original
        end local 1 // int batchSize
        end local 0 // reactor.core.publisher.SinksSpecs$RootSpecImpl this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    2     0       this  Lreactor/core/publisher/SinksSpecs$RootSpecImpl;
            0    2     1  batchSize  I
            1    2     2   original  Lreactor/core/publisher/ReplayProcessor<TT;>;
    Signature: <T:Ljava/lang/Object;>(I)Lreactor/core/publisher/Sinks$Many<TT;>;
    MethodParameters:
           Name  Flags
      batchSize  

  public <T> reactor.core.publisher.Sinks$Many<T> latest();
    descriptor: ()Lreactor/core/publisher/Sinks$Many;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=1
        start local 0 // reactor.core.publisher.SinksSpecs$RootSpecImpl this
         0: .line 165
            invokestatic reactor.core.publisher.ReplayProcessor.cacheLast:()Lreactor/core/publisher/ReplayProcessor;
            astore 1 /* original */
        start local 1 // reactor.core.publisher.ReplayProcessor original
         1: .line 166
            aload 0 /* this */
            aload 1 /* original */
            invokevirtual reactor.core.publisher.SinksSpecs$RootSpecImpl.wrapMany:(Lreactor/core/publisher/Sinks$Many;)Lreactor/core/publisher/Sinks$Many;
            areturn
        end local 1 // reactor.core.publisher.ReplayProcessor original
        end local 0 // reactor.core.publisher.SinksSpecs$RootSpecImpl this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    2     0      this  Lreactor/core/publisher/SinksSpecs$RootSpecImpl;
            1    2     1  original  Lreactor/core/publisher/ReplayProcessor<TT;>;
    Signature: <T:Ljava/lang/Object;>()Lreactor/core/publisher/Sinks$Many<TT;>;

  public <T> reactor.core.publisher.Sinks$Many<T> latestOrDefault(T);
    descriptor: (Ljava/lang/Object;)Lreactor/core/publisher/Sinks$Many;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // reactor.core.publisher.SinksSpecs$RootSpecImpl this
        start local 1 // java.lang.Object value
         0: .line 172
            aload 1 /* value */
            invokestatic reactor.core.publisher.ReplayProcessor.cacheLastOrDefault:(Ljava/lang/Object;)Lreactor/core/publisher/ReplayProcessor;
            astore 2 /* original */
        start local 2 // reactor.core.publisher.ReplayProcessor original
         1: .line 173
            aload 0 /* this */
            aload 2 /* original */
            invokevirtual reactor.core.publisher.SinksSpecs$RootSpecImpl.wrapMany:(Lreactor/core/publisher/Sinks$Many;)Lreactor/core/publisher/Sinks$Many;
            areturn
        end local 2 // reactor.core.publisher.ReplayProcessor original
        end local 1 // java.lang.Object value
        end local 0 // reactor.core.publisher.SinksSpecs$RootSpecImpl this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    2     0      this  Lreactor/core/publisher/SinksSpecs$RootSpecImpl;
            0    2     1     value  TT;
            1    2     2  original  Lreactor/core/publisher/ReplayProcessor<TT;>;
    Signature: <T:Ljava/lang/Object;>(TT;)Lreactor/core/publisher/Sinks$Many<TT;>;
    MethodParameters:
       Name  Flags
      value  

  public <T> reactor.core.publisher.Sinks$Many<T> limit(int);
    descriptor: (I)Lreactor/core/publisher/Sinks$Many;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // reactor.core.publisher.SinksSpecs$RootSpecImpl this
        start local 1 // int historySize
         0: .line 179
            iload 1 /* historySize */
            invokestatic reactor.core.publisher.ReplayProcessor.create:(I)Lreactor/core/publisher/ReplayProcessor;
            astore 2 /* original */
        start local 2 // reactor.core.publisher.ReplayProcessor original
         1: .line 180
            aload 0 /* this */
            aload 2 /* original */
            invokevirtual reactor.core.publisher.SinksSpecs$RootSpecImpl.wrapMany:(Lreactor/core/publisher/Sinks$Many;)Lreactor/core/publisher/Sinks$Many;
            areturn
        end local 2 // reactor.core.publisher.ReplayProcessor original
        end local 1 // int historySize
        end local 0 // reactor.core.publisher.SinksSpecs$RootSpecImpl this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    2     0         this  Lreactor/core/publisher/SinksSpecs$RootSpecImpl;
            0    2     1  historySize  I
            1    2     2     original  Lreactor/core/publisher/ReplayProcessor<TT;>;
    Signature: <T:Ljava/lang/Object;>(I)Lreactor/core/publisher/Sinks$Many<TT;>;
    MethodParameters:
             Name  Flags
      historySize  

  public <T> reactor.core.publisher.Sinks$Many<T> limit(java.time.Duration);
    descriptor: (Ljava/time/Duration;)Lreactor/core/publisher/Sinks$Many;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=3, args_size=2
        start local 0 // reactor.core.publisher.SinksSpecs$RootSpecImpl this
        start local 1 // java.time.Duration maxAge
         0: .line 186
            aload 1 /* maxAge */
            invokestatic reactor.core.publisher.ReplayProcessor.createTimeout:(Ljava/time/Duration;)Lreactor/core/publisher/ReplayProcessor;
            astore 2 /* original */
        start local 2 // reactor.core.publisher.ReplayProcessor original
         1: .line 187
            aload 0 /* this */
            aload 2 /* original */
            invokevirtual reactor.core.publisher.SinksSpecs$RootSpecImpl.wrapMany:(Lreactor/core/publisher/Sinks$Many;)Lreactor/core/publisher/Sinks$Many;
            areturn
        end local 2 // reactor.core.publisher.ReplayProcessor original
        end local 1 // java.time.Duration maxAge
        end local 0 // reactor.core.publisher.SinksSpecs$RootSpecImpl this
      LocalVariableTable:
        Start  End  Slot      Name  Signature
            0    2     0      this  Lreactor/core/publisher/SinksSpecs$RootSpecImpl;
            0    2     1    maxAge  Ljava/time/Duration;
            1    2     2  original  Lreactor/core/publisher/ReplayProcessor<TT;>;
    Signature: <T:Ljava/lang/Object;>(Ljava/time/Duration;)Lreactor/core/publisher/Sinks$Many<TT;>;
    MethodParameters:
        Name  Flags
      maxAge  

  public <T> reactor.core.publisher.Sinks$Many<T> limit(java.time.Duration, reactor.core.scheduler.Scheduler);
    descriptor: (Ljava/time/Duration;Lreactor/core/scheduler/Scheduler;)Lreactor/core/publisher/Sinks$Many;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=4, args_size=3
        start local 0 // reactor.core.publisher.SinksSpecs$RootSpecImpl this
        start local 1 // java.time.Duration maxAge
        start local 2 // reactor.core.scheduler.Scheduler scheduler
         0: .line 193
            aload 1 /* maxAge */
            aload 2 /* scheduler */
            invokestatic reactor.core.publisher.ReplayProcessor.createTimeout:(Ljava/time/Duration;Lreactor/core/scheduler/Scheduler;)Lreactor/core/publisher/ReplayProcessor;
            astore 3 /* original */
        start local 3 // reactor.core.publisher.ReplayProcessor original
         1: .line 194
            aload 0 /* this */
            aload 3 /* original */
            invokevirtual reactor.core.publisher.SinksSpecs$RootSpecImpl.wrapMany:(Lreactor/core/publisher/Sinks$Many;)Lreactor/core/publisher/Sinks$Many;
            areturn
        end local 3 // reactor.core.publisher.ReplayProcessor original
        end local 2 // reactor.core.scheduler.Scheduler scheduler
        end local 1 // java.time.Duration maxAge
        end local 0 // reactor.core.publisher.SinksSpecs$RootSpecImpl this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    2     0       this  Lreactor/core/publisher/SinksSpecs$RootSpecImpl;
            0    2     1     maxAge  Ljava/time/Duration;
            0    2     2  scheduler  Lreactor/core/scheduler/Scheduler;
            1    2     3   original  Lreactor/core/publisher/ReplayProcessor<TT;>;
    Signature: <T:Ljava/lang/Object;>(Ljava/time/Duration;Lreactor/core/scheduler/Scheduler;)Lreactor/core/publisher/Sinks$Many<TT;>;
    MethodParameters:
           Name  Flags
      maxAge     
      scheduler  

  public <T> reactor.core.publisher.Sinks$Many<T> limit(int, java.time.Duration);
    descriptor: (ILjava/time/Duration;)Lreactor/core/publisher/Sinks$Many;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=4, args_size=3
        start local 0 // reactor.core.publisher.SinksSpecs$RootSpecImpl this
        start local 1 // int historySize
        start local 2 // java.time.Duration maxAge
         0: .line 200
            iload 1 /* historySize */
            aload 2 /* maxAge */
            invokestatic reactor.core.publisher.ReplayProcessor.createSizeAndTimeout:(ILjava/time/Duration;)Lreactor/core/publisher/ReplayProcessor;
            astore 3 /* original */
        start local 3 // reactor.core.publisher.ReplayProcessor original
         1: .line 201
            aload 0 /* this */
            aload 3 /* original */
            invokevirtual reactor.core.publisher.SinksSpecs$RootSpecImpl.wrapMany:(Lreactor/core/publisher/Sinks$Many;)Lreactor/core/publisher/Sinks$Many;
            areturn
        end local 3 // reactor.core.publisher.ReplayProcessor original
        end local 2 // java.time.Duration maxAge
        end local 1 // int historySize
        end local 0 // reactor.core.publisher.SinksSpecs$RootSpecImpl this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    2     0         this  Lreactor/core/publisher/SinksSpecs$RootSpecImpl;
            0    2     1  historySize  I
            0    2     2       maxAge  Ljava/time/Duration;
            1    2     3     original  Lreactor/core/publisher/ReplayProcessor<TT;>;
    Signature: <T:Ljava/lang/Object;>(ILjava/time/Duration;)Lreactor/core/publisher/Sinks$Many<TT;>;
    MethodParameters:
             Name  Flags
      historySize  
      maxAge       

  public <T> reactor.core.publisher.Sinks$Many<T> limit(int, java.time.Duration, reactor.core.scheduler.Scheduler);
    descriptor: (ILjava/time/Duration;Lreactor/core/scheduler/Scheduler;)Lreactor/core/publisher/Sinks$Many;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=3, locals=5, args_size=4
        start local 0 // reactor.core.publisher.SinksSpecs$RootSpecImpl this
        start local 1 // int historySize
        start local 2 // java.time.Duration maxAge
        start local 3 // reactor.core.scheduler.Scheduler scheduler
         0: .line 207
            iload 1 /* historySize */
            aload 2 /* maxAge */
            aload 3 /* scheduler */
            invokestatic reactor.core.publisher.ReplayProcessor.createSizeAndTimeout:(ILjava/time/Duration;Lreactor/core/scheduler/Scheduler;)Lreactor/core/publisher/ReplayProcessor;
            astore 4 /* original */
        start local 4 // reactor.core.publisher.ReplayProcessor original
         1: .line 208
            aload 0 /* this */
            aload 4 /* original */
            invokevirtual reactor.core.publisher.SinksSpecs$RootSpecImpl.wrapMany:(Lreactor/core/publisher/Sinks$Many;)Lreactor/core/publisher/Sinks$Many;
            areturn
        end local 4 // reactor.core.publisher.ReplayProcessor original
        end local 3 // reactor.core.scheduler.Scheduler scheduler
        end local 2 // java.time.Duration maxAge
        end local 1 // int historySize
        end local 0 // reactor.core.publisher.SinksSpecs$RootSpecImpl this
      LocalVariableTable:
        Start  End  Slot         Name  Signature
            0    2     0         this  Lreactor/core/publisher/SinksSpecs$RootSpecImpl;
            0    2     1  historySize  I
            0    2     2       maxAge  Ljava/time/Duration;
            0    2     3    scheduler  Lreactor/core/scheduler/Scheduler;
            1    2     4     original  Lreactor/core/publisher/ReplayProcessor<TT;>;
    Signature: <T:Ljava/lang/Object;>(ILjava/time/Duration;Lreactor/core/scheduler/Scheduler;)Lreactor/core/publisher/Sinks$Many<TT;>;
    MethodParameters:
             Name  Flags
      historySize  
      maxAge       
      scheduler    
}
SourceFile: "SinksSpecs.java"
NestHost: reactor.core.publisher.SinksSpecs
InnerClasses:
  public abstract Empty = reactor.core.publisher.Sinks$Empty of reactor.core.publisher.Sinks
  public abstract Many = reactor.core.publisher.Sinks$Many of reactor.core.publisher.Sinks
  public abstract ManySpec = reactor.core.publisher.Sinks$ManySpec of reactor.core.publisher.Sinks
  public abstract MulticastReplaySpec = reactor.core.publisher.Sinks$MulticastReplaySpec of reactor.core.publisher.Sinks
  public abstract MulticastSpec = reactor.core.publisher.Sinks$MulticastSpec of reactor.core.publisher.Sinks
  public abstract One = reactor.core.publisher.Sinks$One of reactor.core.publisher.Sinks
  public abstract RootSpec = reactor.core.publisher.Sinks$RootSpec of reactor.core.publisher.Sinks
  public abstract UnicastSpec = reactor.core.publisher.Sinks$UnicastSpec of reactor.core.publisher.Sinks
  final RootSpecImpl = reactor.core.publisher.SinksSpecs$RootSpecImpl of reactor.core.publisher.SinksSpecs
  final UnicastSpecImpl = reactor.core.publisher.SinksSpecs$UnicastSpecImpl of reactor.core.publisher.SinksSpecs