public class jdk.internal.net.http.ResponseSubscribers$PathSubscriber implements java.net.http.HttpResponse$BodySubscriber<java.nio.file.Path>
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: jdk.internal.net.http.ResponseSubscribers$PathSubscriber
super_class: java.lang.Object
{
private static final java.io.FilePermission[] EMPTY_FILE_PERMISSIONS;
descriptor: [Ljava/io/FilePermission;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
private final java.nio.file.Path file;
descriptor: Ljava/nio/file/Path;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.nio.file.OpenOption[] options;
descriptor: [Ljava/nio/file/OpenOption;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.io.FilePermission[] filePermissions;
descriptor: [Ljava/io/FilePermission;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.util.concurrent.CompletableFuture<java.nio.file.Path> result;
descriptor: Ljava/util/concurrent/CompletableFuture;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/concurrent/CompletableFuture<Ljava/nio/file/Path;>;
private volatile java.util.concurrent.Flow$Subscription subscription;
descriptor: Ljava/util/concurrent/Flow$Subscription;
flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
private volatile java.nio.channels.FileChannel out;
descriptor: Ljava/nio/channels/FileChannel;
flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: iconst_0
anewarray java.io.FilePermission
putstatic jdk.internal.net.http.ResponseSubscribers$PathSubscriber.EMPTY_FILE_PERMISSIONS:[Ljava/io/FilePermission;
return
LocalVariableTable:
Start End Slot Name Signature
private static final java.lang.String pathForSecurityCheck(java.nio.file.Path);
descriptor: (Ljava/nio/file/Path;)Ljava/lang/String;
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokeinterface java.nio.file.Path.toFile:()Ljava/io/File;
invokevirtual java.io.File.getPath:()Ljava/lang/String;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 path Ljava/nio/file/Path;
MethodParameters:
Name Flags
path
public static jdk.internal.net.http.ResponseSubscribers$PathSubscriber create(java.nio.file.Path, java.util.List<java.nio.file.OpenOption>);
descriptor: (Ljava/nio/file/Path;Ljava/util/List;)Ljdk/internal/net/http/ResponseSubscribers$PathSubscriber;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=8, locals=6, args_size=2
start local 0 start local 1 0: aconst_null
astore 2
start local 2 1: invokestatic java.lang.System.getSecurityManager:()Ljava/lang/SecurityManager;
astore 3
start local 3 2: aload 3
ifnull 7
3: aload 0
invokestatic jdk.internal.net.http.ResponseSubscribers$PathSubscriber.pathForSecurityCheck:(Ljava/nio/file/Path;)Ljava/lang/String;
astore 4
start local 4 4: new java.io.FilePermission
dup
aload 4
ldc "write"
invokespecial java.io.FilePermission.<init>:(Ljava/lang/String;Ljava/lang/String;)V
astore 5
start local 5 5: aload 3
aload 5
invokevirtual java.lang.SecurityManager.checkPermission:(Ljava/security/Permission;)V
6: aload 5
astore 2
end local 5 end local 4 7: StackMap locals: java.io.FilePermission java.lang.SecurityManager
StackMap stack:
new jdk.internal.net.http.ResponseSubscribers$PathSubscriber
dup
aload 0
aload 1
iconst_1
anewarray java.io.FilePermission
dup
iconst_0
aload 2
aastore
invokespecial jdk.internal.net.http.ResponseSubscribers$PathSubscriber.<init>:(Ljava/nio/file/Path;Ljava/util/List;[Ljava/io/FilePermission;)V
areturn
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 file Ljava/nio/file/Path;
0 8 1 options Ljava/util/List<Ljava/nio/file/OpenOption;>;
1 8 2 filePermission Ljava/io/FilePermission;
2 8 3 sm Ljava/lang/SecurityManager;
4 7 4 fn Ljava/lang/String;
5 7 5 writePermission Ljava/io/FilePermission;
Signature: (Ljava/nio/file/Path;Ljava/util/List<Ljava/nio/file/OpenOption;>;)Ljdk/internal/net/http/ResponseSubscribers$PathSubscriber;
MethodParameters:
Name Flags
file
options
void <init>(java.nio.file.Path, java.util.List<java.nio.file.OpenOption>, java.io.FilePermission[]);
descriptor: (Ljava/nio/file/Path;Ljava/util/List;[Ljava/io/FilePermission;)V
flags: (0x0080) ACC_VARARGS
Code:
stack=3, 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 jdk.internal.net.http.common.MinimalFuture
dup
invokespecial jdk.internal.net.http.common.MinimalFuture.<init>:()V
putfield jdk.internal.net.http.ResponseSubscribers$PathSubscriber.result:Ljava/util/concurrent/CompletableFuture;
2: aload 0
aload 1
putfield jdk.internal.net.http.ResponseSubscribers$PathSubscriber.file:Ljava/nio/file/Path;
3: aload 0
aload 2
invokeinterface java.util.List.stream:()Ljava/util/stream/Stream;
invokedynamic apply()Ljava/util/function/IntFunction;
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:
(I)Ljava/lang/Object;
jdk/internal/net/http/ResponseSubscribers$PathSubscriber.lambda$0(I)[Ljava/nio/file/OpenOption; (6)
(I)[Ljava/nio/file/OpenOption;
invokeinterface java.util.stream.Stream.toArray:(Ljava/util/function/IntFunction;)[Ljava/lang/Object;
checkcast java.nio.file.OpenOption[]
putfield jdk.internal.net.http.ResponseSubscribers$PathSubscriber.options:[Ljava/nio/file/OpenOption;
4: aload 0
5: aload 3
ifnonnull 6
getstatic jdk.internal.net.http.ResponseSubscribers$PathSubscriber.EMPTY_FILE_PERMISSIONS:[Ljava/io/FilePermission;
goto 7
StackMap locals: jdk.internal.net.http.ResponseSubscribers$PathSubscriber java.nio.file.Path java.util.List java.io.FilePermission[]
StackMap stack: jdk.internal.net.http.ResponseSubscribers$PathSubscriber
6: aload 3
7: StackMap locals: jdk.internal.net.http.ResponseSubscribers$PathSubscriber java.nio.file.Path java.util.List java.io.FilePermission[]
StackMap stack: jdk.internal.net.http.ResponseSubscribers$PathSubscriber java.io.FilePermission[]
putfield jdk.internal.net.http.ResponseSubscribers$PathSubscriber.filePermissions:[Ljava/io/FilePermission;
8: return
end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Ljdk/internal/net/http/ResponseSubscribers$PathSubscriber;
0 9 1 file Ljava/nio/file/Path;
0 9 2 options Ljava/util/List<Ljava/nio/file/OpenOption;>;
0 9 3 filePermissions [Ljava/io/FilePermission;
Signature: (Ljava/nio/file/Path;Ljava/util/List<Ljava/nio/file/OpenOption;>;[Ljava/io/FilePermission;)V
MethodParameters:
Name Flags
file
options
filePermissions
public void onSubscribe(java.util.concurrent.Flow$Subscription);
descriptor: (Ljava/util/concurrent/Flow$Subscription;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=4, args_size=2
start local 0 start local 1 0: aload 0
aload 1
putfield jdk.internal.net.http.ResponseSubscribers$PathSubscriber.subscription:Ljava/util/concurrent/Flow$Subscription;
1: invokestatic java.lang.System.getSecurityManager:()Ljava/lang/SecurityManager;
ifnonnull 7
2: aload 0
aload 0
getfield jdk.internal.net.http.ResponseSubscribers$PathSubscriber.file:Ljava/nio/file/Path;
aload 0
getfield jdk.internal.net.http.ResponseSubscribers$PathSubscriber.options:[Ljava/nio/file/OpenOption;
invokestatic java.nio.channels.FileChannel.open:(Ljava/nio/file/Path;[Ljava/nio/file/OpenOption;)Ljava/nio/channels/FileChannel;
putfield jdk.internal.net.http.ResponseSubscribers$PathSubscriber.out:Ljava/nio/channels/FileChannel;
3: goto 18
StackMap locals:
StackMap stack: java.io.IOException
4: astore 2
start local 2 5: aload 0
getfield jdk.internal.net.http.ResponseSubscribers$PathSubscriber.result:Ljava/util/concurrent/CompletableFuture;
aload 2
invokevirtual java.util.concurrent.CompletableFuture.completeExceptionally:(Ljava/lang/Throwable;)Z
pop
6: return
end local 2 7: StackMap locals:
StackMap stack:
aload 0
invokedynamic run(Ljdk/internal/net/http/ResponseSubscribers$PathSubscriber;)Ljava/security/PrivilegedExceptionAction;
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;
jdk/internal/net/http/ResponseSubscribers$PathSubscriber.lambda$1()Ljava/nio/channels/FileChannel; (7)
()Ljava/nio/channels/FileChannel;
8: astore 2
start local 2 9: aload 0
aload 2
aconst_null
aload 0
getfield jdk.internal.net.http.ResponseSubscribers$PathSubscriber.filePermissions:[Ljava/io/FilePermission;
invokestatic java.security.AccessController.doPrivileged:(Ljava/security/PrivilegedExceptionAction;Ljava/security/AccessControlContext;[Ljava/security/Permission;)Ljava/lang/Object;
checkcast java.nio.channels.FileChannel
putfield jdk.internal.net.http.ResponseSubscribers$PathSubscriber.out:Ljava/nio/channels/FileChannel;
end local 2 10: goto 18
StackMap locals:
StackMap stack: java.security.PrivilegedActionException
11: astore 2
start local 2 12: aload 2
invokevirtual java.security.PrivilegedActionException.getCause:()Ljava/lang/Throwable;
ifnull 13
aload 2
invokevirtual java.security.PrivilegedActionException.getCause:()Ljava/lang/Throwable;
goto 14
StackMap locals: java.security.PrivilegedActionException
StackMap stack:
13: aload 2
StackMap locals:
StackMap stack: java.lang.Throwable
14: astore 3
start local 3 15: aload 0
getfield jdk.internal.net.http.ResponseSubscribers$PathSubscriber.result:Ljava/util/concurrent/CompletableFuture;
aload 3
invokevirtual java.util.concurrent.CompletableFuture.completeExceptionally:(Ljava/lang/Throwable;)Z
pop
16: aload 1
invokeinterface java.util.concurrent.Flow$Subscription.cancel:()V
17: return
end local 3 end local 2 18: StackMap locals:
StackMap stack:
aload 1
lconst_1
invokeinterface java.util.concurrent.Flow$Subscription.request:(J)V
19: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 20 0 this Ljdk/internal/net/http/ResponseSubscribers$PathSubscriber;
0 20 1 subscription Ljava/util/concurrent/Flow$Subscription;
5 7 2 ioe Ljava/io/IOException;
9 10 2 pa Ljava/security/PrivilegedExceptionAction<Ljava/nio/channels/FileChannel;>;
12 18 2 pae Ljava/security/PrivilegedActionException;
15 18 3 t Ljava/lang/Throwable;
Exception table:
from to target type
2 3 4 Class java.io.IOException
7 10 11 Class java.security.PrivilegedActionException
MethodParameters:
Name Flags
subscription
public void onNext(java.util.List<java.nio.ByteBuffer>);
descriptor: (Ljava/util/List;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield jdk.internal.net.http.ResponseSubscribers$PathSubscriber.out:Ljava/nio/channels/FileChannel;
aload 1
getstatic jdk.internal.net.http.common.Utils.EMPTY_BB_ARRAY:[Ljava/nio/ByteBuffer;
invokeinterface java.util.List.toArray:([Ljava/lang/Object;)[Ljava/lang/Object;
checkcast java.nio.ByteBuffer[]
invokevirtual java.nio.channels.FileChannel.write:([Ljava/nio/ByteBuffer;)J
pop2
1: goto 7
StackMap locals:
StackMap stack: java.io.IOException
2: astore 2
start local 2 3: iconst_1
anewarray java.io.Closeable
dup
iconst_0
4: aload 0
getfield jdk.internal.net.http.ResponseSubscribers$PathSubscriber.out:Ljava/nio/channels/FileChannel;
aastore
invokestatic jdk.internal.net.http.common.Utils.close:([Ljava/io/Closeable;)V
5: aload 0
getfield jdk.internal.net.http.ResponseSubscribers$PathSubscriber.subscription:Ljava/util/concurrent/Flow$Subscription;
invokeinterface java.util.concurrent.Flow$Subscription.cancel:()V
6: aload 0
getfield jdk.internal.net.http.ResponseSubscribers$PathSubscriber.result:Ljava/util/concurrent/CompletableFuture;
aload 2
invokevirtual java.util.concurrent.CompletableFuture.completeExceptionally:(Ljava/lang/Throwable;)Z
pop
end local 2 7: StackMap locals:
StackMap stack:
aload 0
getfield jdk.internal.net.http.ResponseSubscribers$PathSubscriber.subscription:Ljava/util/concurrent/Flow$Subscription;
lconst_1
invokeinterface java.util.concurrent.Flow$Subscription.request:(J)V
8: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Ljdk/internal/net/http/ResponseSubscribers$PathSubscriber;
0 9 1 items Ljava/util/List<Ljava/nio/ByteBuffer;>;
3 7 2 ex Ljava/io/IOException;
Exception table:
from to target type
0 1 2 Class java.io.IOException
Signature: (Ljava/util/List<Ljava/nio/ByteBuffer;>;)V
MethodParameters:
Name Flags
items
public void onError(java.lang.Throwable);
descriptor: (Ljava/lang/Throwable;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=2, args_size=2
start local 0 start local 1 0: aload 0
getfield jdk.internal.net.http.ResponseSubscribers$PathSubscriber.result:Ljava/util/concurrent/CompletableFuture;
aload 1
invokevirtual java.util.concurrent.CompletableFuture.completeExceptionally:(Ljava/lang/Throwable;)Z
pop
iconst_1
anewarray java.io.Closeable
dup
iconst_0
1: aload 0
getfield jdk.internal.net.http.ResponseSubscribers$PathSubscriber.out:Ljava/nio/channels/FileChannel;
aastore
invokestatic jdk.internal.net.http.common.Utils.close:([Ljava/io/Closeable;)V
2: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Ljdk/internal/net/http/ResponseSubscribers$PathSubscriber;
0 3 1 e Ljava/lang/Throwable;
MethodParameters:
Name Flags
e
public void onComplete();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=4, locals=1, args_size=1
start local 0 0: iconst_1
anewarray java.io.Closeable
dup
iconst_0
1: aload 0
getfield jdk.internal.net.http.ResponseSubscribers$PathSubscriber.out:Ljava/nio/channels/FileChannel;
aastore
invokestatic jdk.internal.net.http.common.Utils.close:([Ljava/io/Closeable;)V
2: aload 0
getfield jdk.internal.net.http.ResponseSubscribers$PathSubscriber.result:Ljava/util/concurrent/CompletableFuture;
aload 0
getfield jdk.internal.net.http.ResponseSubscribers$PathSubscriber.file:Ljava/nio/file/Path;
invokevirtual java.util.concurrent.CompletableFuture.complete:(Ljava/lang/Object;)Z
pop
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Ljdk/internal/net/http/ResponseSubscribers$PathSubscriber;
public java.util.concurrent.CompletionStage<java.nio.file.Path> getBody();
descriptor: ()Ljava/util/concurrent/CompletionStage;
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield jdk.internal.net.http.ResponseSubscribers$PathSubscriber.result:Ljava/util/concurrent/CompletableFuture;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Ljdk/internal/net/http/ResponseSubscribers$PathSubscriber;
Signature: ()Ljava/util/concurrent/CompletionStage<Ljava/nio/file/Path;>;
public void onNext(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 java.util.List
invokevirtual jdk.internal.net.http.ResponseSubscribers$PathSubscriber.onNext:(Ljava/util/List;)V
return
LocalVariableTable:
Start End Slot Name Signature
private static java.nio.file.OpenOption[] lambda$0(int);
descriptor: (I)[Ljava/nio/file/OpenOption;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=1, locals=1, args_size=1
0: iload 0
anewarray java.nio.file.OpenOption
areturn
LocalVariableTable:
Start End Slot Name Signature
private java.nio.channels.FileChannel lambda$1();
descriptor: ()Ljava/nio/channels/FileChannel;
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield jdk.internal.net.http.ResponseSubscribers$PathSubscriber.file:Ljava/nio/file/Path;
aload 0
getfield jdk.internal.net.http.ResponseSubscribers$PathSubscriber.options:[Ljava/nio/file/OpenOption;
invokestatic java.nio.channels.FileChannel.open:(Ljava/nio/file/Path;[Ljava/nio/file/OpenOption;)Ljava/nio/channels/FileChannel;
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 1 0 this Ljdk/internal/net/http/ResponseSubscribers$PathSubscriber;
Exceptions:
throws java.lang.Exception
}
Signature: Ljava/lang/Object;Ljava/net/http/HttpResponse$BodySubscriber<Ljava/nio/file/Path;>;
SourceFile: "ResponseSubscribers.java"
NestHost: jdk.internal.net.http.ResponseSubscribers
InnerClasses:
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles
public abstract BodySubscriber = java.net.http.HttpResponse$BodySubscriber of java.net.http.HttpResponse
public abstract Subscription = java.util.concurrent.Flow$Subscription of java.util.concurrent.Flow
public PathSubscriber = jdk.internal.net.http.ResponseSubscribers$PathSubscriber of jdk.internal.net.http.ResponseSubscribers