public class jdk.internal.net.http.ResponseSubscribers$PathSubscriber implements jdk.internal.net.http.ResponseSubscribers$TrustedSubscriber<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.security.AccessControlContext acc;
descriptor: Ljava/security/AccessControlContext;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.io.FilePermission[] filePermissions;
descriptor: [Ljava/io/FilePermission;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final boolean isDefaultFS;
descriptor: Z
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 final java.util.concurrent.atomic.AtomicBoolean subscribed;
descriptor: Ljava/util/concurrent/atomic/AtomicBoolean;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
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 final boolean $assertionsDisabled;
descriptor: Z
flags: (0x1018) ACC_STATIC, ACC_FINAL, ACC_SYNTHETIC
static void <clinit>();
descriptor: ()V
flags: (0x0008) ACC_STATIC
Code:
stack=1, locals=0, args_size=0
0: ldc Ljdk/internal/net/http/ResponseSubscribers;
invokevirtual java.lang.Class.desiredAssertionStatus:()Z
ifne 1
iconst_1
goto 2
StackMap locals:
StackMap stack:
1: iconst_0
StackMap locals:
StackMap stack: int
2: putstatic jdk.internal.net.http.ResponseSubscribers$PathSubscriber.$assertionsDisabled:Z
3: 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=9, locals=6, args_size=2
start local 0 start local 1 0: invokestatic java.lang.System.getSecurityManager:()Ljava/lang/SecurityManager;
astore 2
start local 2 1: aconst_null
astore 3
start local 3 2: aload 2
ifnull 9
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 2
aload 5
invokevirtual java.lang.SecurityManager.checkPermission:(Ljava/security/Permission;)V
6: aload 5
astore 3
end local 5 end local 4 7: goto 9
StackMap locals: java.nio.file.Path java.util.List java.lang.SecurityManager java.io.FilePermission
StackMap stack: java.lang.UnsupportedOperationException
8: pop
9: StackMap locals:
StackMap stack:
getstatic jdk.internal.net.http.ResponseSubscribers$PathSubscriber.$assertionsDisabled:Z
ifne 10
aload 3
ifnull 10
aload 3
invokevirtual java.io.FilePermission.getActions:()Ljava/lang/String;
ldc "write"
invokevirtual java.lang.String.equals:(Ljava/lang/Object;)Z
ifne 10
new java.lang.AssertionError
dup
invokespecial java.lang.AssertionError.<init>:()V
athrow
10: StackMap locals:
StackMap stack:
aload 2
ifnull 11
invokestatic java.security.AccessController.getContext:()Ljava/security/AccessControlContext;
goto 12
StackMap locals:
StackMap stack:
11: aconst_null
StackMap locals:
StackMap stack: java.security.AccessControlContext
12: astore 4
start local 4 13: new jdk.internal.net.http.ResponseSubscribers$PathSubscriber
dup
aload 0
aload 1
aload 4
iconst_1
anewarray java.io.FilePermission
dup
iconst_0
aload 3
aastore
invokespecial jdk.internal.net.http.ResponseSubscribers$PathSubscriber.<init>:(Ljava/nio/file/Path;Ljava/util/List;Ljava/security/AccessControlContext;[Ljava/io/FilePermission;)V
areturn
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 14 0 file Ljava/nio/file/Path;
0 14 1 options Ljava/util/List<Ljava/nio/file/OpenOption;>;
1 14 2 sm Ljava/lang/SecurityManager;
2 14 3 filePermission Ljava/io/FilePermission;
4 7 4 fn Ljava/lang/String;
5 7 5 writePermission Ljava/io/FilePermission;
13 14 4 acc Ljava/security/AccessControlContext;
Exception table:
from to target type
3 7 8 Class java.lang.UnsupportedOperationException
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.security.AccessControlContext, java.io.FilePermission[]);
descriptor: (Ljava/nio/file/Path;Ljava/util/List;Ljava/security/AccessControlContext;[Ljava/io/FilePermission;)V
flags: (0x0080) ACC_VARARGS
Code:
stack=3, locals=5, args_size=5
start local 0 start local 1 start local 2 start local 3 start local 4 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
new java.util.concurrent.atomic.AtomicBoolean
dup
invokespecial java.util.concurrent.atomic.AtomicBoolean.<init>:()V
putfield jdk.internal.net.http.ResponseSubscribers$PathSubscriber.subscribed:Ljava/util/concurrent/atomic/AtomicBoolean;
3: aload 0
aload 1
putfield jdk.internal.net.http.ResponseSubscribers$PathSubscriber.file:Ljava/nio/file/Path;
4: 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;
5: aload 0
aload 3
putfield jdk.internal.net.http.ResponseSubscribers$PathSubscriber.acc:Ljava/security/AccessControlContext;
6: aload 0
aload 4
ifnull 7
aload 4
iconst_0
aaload
ifnonnull 8
7: StackMap locals: jdk.internal.net.http.ResponseSubscribers$PathSubscriber java.nio.file.Path java.util.List java.security.AccessControlContext java.io.FilePermission[]
StackMap stack: jdk.internal.net.http.ResponseSubscribers$PathSubscriber
getstatic jdk.internal.net.http.ResponseSubscribers$PathSubscriber.EMPTY_FILE_PERMISSIONS:[Ljava/io/FilePermission;
goto 9
StackMap locals:
StackMap stack: jdk.internal.net.http.ResponseSubscribers$PathSubscriber
8: aload 4
9: StackMap locals: jdk.internal.net.http.ResponseSubscribers$PathSubscriber java.nio.file.Path java.util.List java.security.AccessControlContext 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;
10: aload 0
aload 1
invokestatic jdk.internal.net.http.ResponseSubscribers$PathSubscriber.isDefaultFS:(Ljava/nio/file/Path;)Z
putfield jdk.internal.net.http.ResponseSubscribers$PathSubscriber.isDefaultFS:Z
11: return
end local 4 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 12 0 this Ljdk/internal/net/http/ResponseSubscribers$PathSubscriber;
0 12 1 file Ljava/nio/file/Path;
0 12 2 options Ljava/util/List<Ljava/nio/file/OpenOption;>;
0 12 3 acc Ljava/security/AccessControlContext;
0 12 4 filePermissions [Ljava/io/FilePermission;
Signature: (Ljava/nio/file/Path;Ljava/util/List<Ljava/nio/file/OpenOption;>;Ljava/security/AccessControlContext;[Ljava/io/FilePermission;)V
MethodParameters:
Name Flags
file
options
acc
filePermissions
private static boolean isDefaultFS(java.nio.file.Path);
descriptor: (Ljava/nio/file/Path;)Z
flags: (0x000a) ACC_PRIVATE, ACC_STATIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
invokeinterface java.nio.file.Path.toFile:()Ljava/io/File;
pop
1: iconst_1
ireturn
2: StackMap locals:
StackMap stack: java.lang.UnsupportedOperationException
pop
3: iconst_0
ireturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 file Ljava/nio/file/Path;
Exception table:
from to target type
0 1 2 Class java.lang.UnsupportedOperationException
MethodParameters:
Name Flags
file
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 1
invokestatic java.util.Objects.requireNonNull:(Ljava/lang/Object;)Ljava/lang/Object;
pop
1: aload 0
getfield jdk.internal.net.http.ResponseSubscribers$PathSubscriber.subscribed:Ljava/util/concurrent/atomic/AtomicBoolean;
iconst_0
iconst_1
invokevirtual java.util.concurrent.atomic.AtomicBoolean.compareAndSet:(ZZ)Z
ifne 4
2: aload 1
invokeinterface java.util.concurrent.Flow$Subscription.cancel:()V
3: return
4: StackMap locals:
StackMap stack:
aload 0
aload 1
putfield jdk.internal.net.http.ResponseSubscribers$PathSubscriber.subscription:Ljava/util/concurrent/Flow$Subscription;
5: aload 0
getfield jdk.internal.net.http.ResponseSubscribers$PathSubscriber.acc:Ljava/security/AccessControlContext;
ifnonnull 12
6: 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;
7: goto 30
StackMap locals:
StackMap stack: java.io.IOException
8: astore 2
start local 2 9: 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
10: aload 1
invokeinterface java.util.concurrent.Flow$Subscription.cancel:()V
11: return
end local 2 12: 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;
13: astore 2
start local 2 14: aload 0
aload 0
getfield jdk.internal.net.http.ResponseSubscribers$PathSubscriber.isDefaultFS:Z
ifeq 16
15: aload 2
aload 0
getfield jdk.internal.net.http.ResponseSubscribers$PathSubscriber.acc:Ljava/security/AccessControlContext;
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
goto 17
16: StackMap locals: jdk.internal.net.http.ResponseSubscribers$PathSubscriber java.util.concurrent.Flow$Subscription java.security.PrivilegedExceptionAction
StackMap stack: jdk.internal.net.http.ResponseSubscribers$PathSubscriber
aload 2
aload 0
getfield jdk.internal.net.http.ResponseSubscribers$PathSubscriber.acc:Ljava/security/AccessControlContext;
invokestatic java.security.AccessController.doPrivileged:(Ljava/security/PrivilegedExceptionAction;Ljava/security/AccessControlContext;)Ljava/lang/Object;
checkcast java.nio.channels.FileChannel
17: StackMap locals: jdk.internal.net.http.ResponseSubscribers$PathSubscriber java.util.concurrent.Flow$Subscription java.security.PrivilegedExceptionAction
StackMap stack: jdk.internal.net.http.ResponseSubscribers$PathSubscriber java.nio.channels.FileChannel
putfield jdk.internal.net.http.ResponseSubscribers$PathSubscriber.out:Ljava/nio/channels/FileChannel;
end local 2 18: goto 30
StackMap locals: jdk.internal.net.http.ResponseSubscribers$PathSubscriber java.util.concurrent.Flow$Subscription
StackMap stack: java.security.PrivilegedActionException
19: astore 2
start local 2 20: aload 2
invokevirtual java.security.PrivilegedActionException.getCause:()Ljava/lang/Throwable;
ifnull 21
aload 2
invokevirtual java.security.PrivilegedActionException.getCause:()Ljava/lang/Throwable;
goto 22
StackMap locals: java.security.PrivilegedActionException
StackMap stack:
21: aload 2
StackMap locals:
StackMap stack: java.lang.Throwable
22: astore 3
start local 3 23: 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
24: aload 1
invokeinterface java.util.concurrent.Flow$Subscription.cancel:()V
25: return
end local 3 end local 2 26: StackMap locals: jdk.internal.net.http.ResponseSubscribers$PathSubscriber java.util.concurrent.Flow$Subscription
StackMap stack: java.lang.Exception
astore 2
start local 2 27: 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
28: aload 1
invokeinterface java.util.concurrent.Flow$Subscription.cancel:()V
29: return
end local 2 30: StackMap locals:
StackMap stack:
aload 1
lconst_1
invokeinterface java.util.concurrent.Flow$Subscription.request:(J)V
31: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 32 0 this Ljdk/internal/net/http/ResponseSubscribers$PathSubscriber;
0 32 1 subscription Ljava/util/concurrent/Flow$Subscription;
9 12 2 ioe Ljava/io/IOException;
14 18 2 pa Ljava/security/PrivilegedExceptionAction<Ljava/nio/channels/FileChannel;>;
20 26 2 pae Ljava/security/PrivilegedActionException;
23 26 3 t Ljava/lang/Throwable;
27 30 2 e Ljava/lang/Exception;
Exception table:
from to target type
6 7 8 Class java.io.IOException
12 18 19 Class java.security.PrivilegedActionException
12 18 26 Class java.lang.Exception
MethodParameters:
Name Flags
subscription
public void onNext(java.util.List<java.nio.ByteBuffer>);
descriptor: (Ljava/util/List;)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, 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 6
StackMap locals:
StackMap stack: java.io.IOException
2: astore 2
start local 2 3: aload 0
invokevirtual jdk.internal.net.http.ResponseSubscribers$PathSubscriber.close:()V
4: aload 0
getfield jdk.internal.net.http.ResponseSubscribers$PathSubscriber.subscription:Ljava/util/concurrent/Flow$Subscription;
invokeinterface java.util.concurrent.Flow$Subscription.cancel:()V
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
end local 2 6: 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
7: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Ljdk/internal/net/http/ResponseSubscribers$PathSubscriber;
0 8 1 items Ljava/util/List<Ljava/nio/ByteBuffer;>;
3 6 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=2, 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
1: aload 0
invokevirtual jdk.internal.net.http.ResponseSubscribers$PathSubscriber.close:()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=2, locals=1, args_size=1
start local 0 0: aload 0
invokevirtual jdk.internal.net.http.ResponseSubscribers$PathSubscriber.close:()V
1: 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
2: 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;>;
private void close();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=2, args_size=1
start local 0 0: aload 0
getfield jdk.internal.net.http.ResponseSubscribers$PathSubscriber.acc:Ljava/security/AccessControlContext;
ifnonnull 3
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: goto 8
3: StackMap locals:
StackMap stack:
aload 0
invokedynamic run(Ljdk/internal/net/http/ResponseSubscribers$PathSubscriber;)Ljava/security/PrivilegedAction;
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$2()Ljava/lang/Void; (7)
()Ljava/lang/Void;
astore 1
start local 1 4: aload 0
getfield jdk.internal.net.http.ResponseSubscribers$PathSubscriber.isDefaultFS:Z
ifeq 7
5: aload 1
aload 0
getfield jdk.internal.net.http.ResponseSubscribers$PathSubscriber.acc:Ljava/security/AccessControlContext;
aload 0
getfield jdk.internal.net.http.ResponseSubscribers$PathSubscriber.filePermissions:[Ljava/io/FilePermission;
invokestatic java.security.AccessController.doPrivileged:(Ljava/security/PrivilegedAction;Ljava/security/AccessControlContext;[Ljava/security/Permission;)Ljava/lang/Object;
pop
6: goto 8
7: StackMap locals: java.security.PrivilegedAction
StackMap stack:
aload 1
aload 0
getfield jdk.internal.net.http.ResponseSubscribers$PathSubscriber.acc:Ljava/security/AccessControlContext;
invokestatic java.security.AccessController.doPrivileged:(Ljava/security/PrivilegedAction;Ljava/security/AccessControlContext;)Ljava/lang/Object;
pop
end local 1 8: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 9 0 this Ljdk/internal/net/http/ResponseSubscribers$PathSubscriber;
4 8 1 pa Ljava/security/PrivilegedAction<Ljava/lang/Void;>;
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
private java.lang.Void lambda$2();
descriptor: ()Ljava/lang/Void;
flags: (0x1002) ACC_PRIVATE, ACC_SYNTHETIC
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: aconst_null
areturn
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Ljdk/internal/net/http/ResponseSubscribers$PathSubscriber;
}
Signature: Ljava/lang/Object;Ljdk/internal/net/http/ResponseSubscribers$TrustedSubscriber<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 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
public abstract TrustedSubscriber = jdk.internal.net.http.ResponseSubscribers$TrustedSubscriber of jdk.internal.net.http.ResponseSubscribers