public interface jdk.jfr.consumer.EventStream extends java.lang.AutoCloseable
  minor version: 0
  major version: 59
  flags: flags: (0x0601) ACC_PUBLIC, ACC_INTERFACE, ACC_ABSTRACT
  this_class: jdk.jfr.consumer.EventStream
  super_class: java.lang.Object
{
  public static jdk.jfr.consumer.EventStream openRepository();
    descriptor: ()Ljdk/jfr/consumer/EventStream;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=7, locals=0, args_size=0
         0: .line 140
            invokestatic jdk.jfr.internal.Utils.checkAccessFlightRecorder:()V
         1: .line 141
            new jdk.jfr.internal.consumer.EventDirectoryStream
            dup
            invokestatic java.security.AccessController.getContext:()Ljava/security/AccessControlContext;
            aconst_null
            getstatic jdk.jfr.internal.SecuritySupport.PRIVILEGED:Ljdk/jfr/internal/consumer/FileAccess;
            aconst_null
            invokestatic java.util.Collections.emptyList:()Ljava/util/List;
            invokespecial jdk.jfr.internal.consumer.EventDirectoryStream.<init>:(Ljava/security/AccessControlContext;Ljava/nio/file/Path;Ljdk/jfr/internal/consumer/FileAccess;Ljdk/jfr/internal/PlatformRecording;Ljava/util/List;)V
            areturn
      LocalVariableTable:
        Start  End  Slot  Name  Signature
    Exceptions:
      throws java.io.IOException

  public static jdk.jfr.consumer.EventStream openRepository(java.nio.file.Path);
    descriptor: (Ljava/nio/file/Path;)Ljdk/jfr/consumer/EventStream;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=7, locals=2, args_size=1
        start local 0 // java.nio.file.Path directory
         0: .line 162
            aload 0 /* directory */
            invokestatic java.util.Objects.nonNull:(Ljava/lang/Object;)Z
            pop
         1: .line 163
            invokestatic java.security.AccessController.getContext:()Ljava/security/AccessControlContext;
            astore 1 /* acc */
        start local 1 // java.security.AccessControlContext acc
         2: .line 164
            new jdk.jfr.internal.consumer.EventDirectoryStream
            dup
            aload 1 /* acc */
            aload 0 /* directory */
            getstatic jdk.jfr.internal.consumer.FileAccess.UNPRIVILEGED:Ljdk/jfr/internal/consumer/FileAccess;
            aconst_null
            invokestatic java.util.Collections.emptyList:()Ljava/util/List;
            invokespecial jdk.jfr.internal.consumer.EventDirectoryStream.<init>:(Ljava/security/AccessControlContext;Ljava/nio/file/Path;Ljdk/jfr/internal/consumer/FileAccess;Ljdk/jfr/internal/PlatformRecording;Ljava/util/List;)V
            areturn
        end local 1 // java.security.AccessControlContext acc
        end local 0 // java.nio.file.Path directory
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    3     0  directory  Ljava/nio/file/Path;
            2    3     1        acc  Ljava/security/AccessControlContext;
    Exceptions:
      throws java.io.IOException
    MethodParameters:
           Name  Flags
      directory  

  public static jdk.jfr.consumer.EventStream openFile(java.nio.file.Path);
    descriptor: (Ljava/nio/file/Path;)Ljdk/jfr/consumer/EventStream;
    flags: (0x0009) ACC_PUBLIC, ACC_STATIC
    Code:
      stack=4, locals=1, args_size=1
        start local 0 // java.nio.file.Path file
         0: .line 183
            new jdk.jfr.internal.consumer.EventFileStream
            dup
            invokestatic java.security.AccessController.getContext:()Ljava/security/AccessControlContext;
            aload 0 /* file */
            invokespecial jdk.jfr.internal.consumer.EventFileStream.<init>:(Ljava/security/AccessControlContext;Ljava/nio/file/Path;)V
            areturn
        end local 0 // java.nio.file.Path file
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  file  Ljava/nio/file/Path;
    Exceptions:
      throws java.io.IOException
    MethodParameters:
      Name  Flags
      file  

  public void onMetadata(java.util.function.Consumer<jdk.jfr.consumer.MetadataEvent>);
    descriptor: (Ljava/util/function/Consumer;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=0, locals=2, args_size=2
        start local 0 // jdk.jfr.consumer.EventStream this
        start local 1 // java.util.function.Consumer action
         0: .line 200
            return
        end local 1 // java.util.function.Consumer action
        end local 0 // jdk.jfr.consumer.EventStream this
      LocalVariableTable:
        Start  End  Slot    Name  Signature
            0    1     0    this  Ljdk/jfr/consumer/EventStream;
            0    1     1  action  Ljava/util/function/Consumer<Ljdk/jfr/consumer/MetadataEvent;>;
    Signature: (Ljava/util/function/Consumer<Ljdk/jfr/consumer/MetadataEvent;>;)V
    MethodParameters:
        Name  Flags
      action  

  public abstract void onEvent(java.util.function.Consumer<jdk.jfr.consumer.RecordedEvent>);
    descriptor: (Ljava/util/function/Consumer;)V
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Ljava/util/function/Consumer<Ljdk/jfr/consumer/RecordedEvent;>;)V
    MethodParameters:
        Name  Flags
      action  

  public abstract void onEvent(java.lang.String, java.util.function.Consumer<jdk.jfr.consumer.RecordedEvent>);
    descriptor: (Ljava/lang/String;Ljava/util/function/Consumer;)V
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Ljava/lang/String;Ljava/util/function/Consumer<Ljdk/jfr/consumer/RecordedEvent;>;)V
    MethodParameters:
           Name  Flags
      eventName  
      action     

  public abstract void onFlush(java.lang.Runnable);
    descriptor: (Ljava/lang/Runnable;)V
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    MethodParameters:
        Name  Flags
      action  

  public abstract void onError(java.util.function.Consumer<java.lang.Throwable>);
    descriptor: (Ljava/util/function/Consumer;)V
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Signature: (Ljava/util/function/Consumer<Ljava/lang/Throwable;>;)V
    MethodParameters:
        Name  Flags
      action  

  public abstract void onClose(java.lang.Runnable);
    descriptor: (Ljava/lang/Runnable;)V
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    MethodParameters:
        Name  Flags
      action  

  public abstract void close();
    descriptor: ()V
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT

  public abstract boolean remove(java.lang.Object);
    descriptor: (Ljava/lang/Object;)Z
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    MethodParameters:
        Name  Flags
      action  

  public abstract void setReuse(boolean);
    descriptor: (Z)V
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    MethodParameters:
       Name  Flags
      reuse  

  public abstract void setOrdered(boolean);
    descriptor: (Z)V
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    MethodParameters:
         Name  Flags
      ordered  

  public abstract void setStartTime(java.time.Instant);
    descriptor: (Ljava/time/Instant;)V
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    MethodParameters:
           Name  Flags
      startTime  

  public abstract void setEndTime(java.time.Instant);
    descriptor: (Ljava/time/Instant;)V
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    MethodParameters:
         Name  Flags
      endTime  

  public abstract void start();
    descriptor: ()V
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT

  public abstract void startAsync();
    descriptor: ()V
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT

  public abstract void awaitTermination(java.time.Duration);
    descriptor: (Ljava/time/Duration;)V
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Exceptions:
      throws java.lang.InterruptedException
    MethodParameters:
         Name  Flags
      timeout  

  public abstract void awaitTermination();
    descriptor: ()V
    flags: (0x0401) ACC_PUBLIC, ACC_ABSTRACT
    Exceptions:
      throws java.lang.InterruptedException
}
SourceFile: "EventStream.java"