class org.springframework.http.codec.xml.XmlEventDecoder$AaltoDataBufferToXmlEvent implements java.util.function.Function<org.springframework.core.io.buffer.DataBuffer, org.reactivestreams.Publisher<? extends javax.xml.stream.events.XMLEvent>>
  minor version: 0
  major version: 59
  flags: flags: (0x0020) ACC_SUPER
  this_class: org.springframework.http.codec.xml.XmlEventDecoder$AaltoDataBufferToXmlEvent
  super_class: java.lang.Object
{
  private static final com.fasterxml.aalto.AsyncXMLInputFactory inputFactory;
    descriptor: Lcom/fasterxml/aalto/AsyncXMLInputFactory;
    flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL

  private final com.fasterxml.aalto.AsyncXMLStreamReader<com.fasterxml.aalto.AsyncByteBufferFeeder> streamReader;
    descriptor: Lcom/fasterxml/aalto/AsyncXMLStreamReader;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL
    Signature: Lcom/fasterxml/aalto/AsyncXMLStreamReader<Lcom/fasterxml/aalto/AsyncByteBufferFeeder;>;

  private final javax.xml.stream.util.XMLEventAllocator eventAllocator;
    descriptor: Ljavax/xml/stream/util/XMLEventAllocator;
    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 131
            invokedynamic get()Ljava/util/function/Supplier;
              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;
                  com/fasterxml/aalto/stax/InputFactoryImpl.<init>()V (8)
                  ()Lcom/fasterxml/aalto/stax/InputFactoryImpl;
            invokestatic org.springframework.util.xml.StaxUtils.createDefensiveInputFactory:(Ljava/util/function/Supplier;)Ljavax/xml/stream/XMLInputFactory;
            checkcast com.fasterxml.aalto.AsyncXMLInputFactory
         1: .line 130
            putstatic org.springframework.http.codec.xml.XmlEventDecoder$AaltoDataBufferToXmlEvent.inputFactory:Lcom/fasterxml/aalto/AsyncXMLInputFactory;
         2: .line 131
            return
      LocalVariableTable:
        Start  End  Slot  Name  Signature

  private void <init>();
    descriptor: ()V
    flags: (0x0002) ACC_PRIVATE
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // org.springframework.http.codec.xml.XmlEventDecoder$AaltoDataBufferToXmlEvent this
         0: .line 128
            aload 0 /* this */
            invokespecial java.lang.Object.<init>:()V
         1: .line 133
            aload 0 /* this */
         2: .line 134
            getstatic org.springframework.http.codec.xml.XmlEventDecoder$AaltoDataBufferToXmlEvent.inputFactory:Lcom/fasterxml/aalto/AsyncXMLInputFactory;
            invokevirtual com.fasterxml.aalto.AsyncXMLInputFactory.createAsyncForByteBuffer:()Lcom/fasterxml/aalto/AsyncXMLStreamReader;
            putfield org.springframework.http.codec.xml.XmlEventDecoder$AaltoDataBufferToXmlEvent.streamReader:Lcom/fasterxml/aalto/AsyncXMLStreamReader;
         3: .line 136
            aload 0 /* this */
            invokestatic com.fasterxml.aalto.evt.EventAllocatorImpl.getDefaultInstance:()Lcom/fasterxml/aalto/evt/EventAllocatorImpl;
            putfield org.springframework.http.codec.xml.XmlEventDecoder$AaltoDataBufferToXmlEvent.eventAllocator:Ljavax/xml/stream/util/XMLEventAllocator;
         4: .line 128
            return
        end local 0 // org.springframework.http.codec.xml.XmlEventDecoder$AaltoDataBufferToXmlEvent this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    5     0  this  Lorg/springframework/http/codec/xml/XmlEventDecoder$AaltoDataBufferToXmlEvent;

  public org.reactivestreams.Publisher<? extends javax.xml.stream.events.XMLEvent> apply(org.springframework.core.io.buffer.DataBuffer);
    descriptor: (Lorg/springframework/core/io/buffer/DataBuffer;)Lorg/reactivestreams/Publisher;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=6, args_size=2
        start local 0 // org.springframework.http.codec.xml.XmlEventDecoder$AaltoDataBufferToXmlEvent this
        start local 1 // org.springframework.core.io.buffer.DataBuffer dataBuffer
         0: .line 142
            aload 0 /* this */
            getfield org.springframework.http.codec.xml.XmlEventDecoder$AaltoDataBufferToXmlEvent.streamReader:Lcom/fasterxml/aalto/AsyncXMLStreamReader;
            invokeinterface com.fasterxml.aalto.AsyncXMLStreamReader.getInputFeeder:()Lcom/fasterxml/aalto/AsyncInputFeeder;
            checkcast com.fasterxml.aalto.AsyncByteBufferFeeder
            aload 1 /* dataBuffer */
            invokeinterface org.springframework.core.io.buffer.DataBuffer.asByteBuffer:()Ljava/nio/ByteBuffer;
            invokeinterface com.fasterxml.aalto.AsyncByteBufferFeeder.feedInput:(Ljava/nio/ByteBuffer;)V
         1: .line 143
            new java.util.ArrayList
            dup
            invokespecial java.util.ArrayList.<init>:()V
            astore 2 /* events */
        start local 2 // java.util.List events
         2: .line 145
      StackMap locals: java.util.List
      StackMap stack:
            aload 0 /* this */
            getfield org.springframework.http.codec.xml.XmlEventDecoder$AaltoDataBufferToXmlEvent.streamReader:Lcom/fasterxml/aalto/AsyncXMLStreamReader;
            invokeinterface com.fasterxml.aalto.AsyncXMLStreamReader.next:()I
            sipush 257
            if_icmpne 4
         3: .line 147
            goto 7
         4: .line 150
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield org.springframework.http.codec.xml.XmlEventDecoder$AaltoDataBufferToXmlEvent.eventAllocator:Ljavax/xml/stream/util/XMLEventAllocator;
            aload 0 /* this */
            getfield org.springframework.http.codec.xml.XmlEventDecoder$AaltoDataBufferToXmlEvent.streamReader:Lcom/fasterxml/aalto/AsyncXMLStreamReader;
            invokeinterface javax.xml.stream.util.XMLEventAllocator.allocate:(Ljavax/xml/stream/XMLStreamReader;)Ljavax/xml/stream/events/XMLEvent;
            astore 3 /* event */
        start local 3 // javax.xml.stream.events.XMLEvent event
         5: .line 151
            aload 2 /* events */
            aload 3 /* event */
            invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
            pop
         6: .line 152
            aload 3 /* event */
            invokeinterface javax.xml.stream.events.XMLEvent.isEndDocument:()Z
            ifeq 2
        end local 3 // javax.xml.stream.events.XMLEvent event
         7: .line 157
      StackMap locals:
      StackMap stack:
            aload 2 /* events */
            invokestatic reactor.core.publisher.Flux.fromIterable:(Ljava/lang/Iterable;)Lreactor/core/publisher/Flux;
            astore 5
         8: .line 163
            aload 1 /* dataBuffer */
            invokestatic org.springframework.core.io.buffer.DataBufferUtils.release:(Lorg/springframework/core/io/buffer/DataBuffer;)Z
            pop
         9: .line 157
            aload 5
            areturn
        end local 2 // java.util.List events
        10: .line 159
      StackMap locals: org.springframework.http.codec.xml.XmlEventDecoder$AaltoDataBufferToXmlEvent org.springframework.core.io.buffer.DataBuffer
      StackMap stack: javax.xml.stream.XMLStreamException
            astore 2 /* ex */
        start local 2 // javax.xml.stream.XMLStreamException ex
        11: .line 160
            aload 2 /* ex */
            invokestatic reactor.core.publisher.Mono.error:(Ljava/lang/Throwable;)Lreactor/core/publisher/Mono;
            astore 5
        12: .line 163
            aload 1 /* dataBuffer */
            invokestatic org.springframework.core.io.buffer.DataBufferUtils.release:(Lorg/springframework/core/io/buffer/DataBuffer;)Z
            pop
        13: .line 160
            aload 5
            areturn
        end local 2 // javax.xml.stream.XMLStreamException ex
        14: .line 162
      StackMap locals:
      StackMap stack: java.lang.Throwable
            astore 4
        15: .line 163
            aload 1 /* dataBuffer */
            invokestatic org.springframework.core.io.buffer.DataBufferUtils.release:(Lorg/springframework/core/io/buffer/DataBuffer;)Z
            pop
        16: .line 164
            aload 4
            athrow
        end local 1 // org.springframework.core.io.buffer.DataBuffer dataBuffer
        end local 0 // org.springframework.http.codec.xml.XmlEventDecoder$AaltoDataBufferToXmlEvent this
      LocalVariableTable:
        Start  End  Slot        Name  Signature
            0   17     0        this  Lorg/springframework/http/codec/xml/XmlEventDecoder$AaltoDataBufferToXmlEvent;
            0   17     1  dataBuffer  Lorg/springframework/core/io/buffer/DataBuffer;
            2   10     2      events  Ljava/util/List<Ljavax/xml/stream/events/XMLEvent;>;
            5    7     3       event  Ljavax/xml/stream/events/XMLEvent;
           11   14     2          ex  Ljavax/xml/stream/XMLStreamException;
      Exception table:
        from    to  target  type
           0     8      10  Class javax.xml.stream.XMLStreamException
           0     8      14  any
          10    12      14  any
    Signature: (Lorg/springframework/core/io/buffer/DataBuffer;)Lorg/reactivestreams/Publisher<+Ljavax/xml/stream/events/XMLEvent;>;
    MethodParameters:
            Name  Flags
      dataBuffer  

  public void endOfInput();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // org.springframework.http.codec.xml.XmlEventDecoder$AaltoDataBufferToXmlEvent this
         0: .line 168
            aload 0 /* this */
            getfield org.springframework.http.codec.xml.XmlEventDecoder$AaltoDataBufferToXmlEvent.streamReader:Lcom/fasterxml/aalto/AsyncXMLStreamReader;
            invokeinterface com.fasterxml.aalto.AsyncXMLStreamReader.getInputFeeder:()Lcom/fasterxml/aalto/AsyncInputFeeder;
            checkcast com.fasterxml.aalto.AsyncByteBufferFeeder
            invokeinterface com.fasterxml.aalto.AsyncByteBufferFeeder.endOfInput:()V
         1: .line 169
            return
        end local 0 // org.springframework.http.codec.xml.XmlEventDecoder$AaltoDataBufferToXmlEvent this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    2     0  this  Lorg/springframework/http/codec/xml/XmlEventDecoder$AaltoDataBufferToXmlEvent;

  public java.lang.Object apply(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: .line 1
            aload 0
            aload 1
            checkcast org.springframework.core.io.buffer.DataBuffer
            invokevirtual org.springframework.http.codec.xml.XmlEventDecoder$AaltoDataBufferToXmlEvent.apply:(Lorg/springframework/core/io/buffer/DataBuffer;)Lorg/reactivestreams/Publisher;
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
}
Signature: Ljava/lang/Object;Ljava/util/function/Function<Lorg/springframework/core/io/buffer/DataBuffer;Lorg/reactivestreams/Publisher<+Ljavax/xml/stream/events/XMLEvent;>;>;
SourceFile: "XmlEventDecoder.java"
NestHost: org.springframework.http.codec.xml.XmlEventDecoder
InnerClasses:
  public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
  private AaltoDataBufferToXmlEvent = org.springframework.http.codec.xml.XmlEventDecoder$AaltoDataBufferToXmlEvent of org.springframework.http.codec.xml.XmlEventDecoder