ت‏؛¾7é java/lang/Object()V %net/luminis/quic/stream/StreamManager connection%Lnet/luminis/quic/QuicConnectionImpl; roleLnet/luminis/quic/Role; logLnet/luminis/quic/log/Logger; net/luminis/quic/Roleother()Lnet/luminis/quic/Role; computeMaxStreamId(ILnet/luminis/quic/Role;Z)I !"maxOpenStreamIdUniI $%"maxOpenStreamIdBidi '()*+net/luminis/quic/Version getDefault()Lnet/luminis/quic/Version; -./quicVersionLnet/luminis/quic/Version;1&java/util/concurrent/ConcurrentHashMap 0 456streamsLjava/util/Map;8java/util/concurrent/Semaphore 7:;(I)V =>?openBidirectionalStreams Ljava/util/concurrent/Semaphore; AB?openUnidirectionalStreams DEServer GHClient' LMNOPjava/util/concurrent/TimeUnitDAYSLjava/util/concurrent/TimeUnit; RSTcreateStream@(ZJLjava/util/concurrent/TimeUnit;)Lnet/luminis/quic/QuicStream;V%java/util/concurrent/TimeoutExceptionXjava/lang/RuntimeException W[\]apply<()Lnet/luminis/quic/stream/StreamManager$QuicStreamSupplier; _S`…(ZJLjava/util/concurrent/TimeUnit;Lnet/luminis/quic/stream/StreamManager$QuicStreamSupplier;)Lnet/luminis/quic/stream/QuicStreamImpl; 7bcd tryAcquire#(JLjava/util/concurrent/TimeUnit;)Z Ugjava/lang/InterruptedExceptioni-blocked createStream operation is interruptedklmnonet/luminis/quic/log/Loggerdebug(Ljava/lang/String;)Vqoperation interrupted Uso uvwgenerateStreamId(Z)I yz{flowController%Lnet/luminis/quic/stream/FlowControl;}~\€8net/luminis/quic/stream/StreamManager$QuicStreamSupplier¬(Lnet/luminis/quic/Version;ILnet/luminis/quic/QuicConnectionImpl;Lnet/luminis/quic/stream/FlowControl;Lnet/luminis/quic/log/Logger;)Lnet/luminis/quic/stream/QuicStreamImpl; ‚ƒ„…†java/lang/IntegervalueOf(I)Ljava/lang/Integer;ˆ‰ٹ‹Œ java/util/Mapput8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; LژڈPMILLISECONDS[’'net/luminis/quic/stream/EarlyDataStream ”•"nextStreamId —ک™ڑ›"net/luminis/quic/frame/StreamFramegetStreamId()Iˆ‌‍ںget&(Ljava/lang/Object;)Ljava/lang/Object;،&net/luminis/quic/stream/QuicStreamImpl £¤¥add'(Lnet/luminis/quic/frame/StreamFrame;)V —§¨©isFinal()Z «¬isPeerInitiated(I)Z ¯°;increaseMaxOpenStreams ²³isUni µ¶isBidi¸¹؛makeConcatWithConstants(II)Ljava/lang/String; ¼½…(Lnet/luminis/quic/Version;ILnet/luminis/quic/QuicConnectionImpl;Lnet/luminis/quic/stream/FlowControl;Lnet/luminis/quic/log/Logger;)V ؟ہءpeerInitiatedStreamCallbackLjava/util/function/Consumer;أؤإئاjava/util/function/Consumeraccept(Ljava/lang/Object;)Vةnet/luminis/quic/TransportError ثجحخد1net/luminis/quic/QuicConstants$TransportErrorCodeSTREAM_LIMIT_ERROR3Lnet/luminis/quic/QuicConstants$TransportErrorCode; برز6(Lnet/luminis/quic/QuicConstants$TransportErrorCode;)Vش¹ص(I)Ljava/lang/String;k×طoerror عکغ'net/luminis/quic/frame/StopSendingFrame عفقكgetErrorCode()J لâمresetStream(J)V هکو'net/luminis/quic/frame/ResetStreamFrame هف هéêكgetFinalSize ىيîterminateStream(JJ)V ًٌٍmaxOpenStreamsUniUpdateQueuedZô\ُF(Lnet/luminis/quic/stream/StreamManager;)Ljava/util/function/Function; ÷ّùْû net/luminis/quic/EncryptionLevelApp"Lnet/luminis/quic/EncryptionLevel;‎ئ‏F(Lnet/luminis/quic/stream/StreamManager;)Ljava/util/function/Consumer; #net/luminis/quic/QuicConnectionImplsend`(Ljava/util/function/Function;ILnet/luminis/quic/EncryptionLevel;Ljava/util/function/Consumer;)V ٍmaxOpenStreamsBidiUpdateQueuedô $net/luminis/quic/ImplementationError &net/luminis/quic/frame/MaxStreamsFrame (JZ)V ©isAppliesToBidirectionalےےے createMaxStreamsUpdateBidi%(I)Lnet/luminis/quic/frame/QuicFrame; B(Lnet/luminis/quic/frame/QuicFrame;Ljava/util/function/Consumer;)V createMaxStreamsUpdateUni !ك getMaxStreams #$%maxStreamsAcceptedByPeerBidiLjava/lang/Long; '()*كjava/lang/Long longValue,¹-(IJ)Ljava/lang/String; '/…0(J)Ljava/lang/Long; 723;release 56%maxStreamsAcceptedByPeerUni,ˆ9:;values()Ljava/util/Collection;=>?@Ajava/util/Collectionstream()Ljava/util/stream/Stream; CئD()Ljava/util/function/Consumer;FGHIJjava/util/stream/StreamforEach (Ljava/util/function/Consumer;)V L¹M(J)Ljava/lang/String;ےےےQYServer initial max streams bidirectional is larger than supported; limiting to 2147483647S¹T%(Ljava/lang/Long;J)Ljava/lang/String;LWZServer initial max streams unidirectional is larger than supported; limiting to 2147483647 S Z[abort])net/luminis/quic/QuicClientConnectionImpl ‘_`‹(Lnet/luminis/quic/Version;ILnet/luminis/quic/QuicClientConnectionImpl;Lnet/luminis/quic/stream/FlowControl;Lnet/luminis/quic/log/Logger;)V SignatureLLjava/util/Map;;^(Lnet/luminis/quic/QuicConnectionImpl;Lnet/luminis/quic/Role;Lnet/luminis/quic/log/Logger;II)VCodeLineNumberTableLocalVariableTablethis'Lnet/luminis/quic/stream/StreamManager;quicConnectionmaxOpenStreamsUnimaxOpenStreamsBidi maxStreamspeerRole bidirectionalmaxStreamId StackMapTable (Z)Lnet/luminis/quic/QuicStream;e'Ljava/util/concurrent/TimeoutException;timeoutJtimeoutUnit Exceptionsacquired Ljava/lang/InterruptedException;unit streamFactory:Lnet/luminis/quic/stream/StreamManager$QuicStreamSupplier;streamId(Lnet/luminis/quic/stream/QuicStreamImpl;createEarlyDataStream,(Z)Lnet/luminis/quic/stream/EarlyDataStream;idsetFlowController((Lnet/luminis/quic/stream/FlowControl;)Vprocessframe$Lnet/luminis/quic/frame/StreamFrame;‰java/lang/Throwable,(Lnet/luminis/quic/frame/StopSendingFrame;)VstopSendingFrame)Lnet/luminis/quic/frame/StopSendingFrame;,(Lnet/luminis/quic/frame/ResetStreamFrame;)VresetStreamFrame)Lnet/luminis/quic/frame/ResetStreamFrame;maxSizeretransmitMaxStreams%(Lnet/luminis/quic/frame/QuicFrame;)V"Lnet/luminis/quic/frame/QuicFrame; lostFrame(Lnet/luminis/quic/frame/MaxStreamsFrame;+(Lnet/luminis/quic/frame/MaxStreamsFrame;)V incrementabortAllsetPeerInitiatedStreamCallbackstreamProcessorLocalVariableTypeTable?(Ljava/util/function/Consumer;)VsetInitialMaxStreamsBidiinitialMaxStreamsBidisetInitialMaxStreamsUniinitialMaxStreamsUnigetMaxBidirectionalStreamsgetMaxUnirectionalStreamslambda$abortAll$2+(Lnet/luminis/quic/stream/QuicStreamImpl;)Vslambda$createEarlyDataStream$1loggerlambda$createStream$0 SourceFileStreamManager.javaNestMembersBootstrapMethods® ¯°±²³"java/lang/invoke/LambdaMetafactorymetafactoryج(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/StringConcatFactoryک(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/invoke/CallSite;آ?B?ٌٍٍdeà\*·*+µ*,µ *-µ**,¶¶µ**,¶¶µ#*¸&µ,*»0Y·2µ3*»7Y·9µ<*»7Y·9µ@±f.:; <=>"?1@8ACBOC[Dg>\hi\j\\\k"\l"e®2h6,²C¦ ™„,²F¦ ڑ„,²F¦ ™„¬f"KMNQR!U,V/Xg42hi2m"2n2oٍ-p"qü Sreo*I²K¶Q°M»WY·Y؟Uf]^ `g sthioٍqLUSTeV* ؛Z¶^°feg*hioٍuvwPxUS`eM|™*´< ¶a6§*´@ ¶a6ڑ»UY·e؟§:*´h¹j»UYp·r؟*¶t6*´,*´*´x*´¹|:*´3¸پ¹‡W°,/ff6 lmpr$s,x/u1v<wFzM{h|y}gf yٍ yٍ1sz|hi|oٍ|uv|{P||}M/~"h@qüْBfxU€پeo* ²چ؛گ¶^ہ‘°M°Ufˆٹ‹g sthioٍqRU"vwe“**´“x*´ ²F¦§`=ڑ„*Y´“`µ“¬f“”—™(ڑg *hi*oٍ‚"qTےüƒ„e>*+µx±f ں ghiz{…¥e¼ً+¶–=*´3¸پ¹œہ N-ئ-+¶¢+¶¦™ج*¶ھ™ؤ*¶®§¼*¶ھ™¥*Y:آ*¶±™*´،*¶´™l*´#¢d*´l`؛·¹j» Y*´,*´*´x*´·»N*´3¸پ-¹‡W-+¶¢*´¾ئ *´¾-¹آ+¶¦™*¶®§»بY²ت·ذ؟أ§:أ؟§*´؛س¹ض±CزصصعصfV£¤¥¦©.ھ6®>¯C°c±w²گ³ں´¤µ«¶µ¸¼¹ؤہدآàإïبg*ًhiً†‡ë~"ع@q ‎6 üûQ Eˆْxب…ٹey!*´3+¶ظ¸پ¹œہ M,ئ,+¶ـ¶à±fحخذ زg !hi!‹Œ @qü …چe}%*´3+¶ن¸پ¹œہ M,ئ,+¶ç+¶è¶ë±fصضط$عg %hi%ژڈ@qü$ °;eüv*YMآ*¶±™4*Y´`µ*´ïڑQ*´*؛َ ²ِ*؛ü¶ے*µï§1*Y´#`µ#*´ڑ *´*؛ ²ِ*؛ü¶ے*µ,أ§N,أ-؟±mppspf2فقكàل5â=هGوNçfèkëuىgvhiv~"qü=-Dˆْe¦1 ¢» Y·؟*YMآ*µï,أ§N,أ-؟»Y*´l…·°fïًٍَô!÷g1hi1گ"qے ˆْe¦1 ¢» Y·؟*YMآ*µ,أ§N,أ-؟»Y*´#l…·°fûü‏ے!g1hi1گ"qے ˆْ‘’e•8+ہM,¶™*´*¶*؛ü¶§*´*¶*؛ü¶±f #7g 8hi8†“3”•q ü#¬eip*´ ²F¦§ §¬fghi~"qQے@³eL p¤§¬fg hi ~"q@¶eL p¢§¬fg hi ~"q@!…–e‘+¶™I+¶*´"¶&”‍}+¶*´"¶&eˆ=*´+¶؛+¹j*+¶¸.µ"*´<¶1§F+¶*´4¶&”‍7+¶*´4¶&eˆ=*´+¶؛7¹j*+¶¸.µ4*´@¶1±f6 $ 7!B"J#M&\'j(})ˆ*گ-g*$&—"j&—"‘hi‘†•qûMûBکeG*´3¹8¹<؛B¹E±f 01ghi!™JeP*+µ¾±f 45ghiڑء›ڑcaœ!‌مeآb*´"ئ*´"¶&”›>*´؛K¹j*¸.µ"N”‍*´P¹ضN@*´<ˆ¶1§*´*´"؛R¹ض±f& <=">*?2@>ABCNFaHgbhib‍vq.!ںمeآb*´4ئ*´4¶&”›>*´؛U¹j*¸.µ4N”‍*´V¹ضN@*´@ˆ¶1§*´*´4؛X¹ض±f& OP"Q*R2S>TBVNYa[gbhib vq.!،كe2*´"¶&f^ghi!¢كe2*´4¶&fbghi £¤e/*¶Y±f0g¥ ¦€ec»‘Y*,ہ\-·^°f‰g4./~"z{§ ¨€e`» Y*,-·»°ffg4./~"z{§©ھ«}¬n´µ´´¸´»ء»أإئاةتحإخا»د»رةسض»×»ظ»غ»فك}àثلم@نوè