7net/luminis/quic/log/NullLogger  ()V    #net/luminis/quic/stream/FlowControl;(Lnet/luminis/quic/Role;JJJJLnet/luminis/quic/log/Logger;)V java/lang/Object  roleLnet/luminis/quic/Role;  initialMaxDataJ  initialMaxStreamDataBidiLocal  initialMaxStreamDataBidiRemote  initialMaxStreamDataUni ! "#logLnet/luminis/quic/log/Logger;%&java/util/concurrent/ConcurrentHashMap $ ( )*streamListenersLjava/util/Map; , -maxDataAllowed / 0maxDataAssigned2java/util/HashMap 1 5 6*maxStreamDataAllowed 8 9*maxStreamDataAssigned ;<= >?net/luminis/quic/QuicStream getStreamId()I A BCcurrentStreamCredits (Lnet/luminis/quic/QuicStream;)J EFG HIjava/lang/IntegervalueOf(I)Ljava/lang/Integer; KLM NO java/util/Mapget&(Ljava/lang/Object;)Ljava/lang/Object;Qjava/lang/Long PS TU longValue()J PW XYmin(JJ)J["java/lang/IllegalArgumentException Z P^ H_(J)Ljava/lang/Long; Ka bcput8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; Pe fgequals(Ljava/lang/Object;)Z ijk lm#net/luminis/quic/stream/BlockReasonSTREAM_DATA_BLOCKED%Lnet/luminis/quic/stream/BlockReason; io pm DATA_BLOCKED ir sm NOT_BLOCKED uvw xnet/luminis/quic/RoleServerz$net/luminis/quic/ImplementationError y }~ U$net/luminis/quic/TransportParametersgetInitialMaxData makeConcatWithConstants(JJ)Ljava/lang/String;  net/luminis/quic/log/Loggerinfo(Ljava/lang/String;)V error } U getInitialMaxStreamDataBidiLocal K entrySet()Ljava/util/Set;   java/util/Setstream()Ljava/util/stream/Stream; test ()Ljava/util/function/Predicate;  java/util/stream/Streamfilter9(Ljava/util/function/Predicate;)Ljava/util/stream/Stream; acceptj(Lnet/luminis/quic/stream/FlowControl;Lnet/luminis/quic/TransportParameters;)Ljava/util/function/Consumer; forEach (Ljava/util/function/Consumer;)V } U!getInitialMaxStreamDataBidiRemote } UgetInitialMaxStreamDataUni K Oremove K g containsKey  CdetermineInitialMaxStreamData  maxOpenedStreamIdI ; isUnidirectional()Z u Client ; isClientInitiatedBidirectional ; isServerInitiatedBidirectional  U#net/luminis/quic/frame/MaxDataFrame getMaxData F(Lnet/luminis/quic/stream/FlowControl;)Ljava/util/function/BiConsumer; K "(Ljava/util/function/BiConsumer;)V <)net/luminis/quic/frame/MaxStreamDataFrame 1net/luminis/quic/stream/FlowControlUpdateListener streamNotBlocked(I)V  locallyInitiated(I)Znet/luminis/quic/TransportError  1net/luminis/quic/QuicConstants$TransportErrorCodeSTREAM_STATE_ERROR3Lnet/luminis/quic/QuicConstants$TransportErrorCode; 6(Lnet/luminis/quic/QuicConstants$TransportErrorCode;)V E ?intValue  java/util/Map$EntrygetValue()Ljava/lang/Object;  getKey Signature4Ljava/util/Map;WLjava/util/Map;(Lnet/luminis/quic/Role;JJJJ)VCodeLineNumberTableLocalVariableTablethis%Lnet/luminis/quic/stream/FlowControl;increaseFlowControlLimit!(Lnet/luminis/quic/QuicStream;J)JpossibleStreamIncrementrequestedIncrementproposedStreamIncrementnewStreamLimitLnet/luminis/quic/QuicStream;requestedLimitstreamId StackMapTablejava/lang/ThrowablegetFlowControlLimitgetFlowControlBlockReasonD(Lnet/luminis/quic/QuicStream;)Lnet/luminis/quic/stream/BlockReason;getConnectionDataLimitupdateInitialValues)(Lnet/luminis/quic/TransportParameters;)VpeerTransportParameters&Lnet/luminis/quic/TransportParameters;registerS(Lnet/luminis/quic/QuicStream;Lnet/luminis/quic/stream/FlowControlUpdateListener;)Vlistener3Lnet/luminis/quic/stream/FlowControlUpdateListener; unregister (Lnet/luminis/quic/QuicStream;)V streamOpened streamClosedallowedByStreammaxStreamIncrementmaxPossibleDataIncrementprocess((Lnet/luminis/quic/frame/MaxDataFrame;)VmaxDataWasReachedZframe%Lnet/luminis/quic/frame/MaxDataFrame;.(Lnet/luminis/quic/frame/MaxStreamDataFrame;)VstreamWasBlocked maxStreamData+Lnet/luminis/quic/frame/MaxStreamDataFrame; Exceptionslambda$process$6I(Ljava/lang/Integer;Lnet/luminis/quic/stream/FlowControlUpdateListener;)VLjava/lang/Integer;streamWasBlockedByMaxDataOnlylambda$updateInitialValues$5>(Lnet/luminis/quic/TransportParameters;Ljava/util/Map$Entry;)VentryLjava/util/Map$Entry;lambda$updateInitialValues$4(Ljava/util/Map$Entry;)Zlambda$updateInitialValues$3lambda$updateInitialValues$2lambda$updateInitialValues$1lambda$updateInitialValues$0 SourceFileFlowControl.javaBootstrapMethodsH IJK L$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;N'Increasing initial max data from  to P7Ignoring attempt to reduce initial max data from  to R STU VW"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;gZ [ C??^(Ljava/lang/Object;)V` a B;c(Ljava/util/Map$Entry;)Ve/Ignoring attempt to reduce max data from  to g h A?j k @;m n >?p q :;s'(Ljava/lang/Object;Ljava/lang/Object;)Vu v 677 InnerClassesznet/luminis/quic/QuicConstantsTransportErrorCodeEntry~%java/lang/invoke/MethodHandles$Lookupjava/lang/invoke/MethodHandlesLookup! -06*9*"#)*t *+ Y HI >    R* *+* **** *$Y&'* +* .*1Y34*1Y376 KL MNOP Q&R1T6U;VFWQX HR  RRRRRR"#   h+:6*Y:*+@7 *7DJPRe7V7  ZY\*Y. a.*7DJPR a7 *7D ]`W í: 2 cd ef,g5i<jDmOnho|qr Rn,V5M h   ,D; =; C**YM*7+:DJPR*+@a,íN,-$%%(%|}%~ *  *%; B+:=*7DJP*4DJdh*+*.nq*.:> B  B;.U/*+   !n*t yY{+|*0* *+|+|*+0*+|+%+|** *+|+*@* *+*4*+%+** *++*@* *+*4*+%+** *++*@* *+*4*+%+** *+z 4@KWmy !-COex    8!H!H!H! !W*'+:D,`W    "#$%L*'+:DW    &%]+:=*YN*4D+*4D*+]`W*7D ]`W*¤*-ç :- RUUYU&  1CKP\ ]  ]VC D'%4+:=*YN*7DW*4DW-ç :- ),,0, '3 4  4-,; Cl+**ʦ +*t+**ʦ +*t+*yY{& ,49W_ d l  l BC L+:=*4DJPRB!*7DJPRe7*+*.e772=EI! >L  LE1(2)=*I;+,J*YM+*+0*+*.>*+ӵ+*'*,ç :,?BBFB"%'(")**.+=3I4 "-.J  J/0  @D+1*YM+>+7*4D*4DJPR*7DJPR*4DJPR*.*+6*4D]`W*'DJ**¤Y,ç :,:78 9:<8=u?@ACIJMN 4u.2. 3  /4r @/D5n#*ʦppQ RU #  # @ @67,*7+J*4+J> ,+,-!.+0 *,  ,8,"#9. @:;~/+,PR*4,E+]`W. /  //<=. >?M*Ep <=@@;~/+,PR*4,E+]`W. /  //<=. A?L*Ep <=@B;~/+,PR*4,E+]`W. /  //<=. C?M*Ep <=@DEFZ GMGOQXY\Q]_bGdQXf\Q]ibQXl\Q]obQrtwxy{@K| }