class org.springframework.http.codec.multipart.SynchronossPartHttpMessageReader$SynchronossPartGenerator implements java.util.function.Consumer<reactor.core.publisher.FluxSink<org.springframework.http.codec.multipart.Part>>
minor version: 0
major version: 59
flags: flags: (0x0020) ACC_SUPER
this_class: org.springframework.http.codec.multipart.SynchronossPartHttpMessageReader$SynchronossPartGenerator
super_class: java.lang.Object
{
private final org.springframework.http.ReactiveHttpInputMessage inputMessage;
descriptor: Lorg/springframework/http/ReactiveHttpInputMessage;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final org.springframework.core.io.buffer.DataBufferFactory bufferFactory;
descriptor: Lorg/springframework/core/io/buffer/DataBufferFactory;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final org.synchronoss.cloud.nio.multipart.PartBodyStreamStorageFactory streamStorageFactory;
descriptor: Lorg/synchronoss/cloud/nio/multipart/PartBodyStreamStorageFactory;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
void <init>(org.springframework.http.ReactiveHttpInputMessage, org.springframework.core.io.buffer.DataBufferFactory, org.synchronoss.cloud.nio.multipart.PartBodyStreamStorageFactory);
descriptor: (Lorg/springframework/http/ReactiveHttpInputMessage;Lorg/springframework/core/io/buffer/DataBufferFactory;Lorg/synchronoss/cloud/nio/multipart/PartBodyStreamStorageFactory;)V
flags: (0x0000)
Code:
stack=2, locals=4, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
aload 1
putfield org.springframework.http.codec.multipart.SynchronossPartHttpMessageReader$SynchronossPartGenerator.inputMessage:Lorg/springframework/http/ReactiveHttpInputMessage;
2: aload 0
aload 2
putfield org.springframework.http.codec.multipart.SynchronossPartHttpMessageReader$SynchronossPartGenerator.bufferFactory:Lorg/springframework/core/io/buffer/DataBufferFactory;
3: aload 0
aload 3
putfield org.springframework.http.codec.multipart.SynchronossPartHttpMessageReader$SynchronossPartGenerator.streamStorageFactory:Lorg/synchronoss/cloud/nio/multipart/PartBodyStreamStorageFactory;
4: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/springframework/http/codec/multipart/SynchronossPartHttpMessageReader$SynchronossPartGenerator;
0 5 1 inputMessage Lorg/springframework/http/ReactiveHttpInputMessage;
0 5 2 bufferFactory Lorg/springframework/core/io/buffer/DataBufferFactory;
0 5 3 streamStorageFactory Lorg/synchronoss/cloud/nio/multipart/PartBodyStreamStorageFactory;
MethodParameters:
Name Flags
inputMessage
bufferFactory
streamStorageFactory
public void accept(reactor.core.publisher.FluxSink<org.springframework.http.codec.multipart.Part>);
descriptor: (Lreactor/core/publisher/FluxSink;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=5, locals=9, args_size=2
start local 0 start local 1 0: aload 0
getfield org.springframework.http.codec.multipart.SynchronossPartHttpMessageReader$SynchronossPartGenerator.inputMessage:Lorg/springframework/http/ReactiveHttpInputMessage;
invokeinterface org.springframework.http.ReactiveHttpInputMessage.getHeaders:()Lorg/springframework/http/HttpHeaders;
astore 2
start local 2 1: aload 2
invokevirtual org.springframework.http.HttpHeaders.getContentType:()Lorg/springframework/http/MediaType;
astore 3
start local 3 2: aload 3
ifnull 3
iconst_1
goto 4
StackMap locals: org.springframework.http.HttpHeaders org.springframework.http.MediaType
StackMap stack:
3: iconst_0
StackMap locals:
StackMap stack: int
4: ldc "No content type set"
invokestatic org.springframework.util.Assert.state:(ZLjava/lang/String;)V
5: aload 0
aload 2
invokevirtual org.springframework.http.codec.multipart.SynchronossPartHttpMessageReader$SynchronossPartGenerator.getContentLength:(Lorg/springframework/http/HttpHeaders;)I
istore 4
start local 4 6: aload 3
invokevirtual org.springframework.http.MediaType.getCharset:()Ljava/nio/charset/Charset;
invokestatic java.util.Optional.ofNullable:(Ljava/lang/Object;)Ljava/util/Optional;
getstatic java.nio.charset.StandardCharsets.UTF_8:Ljava/nio/charset/Charset;
invokevirtual java.util.Optional.orElse:(Ljava/lang/Object;)Ljava/lang/Object;
checkcast java.nio.charset.Charset
astore 5
start local 5 7: new org.synchronoss.cloud.nio.multipart.MultipartContext
dup
aload 3
invokevirtual org.springframework.http.MediaType.toString:()Ljava/lang/String;
iload 4
aload 5
invokevirtual java.nio.charset.Charset.name:()Ljava/lang/String;
invokespecial org.synchronoss.cloud.nio.multipart.MultipartContext.<init>:(Ljava/lang/String;ILjava/lang/String;)V
astore 6
start local 6 8: new org.springframework.http.codec.multipart.SynchronossPartHttpMessageReader$FluxSinkAdapterListener
dup
aload 1
aload 0
getfield org.springframework.http.codec.multipart.SynchronossPartHttpMessageReader$SynchronossPartGenerator.bufferFactory:Lorg/springframework/core/io/buffer/DataBufferFactory;
aload 6
invokespecial org.springframework.http.codec.multipart.SynchronossPartHttpMessageReader$FluxSinkAdapterListener.<init>:(Lreactor/core/publisher/FluxSink;Lorg/springframework/core/io/buffer/DataBufferFactory;Lorg/synchronoss/cloud/nio/multipart/MultipartContext;)V
astore 7
start local 7 9: aload 6
invokestatic org.synchronoss.cloud.nio.multipart.Multipart.multipart:(Lorg/synchronoss/cloud/nio/multipart/MultipartContext;)Lorg/synchronoss/cloud/nio/multipart/Multipart$Builder;
10: aload 0
getfield org.springframework.http.codec.multipart.SynchronossPartHttpMessageReader$SynchronossPartGenerator.streamStorageFactory:Lorg/synchronoss/cloud/nio/multipart/PartBodyStreamStorageFactory;
invokevirtual org.synchronoss.cloud.nio.multipart.Multipart$Builder.usePartBodyStreamStorageFactory:(Lorg/synchronoss/cloud/nio/multipart/PartBodyStreamStorageFactory;)Lorg/synchronoss/cloud/nio/multipart/Multipart$Builder;
11: aload 7
invokevirtual org.synchronoss.cloud.nio.multipart.Multipart$Builder.forNIO:(Lorg/synchronoss/cloud/nio/multipart/NioMultipartParserListener;)Lorg/synchronoss/cloud/nio/multipart/NioMultipartParser;
12: astore 8
start local 8 13: aload 0
getfield org.springframework.http.codec.multipart.SynchronossPartHttpMessageReader$SynchronossPartGenerator.inputMessage:Lorg/springframework/http/ReactiveHttpInputMessage;
invokeinterface org.springframework.http.ReactiveHttpInputMessage.getBody:()Lreactor/core/publisher/Flux;
aload 8
aload 7
invokedynamic accept(Lorg/synchronoss/cloud/nio/multipart/NioMultipartParser;Lorg/synchronoss/cloud/nio/multipart/NioMultipartParserListener;)Ljava/util/function/Consumer;
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;)V
org/springframework/http/codec/multipart/SynchronossPartHttpMessageReader$SynchronossPartGenerator.lambda$0(Lorg/synchronoss/cloud/nio/multipart/NioMultipartParser;Lorg/synchronoss/cloud/nio/multipart/NioMultipartParserListener;Lorg/springframework/core/io/buffer/DataBuffer;)V (6)
(Lorg/springframework/core/io/buffer/DataBuffer;)V
14: aload 7
aload 8
invokedynamic accept(Lorg/synchronoss/cloud/nio/multipart/NioMultipartParserListener;Lorg/synchronoss/cloud/nio/multipart/NioMultipartParser;)Ljava/util/function/Consumer;
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;)V
org/springframework/http/codec/multipart/SynchronossPartHttpMessageReader$SynchronossPartGenerator.lambda$1(Lorg/synchronoss/cloud/nio/multipart/NioMultipartParserListener;Lorg/synchronoss/cloud/nio/multipart/NioMultipartParser;Ljava/lang/Throwable;)V (6)
(Ljava/lang/Throwable;)V
15: aload 8
aload 7
invokedynamic run(Lorg/synchronoss/cloud/nio/multipart/NioMultipartParser;Lorg/synchronoss/cloud/nio/multipart/NioMultipartParserListener;)Ljava/lang/Runnable;
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:
()V
org/springframework/http/codec/multipart/SynchronossPartHttpMessageReader$SynchronossPartGenerator.lambda$2(Lorg/synchronoss/cloud/nio/multipart/NioMultipartParser;Lorg/synchronoss/cloud/nio/multipart/NioMultipartParserListener;)V (6)
()V
16: invokevirtual reactor.core.publisher.Flux.subscribe:(Ljava/util/function/Consumer;Ljava/util/function/Consumer;Ljava/lang/Runnable;)Lreactor/core/Disposable;
pop
17: return
end local 8 end local 7 end local 6 end local 5 end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 18 0 this Lorg/springframework/http/codec/multipart/SynchronossPartHttpMessageReader$SynchronossPartGenerator;
0 18 1 emitter Lreactor/core/publisher/FluxSink<Lorg/springframework/http/codec/multipart/Part;>;
1 18 2 headers Lorg/springframework/http/HttpHeaders;
2 18 3 mediaType Lorg/springframework/http/MediaType;
6 18 4 length I
7 18 5 charset Ljava/nio/charset/Charset;
8 18 6 context Lorg/synchronoss/cloud/nio/multipart/MultipartContext;
9 18 7 listener Lorg/synchronoss/cloud/nio/multipart/NioMultipartParserListener;
13 18 8 parser Lorg/synchronoss/cloud/nio/multipart/NioMultipartParser;
Signature: (Lreactor/core/publisher/FluxSink<Lorg/springframework/http/codec/multipart/Part;>;)V
MethodParameters:
Name Flags
emitter
private int (org.springframework.http.HttpHeaders);
descriptor: (Lorg/springframework/http/HttpHeaders;)I
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=4, args_size=2
start local 0 start local 1 0: aload 1
invokevirtual org.springframework.http.HttpHeaders.getContentLength:()J
lstore 2
start local 2 1: lload 2
l2i
i2l
lload 2
lcmp
ifne 2
lload 2
l2i
goto 3
StackMap locals: long
StackMap stack:
2: iconst_m1
StackMap locals:
StackMap stack: int
3: ireturn
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/springframework/http/codec/multipart/SynchronossPartHttpMessageReader$SynchronossPartGenerator;
0 4 1 headers Lorg/springframework/http/HttpHeaders;
1 4 2 length J
MethodParameters:
Name Flags
headers
public void accept(java.lang.Object);
descriptor: (Ljava/lang/Object;)V
flags: (0x1041) ACC_PUBLIC, ACC_BRIDGE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
0: aload 0
aload 1
checkcast reactor.core.publisher.FluxSink
invokevirtual org.springframework.http.codec.multipart.SynchronossPartHttpMessageReader$SynchronossPartGenerator.accept:(Lreactor/core/publisher/FluxSink;)V
return
LocalVariableTable:
Start End Slot Name Signature
private static void lambda$0(org.synchronoss.cloud.nio.multipart.NioMultipartParser, org.synchronoss.cloud.nio.multipart.NioMultipartParserListener, org.springframework.core.io.buffer.DataBuffer);
descriptor: (Lorg/synchronoss/cloud/nio/multipart/NioMultipartParser;Lorg/synchronoss/cloud/nio/multipart/NioMultipartParserListener;Lorg/springframework/core/io/buffer/DataBuffer;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=6, args_size=3
start local 2 0: aload 2
invokeinterface org.springframework.core.io.buffer.DataBuffer.readableByteCount:()I
newarray 8
astore 3
start local 3 1: aload 2
aload 3
invokeinterface org.springframework.core.io.buffer.DataBuffer.read:([B)Lorg/springframework/core/io/buffer/DataBuffer;
pop
2: aload 0
aload 3
invokevirtual org.synchronoss.cloud.nio.multipart.NioMultipartParser.write:([B)V
3: goto 10
4: StackMap locals: org.synchronoss.cloud.nio.multipart.NioMultipartParser org.synchronoss.cloud.nio.multipart.NioMultipartParserListener org.springframework.core.io.buffer.DataBuffer byte[]
StackMap stack: java.io.IOException
astore 4
start local 4 5: aload 1
ldc "Exception thrown providing input to the parser"
aload 4
invokeinterface org.synchronoss.cloud.nio.multipart.NioMultipartParserListener.onError:(Ljava/lang/String;Ljava/lang/Throwable;)V
end local 4 6: aload 2
invokestatic org.springframework.core.io.buffer.DataBufferUtils.release:(Lorg/springframework/core/io/buffer/DataBuffer;)Z
pop
goto 11
7: StackMap locals:
StackMap stack: java.lang.Throwable
astore 5
8: aload 2
invokestatic org.springframework.core.io.buffer.DataBufferUtils.release:(Lorg/springframework/core/io/buffer/DataBuffer;)Z
pop
9: aload 5
athrow
10: StackMap locals:
StackMap stack:
aload 2
invokestatic org.springframework.core.io.buffer.DataBufferUtils.release:(Lorg/springframework/core/io/buffer/DataBuffer;)Z
pop
end local 3 11: StackMap locals:
StackMap stack:
return
end local 2 LocalVariableTable:
Start End Slot Name Signature
0 12 2 buffer Lorg/springframework/core/io/buffer/DataBuffer;
1 11 3 resultBytes [B
5 6 4 ex Ljava/io/IOException;
Exception table:
from to target type
2 3 4 Class java.io.IOException
2 6 7 any
private static void lambda$1(org.synchronoss.cloud.nio.multipart.NioMultipartParserListener, org.synchronoss.cloud.nio.multipart.NioMultipartParser, java.lang.Throwable);
descriptor: (Lorg/synchronoss/cloud/nio/multipart/NioMultipartParserListener;Lorg/synchronoss/cloud/nio/multipart/NioMultipartParser;Ljava/lang/Throwable;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=4, args_size=3
start local 2 0: aload 0
ldc "Request body input error"
aload 2
invokeinterface org.synchronoss.cloud.nio.multipart.NioMultipartParserListener.onError:(Ljava/lang/String;Ljava/lang/Throwable;)V
1: aload 1
invokevirtual org.synchronoss.cloud.nio.multipart.NioMultipartParser.close:()V
2: goto 5
3: StackMap locals:
StackMap stack: java.io.IOException
astore 3
start local 3 4: aload 0
ldc "Exception thrown while closing the parser"
aload 3
invokeinterface org.synchronoss.cloud.nio.multipart.NioMultipartParserListener.onError:(Ljava/lang/String;Ljava/lang/Throwable;)V
end local 3 5: StackMap locals:
StackMap stack:
return
end local 2 LocalVariableTable:
Start End Slot Name Signature
0 6 2 ex Ljava/lang/Throwable;
4 5 3 ex2 Ljava/io/IOException;
Exception table:
from to target type
0 2 3 Class java.io.IOException
private static void lambda$2(org.synchronoss.cloud.nio.multipart.NioMultipartParser, org.synchronoss.cloud.nio.multipart.NioMultipartParserListener);
descriptor: (Lorg/synchronoss/cloud/nio/multipart/NioMultipartParser;Lorg/synchronoss/cloud/nio/multipart/NioMultipartParserListener;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=3, args_size=2
0: aload 0
invokevirtual org.synchronoss.cloud.nio.multipart.NioMultipartParser.close:()V
1: goto 4
2: StackMap locals:
StackMap stack: java.io.IOException
astore 2
start local 2 3: aload 1
ldc "Exception thrown while closing the parser"
aload 2
invokeinterface org.synchronoss.cloud.nio.multipart.NioMultipartParserListener.onError:(Ljava/lang/String;Ljava/lang/Throwable;)V
end local 2 4: StackMap locals:
StackMap stack:
return
LocalVariableTable:
Start End Slot Name Signature
3 4 2 ex Ljava/io/IOException;
Exception table:
from to target type
0 1 2 Class java.io.IOException
}
Signature: Ljava/lang/Object;Ljava/util/function/Consumer<Lreactor/core/publisher/FluxSink<Lorg/springframework/http/codec/multipart/Part;>;>;
SourceFile: "SynchronossPartHttpMessageReader.java"
NestHost: org.springframework.http.codec.multipart.SynchronossPartHttpMessageReader
InnerClasses:
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
private FluxSinkAdapterListener = org.springframework.http.codec.multipart.SynchronossPartHttpMessageReader$FluxSinkAdapterListener of org.springframework.http.codec.multipart.SynchronossPartHttpMessageReader
private SynchronossPartGenerator = org.springframework.http.codec.multipart.SynchronossPartHttpMessageReader$SynchronossPartGenerator of org.springframework.http.codec.multipart.SynchronossPartHttpMessageReader
public Builder = org.synchronoss.cloud.nio.multipart.Multipart$Builder of org.synchronoss.cloud.nio.multipart.Multipart