class org.springframework.http.client.reactive.ReactorClientHttpResponse implements org.springframework.http.client.reactive.ClientHttpResponse
minor version: 0
major version: 59
flags: flags: (0x0020) ACC_SUPER
this_class: org.springframework.http.client.reactive.ReactorClientHttpResponse
super_class: java.lang.Object
{
private final org.springframework.core.io.buffer.NettyDataBufferFactory bufferFactory;
descriptor: Lorg/springframework/core/io/buffer/NettyDataBufferFactory;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final reactor.netty.http.client.HttpClientResponse response;
descriptor: Lreactor/netty/http/client/HttpClientResponse;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final reactor.netty.NettyInbound inbound;
descriptor: Lreactor/netty/NettyInbound;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.util.concurrent.atomic.AtomicBoolean rejectSubscribers;
descriptor: Ljava/util/concurrent/atomic/AtomicBoolean;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
public void <init>(reactor.netty.http.client.HttpClientResponse, reactor.netty.NettyInbound, io.netty.buffer.ByteBufAllocator);
descriptor: (Lreactor/netty/http/client/HttpClientResponse;Lreactor/netty/NettyInbound;Lio/netty/buffer/ByteBufAllocator;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, 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
new java.util.concurrent.atomic.AtomicBoolean
dup
invokespecial java.util.concurrent.atomic.AtomicBoolean.<init>:()V
putfield org.springframework.http.client.reactive.ReactorClientHttpResponse.rejectSubscribers:Ljava/util/concurrent/atomic/AtomicBoolean;
2: aload 0
aload 1
putfield org.springframework.http.client.reactive.ReactorClientHttpResponse.response:Lreactor/netty/http/client/HttpClientResponse;
3: aload 0
aload 2
putfield org.springframework.http.client.reactive.ReactorClientHttpResponse.inbound:Lreactor/netty/NettyInbound;
4: aload 0
new org.springframework.core.io.buffer.NettyDataBufferFactory
dup
aload 3
invokespecial org.springframework.core.io.buffer.NettyDataBufferFactory.<init>:(Lio/netty/buffer/ByteBufAllocator;)V
putfield org.springframework.http.client.reactive.ReactorClientHttpResponse.bufferFactory:Lorg/springframework/core/io/buffer/NettyDataBufferFactory;
5: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lorg/springframework/http/client/reactive/ReactorClientHttpResponse;
0 6 1 response Lreactor/netty/http/client/HttpClientResponse;
0 6 2 inbound Lreactor/netty/NettyInbound;
0 6 3 alloc Lio/netty/buffer/ByteBufAllocator;
MethodParameters:
Name Flags
response
inbound
alloc
public reactor.core.publisher.Flux<org.springframework.core.io.buffer.DataBuffer> getBody();
descriptor: ()Lreactor/core/publisher/Flux;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield org.springframework.http.client.reactive.ReactorClientHttpResponse.inbound:Lreactor/netty/NettyInbound;
invokeinterface reactor.netty.NettyInbound.receive:()Lreactor/netty/ByteBufFlux;
1: aload 0
invokedynamic accept(Lorg/springframework/http/client/reactive/ReactorClientHttpResponse;)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/client/reactive/ReactorClientHttpResponse.lambda$0(Lorg/reactivestreams/Subscription;)V (7)
(Lorg/reactivestreams/Subscription;)V
invokevirtual reactor.netty.ByteBufFlux.doOnSubscribe:(Ljava/util/function/Consumer;)Lreactor/core/publisher/Flux;
2: aload 0
invokedynamic run(Lorg/springframework/http/client/reactive/ReactorClientHttpResponse;)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/client/reactive/ReactorClientHttpResponse.lambda$1()V (7)
()V
invokevirtual reactor.core.publisher.Flux.doOnCancel:(Ljava/lang/Runnable;)Lreactor/core/publisher/Flux;
3: aload 0
invokedynamic apply(Lorg/springframework/http/client/reactive/ReactorClientHttpResponse;)Ljava/util/function/Function;
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;)Ljava/lang/Object;
org/springframework/http/client/reactive/ReactorClientHttpResponse.lambda$2(Lio/netty/buffer/ByteBuf;)Lorg/springframework/core/io/buffer/DataBuffer; (7)
(Lio/netty/buffer/ByteBuf;)Lorg/springframework/core/io/buffer/DataBuffer;
invokevirtual reactor.core.publisher.Flux.map:(Ljava/util/function/Function;)Lreactor/core/publisher/Flux;
4: areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lorg/springframework/http/client/reactive/ReactorClientHttpResponse;
Signature: ()Lreactor/core/publisher/Flux<Lorg/springframework/core/io/buffer/DataBuffer;>;
public org.springframework.http.HttpHeaders ();
descriptor: ()Lorg/springframework/http/HttpHeaders;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: new org.springframework.http.HttpHeaders
dup
invokespecial org.springframework.http.HttpHeaders.<init>:()V
astore 1
start local 1 1: aload 0
getfield org.springframework.http.client.reactive.ReactorClientHttpResponse.response:Lreactor/netty/http/client/HttpClientResponse;
invokeinterface reactor.netty.http.client.HttpClientResponse.responseHeaders:()Lio/netty/handler/codec/http/HttpHeaders;
invokevirtual io.netty.handler.codec.http.HttpHeaders.entries:()Ljava/util/List;
aload 1
invokedynamic accept(Lorg/springframework/http/HttpHeaders;)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/client/reactive/ReactorClientHttpResponse.lambda$3(Lorg/springframework/http/HttpHeaders;Ljava/util/Map$Entry;)V (6)
(Ljava/util/Map$Entry;)V
invokeinterface java.util.List.forEach:(Ljava/util/function/Consumer;)V
2: aload 1
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/springframework/http/client/reactive/ReactorClientHttpResponse;
1 3 1 headers Lorg/springframework/http/HttpHeaders;
public org.springframework.http.HttpStatus getStatusCode();
descriptor: ()Lorg/springframework/http/HttpStatus;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual org.springframework.http.client.reactive.ReactorClientHttpResponse.getRawStatusCode:()I
invokestatic org.springframework.http.HttpStatus.valueOf:(I)Lorg/springframework/http/HttpStatus;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/springframework/http/client/reactive/ReactorClientHttpResponse;
public int getRawStatusCode();
descriptor: ()I
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield org.springframework.http.client.reactive.ReactorClientHttpResponse.response:Lreactor/netty/http/client/HttpClientResponse;
invokeinterface reactor.netty.http.client.HttpClientResponse.status:()Lio/netty/handler/codec/http/HttpResponseStatus;
invokevirtual io.netty.handler.codec.http.HttpResponseStatus.code:()I
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Lorg/springframework/http/client/reactive/ReactorClientHttpResponse;
public org.springframework.util.MultiValueMap<java.lang.String, org.springframework.http.ResponseCookie> getCookies();
descriptor: ()Lorg/springframework/util/MultiValueMap;
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: new org.springframework.util.LinkedMultiValueMap
dup
invokespecial org.springframework.util.LinkedMultiValueMap.<init>:()V
astore 1
start local 1 1: aload 0
getfield org.springframework.http.client.reactive.ReactorClientHttpResponse.response:Lreactor/netty/http/client/HttpClientResponse;
invokeinterface reactor.netty.http.client.HttpClientResponse.cookies:()Ljava/util/Map;
invokeinterface java.util.Map.values:()Ljava/util/Collection;
invokeinterface java.util.Collection.stream:()Ljava/util/stream/Stream;
invokedynamic apply()Ljava/util/function/Function;
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;)Ljava/lang/Object;
java/util/Collection.stream()Ljava/util/stream/Stream; (9 itf)
(Ljava/util/Set;)Ljava/util/stream/Stream;
invokeinterface java.util.stream.Stream.flatMap:(Ljava/util/function/Function;)Ljava/util/stream/Stream;
2: aload 1
invokedynamic accept(Lorg/springframework/util/MultiValueMap;)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/client/reactive/ReactorClientHttpResponse.lambda$5(Lorg/springframework/util/MultiValueMap;Lio/netty/handler/codec/http/cookie/Cookie;)V (6)
(Lio/netty/handler/codec/http/cookie/Cookie;)V
invokeinterface java.util.stream.Stream.forEach:(Ljava/util/function/Consumer;)V
3: aload 1
invokestatic org.springframework.util.CollectionUtils.unmodifiableMultiValueMap:(Lorg/springframework/util/MultiValueMap;)Lorg/springframework/util/MultiValueMap;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/springframework/http/client/reactive/ReactorClientHttpResponse;
1 4 1 result Lorg/springframework/util/MultiValueMap<Ljava/lang/String;Lorg/springframework/http/ResponseCookie;>;
Signature: ()Lorg/springframework/util/MultiValueMap<Ljava/lang/String;Lorg/springframework/http/ResponseCookie;>;
public java.lang.String toString();
descriptor: ()Ljava/lang/String;
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: new java.lang.StringBuilder
dup
ldc "ReactorClientHttpResponse{request=["
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
1: aload 0
getfield org.springframework.http.client.reactive.ReactorClientHttpResponse.response:Lreactor/netty/http/client/HttpClientResponse;
invokeinterface reactor.netty.http.client.HttpClientResponse.method:()Lio/netty/handler/codec/http/HttpMethod;
invokevirtual io.netty.handler.codec.http.HttpMethod.name:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc " "
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
getfield org.springframework.http.client.reactive.ReactorClientHttpResponse.response:Lreactor/netty/http/client/HttpClientResponse;
invokeinterface reactor.netty.http.client.HttpClientResponse.uri:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
ldc "],"
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
2: ldc "status="
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
aload 0
invokevirtual org.springframework.http.client.reactive.ReactorClientHttpResponse.getRawStatusCode:()I
invokevirtual java.lang.StringBuilder.append:(I)Ljava/lang/StringBuilder;
bipush 125
invokevirtual java.lang.StringBuilder.append:(C)Ljava/lang/StringBuilder;
3: invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/springframework/http/client/reactive/ReactorClientHttpResponse;
private void lambda$0(org.reactivestreams.Subscription);
descriptor: (Lorg/reactivestreams/Subscription;)V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=3, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield org.springframework.http.client.reactive.ReactorClientHttpResponse.rejectSubscribers:Ljava/util/concurrent/atomic/AtomicBoolean;
invokevirtual java.util.concurrent.atomic.AtomicBoolean.get:()Z
ifeq 2
1: new java.lang.IllegalStateException
dup
ldc "The client response body can only be consumed once."
invokespecial java.lang.IllegalStateException.<init>:(Ljava/lang/String;)V
athrow
2: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/springframework/http/client/reactive/ReactorClientHttpResponse;
0 3 1 s Lorg/reactivestreams/Subscription;
private void lambda$1();
descriptor: ()V
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield org.springframework.http.client.reactive.ReactorClientHttpResponse.rejectSubscribers:Ljava/util/concurrent/atomic/AtomicBoolean;
iconst_1
invokevirtual java.util.concurrent.atomic.AtomicBoolean.set:(Z)V
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/springframework/http/client/reactive/ReactorClientHttpResponse;
private org.springframework.core.io.buffer.DataBuffer lambda$2(io.netty.buffer.ByteBuf);
descriptor: (Lio/netty/buffer/ByteBuf;)Lorg/springframework/core/io/buffer/DataBuffer;
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 1
invokevirtual io.netty.buffer.ByteBuf.retain:()Lio/netty/buffer/ByteBuf;
pop
1: aload 0
getfield org.springframework.http.client.reactive.ReactorClientHttpResponse.bufferFactory:Lorg/springframework/core/io/buffer/NettyDataBufferFactory;
aload 1
invokevirtual org.springframework.core.io.buffer.NettyDataBufferFactory.wrap:(Lio/netty/buffer/ByteBuf;)Lorg/springframework/core/io/buffer/NettyDataBuffer;
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/springframework/http/client/reactive/ReactorClientHttpResponse;
0 2 1 byteBuf Lio/netty/buffer/ByteBuf;
private static void (org.springframework.http.HttpHeaders, java.util.Map$Entry);
descriptor: (Lorg/springframework/http/HttpHeaders;Ljava/util/Map$Entry;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=3, locals=2, args_size=2
start local 1 0: aload 0
aload 1
invokeinterface java.util.Map$Entry.getKey:()Ljava/lang/Object;
checkcast java.lang.String
aload 1
invokeinterface java.util.Map$Entry.getValue:()Ljava/lang/Object;
checkcast java.lang.String
invokevirtual org.springframework.http.HttpHeaders.add:(Ljava/lang/String;Ljava/lang/String;)V
return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 1 1 e Ljava/util/Map$Entry<Ljava/lang/String;Ljava/lang/String;>;
private static void lambda$5(org.springframework.util.MultiValueMap, io.netty.handler.codec.http.cookie.Cookie);
descriptor: (Lorg/springframework/util/MultiValueMap;Lio/netty/handler/codec/http/cookie/Cookie;)V
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=5, locals=2, args_size=2
start local 1 0: aload 0
aload 1
invokeinterface io.netty.handler.codec.http.cookie.Cookie.name:()Ljava/lang/String;
aload 1
invokeinterface io.netty.handler.codec.http.cookie.Cookie.name:()Ljava/lang/String;
aload 1
invokeinterface io.netty.handler.codec.http.cookie.Cookie.value:()Ljava/lang/String;
invokestatic org.springframework.http.ResponseCookie.from:(Ljava/lang/String;Ljava/lang/String;)Lorg/springframework/http/ResponseCookie$ResponseCookieBuilder;
1: aload 1
invokeinterface io.netty.handler.codec.http.cookie.Cookie.domain:()Ljava/lang/String;
invokeinterface org.springframework.http.ResponseCookie$ResponseCookieBuilder.domain:(Ljava/lang/String;)Lorg/springframework/http/ResponseCookie$ResponseCookieBuilder;
2: aload 1
invokeinterface io.netty.handler.codec.http.cookie.Cookie.path:()Ljava/lang/String;
invokeinterface org.springframework.http.ResponseCookie$ResponseCookieBuilder.path:(Ljava/lang/String;)Lorg/springframework/http/ResponseCookie$ResponseCookieBuilder;
3: aload 1
invokeinterface io.netty.handler.codec.http.cookie.Cookie.maxAge:()J
invokeinterface org.springframework.http.ResponseCookie$ResponseCookieBuilder.maxAge:(J)Lorg/springframework/http/ResponseCookie$ResponseCookieBuilder;
4: aload 1
invokeinterface io.netty.handler.codec.http.cookie.Cookie.isSecure:()Z
invokeinterface org.springframework.http.ResponseCookie$ResponseCookieBuilder.secure:(Z)Lorg/springframework/http/ResponseCookie$ResponseCookieBuilder;
5: aload 1
invokeinterface io.netty.handler.codec.http.cookie.Cookie.isHttpOnly:()Z
invokeinterface org.springframework.http.ResponseCookie$ResponseCookieBuilder.httpOnly:(Z)Lorg/springframework/http/ResponseCookie$ResponseCookieBuilder;
6: invokeinterface org.springframework.http.ResponseCookie$ResponseCookieBuilder.build:()Lorg/springframework/http/ResponseCookie;
7: invokeinterface org.springframework.util.MultiValueMap.add:(Ljava/lang/Object;Ljava/lang/Object;)V
8: return
end local 1 LocalVariableTable:
Start End Slot Name Signature
0 9 1 cookie Lio/netty/handler/codec/http/cookie/Cookie;
}
SourceFile: "ReactorClientHttpResponse.java"
InnerClasses:
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
public abstract Entry = java.util.Map$Entry of java.util.Map
public abstract ResponseCookieBuilder = org.springframework.http.ResponseCookie$ResponseCookieBuilder of org.springframework.http.ResponseCookie