4 -g hi #jk l #m nop #qr #st #uv #wx #yz #{ #|}~    !   #    CHUNK_SIZE_IN_KBI ConstantValueexecutor&Ljava/util/concurrent/ExecutorService;demand(Ljava/util/concurrent/atomic/AtomicLong; subscriber Lorg/reactivestreams/Subscriber; SignaturejLorg/reactivestreams/Subscriber<-Lsoftware/amazon/awssdk/services/transcribestreaming/model/AudioStream;>;streamingMkvReader:Lcom/amazonaws/kinesisvideo/parser/mkv/StreamingMkvReader; contactIdLjava/lang/String; outputStreamLjava/io/OutputStream; tagProcessor=Lcom/amazonaws/kvstranscribestreaming/KVSContactTagProcessor;fragmentVisitorELcom/amazonaws/kinesisvideo/parser/utilities/FragmentMetadataVisitor;track(Lorg/reactivestreams/Subscriber;Lcom/amazonaws/kinesisvideo/parser/mkv/StreamingMkvReader;Ljava/lang/String;Ljava/io/OutputStream;Lcom/amazonaws/kvstranscribestreaming/KVSContactTagProcessor;Lcom/amazonaws/kinesisvideo/parser/utilities/FragmentMetadataVisitor;Ljava/lang/String;)VCodeLineNumberTableLocalVariableTablethisCLcom/amazonaws/transcribestreaming/KVSByteToAudioEventSubscription;sLocalVariableTypeTablec(Lorg/reactivestreams/Subscriber<-Lsoftware/amazon/awssdk/services/transcribestreaming/model/AudioStream;>;Lcom/amazonaws/kinesisvideo/parser/mkv/StreamingMkvReader;Ljava/lang/String;Ljava/io/OutputStream;Lcom/amazonaws/kvstranscribestreaming/KVSContactTagProcessor;Lcom/amazonaws/kinesisvideo/parser/utilities/FragmentMetadataVisitor;Ljava/lang/String;)Vrequest(J)VnJ StackMapTablecancel()VaudioEventFromBuffer](Ljava/nio/ByteBuffer;)Lsoftware/amazon/awssdk/services/transcribestreaming/model/AudioEvent;bbLjava/nio/ByteBuffer;lambda$request$0 audioEventFLsoftware/amazon/awssdk/services/transcribestreaming/model/AudioEvent; audioBytes[B audioBuffereLjava/lang/Exception; SourceFile$KVSByteToAudioEventSubscription.java FV 34&java/util/concurrent/atomic/AtomicLong FQ 56 org/reactivestreams/Subscriber 788com/amazonaws/kinesisvideo/parser/mkv/StreamingMkvReader ;<java/lang/String =>java/io/OutputStream ?@;com/amazonaws/kvstranscribestreaming/KVSContactTagProcessor ABCcom/amazonaws/kinesisvideo/parser/utilities/FragmentMetadataVisitor CD E>"java/lang/IllegalArgumentExceptionDemand must be positive F BootstrapMethodsV  V   Dsoftware/amazon/awssdk/services/transcribestreaming/model/AudioEvent Acom/amazonaws/transcribestreaming/KVSByteToAudioEventSubscription  WX V java/lang/Exceptionjava/lang/Object org/reactivestreams/Subscriptionjava/nio/ByteBufferjava/util/concurrent/ExecutorsnewFixedThreadPool)(I)Ljava/util/concurrent/ExecutorService;!org/apache/commons/lang3/ValidatenotNull&(Ljava/lang/Object;)Ljava/lang/Object;(Ljava/lang/String;)VonError(Ljava/lang/Throwable;)V getAndAdd(J)J #runY(Lcom/amazonaws/transcribestreaming/KVSByteToAudioEventSubscription;)Ljava/lang/Runnable;$java/util/concurrent/ExecutorServicesubmit3(Ljava/lang/Runnable;)Ljava/util/concurrent/Future;shutdownbuilderBuilder InnerClassesP()Lsoftware/amazon/awssdk/services/transcribestreaming/model/AudioEvent$Builder;$software/amazon/awssdk/core/SdkBytesfromByteBuffer=(Ljava/nio/ByteBuffer;)Lsoftware/amazon/awssdk/core/SdkBytes;Lsoftware/amazon/awssdk/services/transcribestreaming/model/AudioEvent$Builder audioChunkv(Lsoftware/amazon/awssdk/core/SdkBytes;)Lsoftware/amazon/awssdk/services/transcribestreaming/model/AudioEvent$Builder;build()Ljava/lang/Object;get()J-com/amazonaws/kvstranscribestreaming/KVSUtilsgetByteBufferFromStream(Lcom/amazonaws/kinesisvideo/parser/mkv/StreamingMkvReader;Lcom/amazonaws/kinesisvideo/parser/utilities/FragmentMetadataVisitor;Lcom/amazonaws/kvstranscribestreaming/KVSContactTagProcessor;Ljava/lang/String;ILjava/lang/String;)Ljava/nio/ByteBuffer; remaining()IonNext(Ljava/lang/Object;)V([B)Ljava/nio/ByteBuffer;write([B)V onCompletegetAndDecrement [V"java/lang/invoke/LambdaMetafactory metafactoryLookup(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;%java/lang/invoke/MethodHandles$Lookupjava/lang/invoke/MethodHandles!#-. /0123456789:;<=>?@ABCDE>FGHj***Y *+ *, *- **** I. 7+ ,8#9.:9;E<Q=]>i?JRjKLjM8j;<j=>j?@jABjCDjE>N jM:9OPQH2 * Y*X**WICDG!I1cJ2KL2RSTUVH8 *I g hJ  KLWXHU+ !Ikl mkJKLYZ[VH,z*" b* *** *$L+%+*+&M* ,'+%N+-(W*-)* **+XL* +kn,IFK M%O,Q2R<UCVIWQYTZ][`]h^kan_o`ybJ42\]C^_%C`Zo abzKLTSc Bd ef!