4 "Y Z[ \] ^ _ ` abc d ef gl mn mo p qr st suvw xy z{ z| } ~ z  e e CHUNK_SIZE_IN_BYTESI 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;>; inputStreamLjava/io/InputStream;8(Lorg/reactivestreams/Subscriber;Ljava/io/InputStream;)VCodeLineNumberTableLocalVariableTablethisDLcom/amazonaws/transcribestreaming/FileByteToAudioEventSubscription;sLocalVariableTypeTable(Lorg/reactivestreams/Subscriber<-Lsoftware/amazon/awssdk/services/transcribestreaming/model/AudioStream;>;Ljava/io/InputStream;)Vrequest(J)VnJ StackMapTablecancel()VaudioEventFromBuffer](Ljava/nio/ByteBuffer;)Lsoftware/amazon/awssdk/services/transcribestreaming/model/AudioEvent;bbLjava/nio/ByteBuffer;getNextByteBuffer()Ljava/nio/ByteBuffer; audioBytes[BlenJ Exceptionslambda$request$0 audioEventFLsoftware/amazon/awssdk/services/transcribestreaming/model/AudioEvent; audioBuffereLjava/lang/Exception; SourceFile%FileByteToAudioEventSubscription.java 2B ()&java/util/concurrent/atomic/AtomicLong 2= *+ ,- 01"java/lang/IllegalArgumentExceptionDemand must be positive 2 BootstrapMethodsB  B   Dsoftware/amazon/awssdk/services/transcribestreaming/model/AudioEventBcom/amazonaws/transcribestreaming/FileByteToAudioEventSubscription  GH CD B java/lang/Exceptionjava/lang/Object org/reactivestreams/Subscriptionjava/io/IOExceptionjava/nio/ByteBufferjava/util/concurrent/ExecutorsnewFixedThreadPool)(I)Ljava/util/concurrent/ExecutorService;(Ljava/lang/String;)Vorg/reactivestreams/SubscriberonError(Ljava/lang/Throwable;)V getAndAdd(J)J runZ(Lcom/amazonaws/transcribestreaming/FileByteToAudioEventSubscription;)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;java/io/InputStreamread([B)Iallocate(I)Ljava/nio/ByteBuffer;wrap([BII)Ljava/nio/ByteBuffer;get()J remaining()IonNext(Ljava/lang/Object;)V onCompletegetAndDecrement OB"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!"#$%&'()*+,-./01234#***Y *+*,5*% &+,"-6 #78#9-#01: #9/.;<=42 * Y * X**W5125!71K62782>?@AB48 *5 O P6  78CD4U+5ST US678EFGH4zL*+=+5Z\ ]^`6 78IJ K%@ LMNOB4Q* 9*L+*+M*,** XL*+ BE!5:9 :<>?(A+B4C7E?FBIEGFHPJ6* PQ.RFF STQ78@*U BV WXs h ijkj