7+net/luminis/quic/send/PacketNumberGenerator  ()V    %net/luminis/quic/send/PacketAssembler(Lnet/luminis/quic/VersionHolder;Lnet/luminis/quic/EncryptionLevel;Lnet/luminis/quic/send/SendRequestQueue;Lnet/luminis/quic/AckGenerator;Lnet/luminis/quic/send/PacketNumberGenerator;)V java/lang/Object   quicVersion Lnet/luminis/quic/VersionHolder;  level"Lnet/luminis/quic/EncryptionLevel;   requestQueue(Lnet/luminis/quic/send/SendRequestQueue;   ackGeneratorLnet/luminis/quic/AckGenerator;  !"packetNumberGenerator-Lnet/luminis/quic/send/PacketNumberGenerator; $%& '(java/lang/Integermin(II)I * +, createPacket*([B[B)Lnet/luminis/quic/packet/QuicPacket;.java/util/ArrayList - 123 45&net/luminis/quic/send/SendRequestQueuemustAndWillSendAck()Z 789 :5net/luminis/quic/AckGeneratorhasNewAckToSend 7< => generateAck()Ljava/util/Optional; @AB CDjava/util/Optionalget()Ljava/lang/Object;Fnet/luminis/quic/frame/AckFrame EH IJgetFrameLength()I LMN OP"net/luminis/quic/packet/QuicPacketestimateLength(I)I LR STaddFrame%(Lnet/luminis/quic/frame/QuicFrame;)V V WXEMPTY_CALLBACKLjava/util/function/Consumer; Z[\ ]^java/util/Listadd(Ljava/lang/Object;)Z L` abgetPacketNumber()Ljava/lang/Long; def ghjava/lang/Long longValue()J 7j klregisterAckSendWithPacket%(Lnet/luminis/quic/frame/AckFrame;J)V 1n o addAckRequest @q r>empty 1t u5 hasRequests 7w x5 hasAckToSend @z {|orElse&(Ljava/lang/Object;)Ljava/lang/Object; 1~ 5hasProbeWithData 1 getProbe()Ljava/util/List; Z stream()Ljava/util/stream/Stream;  applyAsInt$()Ljava/util/function/ToIntFunction;  java/util/stream/StreammapToInt@(Ljava/util/function/ToIntFunction;)Ljava/util/stream/IntStream;  Jjava/util/stream/IntStreamsum net/luminis/quic/frame/PingFrame  H net/luminis/quic/frame/QuicFrame Z of$(Ljava/lang/Object;)Ljava/util/List; L  setIsProbe(Z)V L  addFrames(Ljava/util/List;)Vnet/luminis/quic/send/SendItem '(Lnet/luminis/quic/packet/QuicPacket;)V @ ((Ljava/lang/Object;)Ljava/util/Optional; 1 next(I)Ljava/util/Optional; @ 5isEmpty!net/luminis/quic/send/SendRequest getFrameSupplier()Ljava/util/function/Function; $ valueOf(I)Ljava/lang/Integer;  |java/util/function/Functionapplyjava/lang/RuntimeException makeConcatWithConstants8(IILnet/luminis/quic/frame/QuicFrame;)Ljava/lang/String; (Ljava/lang/String;)V getLostCallback()Ljava/util/function/Consumer; 1 5hasProbe L  getFrames Z  restorePacketNumber  createPacketLostCallbackS(Lnet/luminis/quic/packet/QuicPacket;Ljava/util/List;)Ljava/util/function/Consumer; D(Lnet/luminis/quic/packet/QuicPacket;Ljava/util/function/Consumer;)V  stoppingZ 1 (Z)Z  XfinalizerCallback  java/util/function/Consumeraccept(Ljava/lang/Object;)V  hnextPacketNumber  Z Jsizejava/lang/IllegalStateException  /(Ljava/util/List;)Ljava/util/function/Consumer;  'net/luminis/quic/send/PacketAssembler$1+$SwitchMap$net$luminis$quic$EncryptionLevel[I     J net/luminis/quic/EncryptionLevelordinal'net/luminis/quic/packet/HandshakePacket  net/luminis/quic/VersionHolder getVersion()Lnet/luminis/quic/Version;   C(Lnet/luminis/quic/Version;[B[BLnet/luminis/quic/frame/QuicFrame;)V)net/luminis/quic/packet/ShortHeaderPacket  A(Lnet/luminis/quic/Version;[BLnet/luminis/quic/frame/QuicFrame;)V%net/luminis/quic/packet/ZeroRttPacket    L# $%setPacketNumber(J)V 1' (clear* +6(Lnet/luminis/quic/EncryptionLevel;)Ljava/lang/String; Z- C.(I)Ljava/lang/Object;0  SignatureALjava/util/function/Consumer;JFLjava/util/function/Consumer;(Lnet/luminis/quic/VersionHolder;Lnet/luminis/quic/EncryptionLevel;Lnet/luminis/quic/send/SendRequestQueue;Lnet/luminis/quic/AckGenerator;)VCodeLineNumberTableLocalVariableTablethis'Lnet/luminis/quic/send/PacketAssembler;version pnGeneratorassemble(II[B[B)Ljava/util/Optional; probeFrame"Lnet/luminis/quic/frame/QuicFrame; probeDataLjava/util/List; estimatedSizeI proposedSizeLjava/util/Optional; nextFrame assembledItemremainingCwndSizeavailablePacketSizesourceConnectionId[BdestinationConnectionId availablepacket$Lnet/luminis/quic/packet/QuicPacket; callbacksackFrame!Lnet/luminis/quic/frame/AckFrame;optionalAckSizeLocalVariableTypeTable4Ljava/util/List;9Ljava/util/Optional;6Ljava/util/Optional;SLjava/util/List;>; StackMapTableL>(II[B[B)Ljava/util/Optional;(Lnet/luminis/quic/packet/QuicPacket;Ljava/util/List;>;)Ljava/util/function/Consumer;stop (Ljava/util/function/Consumer;)V finalizerI(Ljava/util/function/Consumer;)VtoString()Ljava/lang/String;!lambda$createPacketLostCallback$27(Ljava/util/List;Lnet/luminis/quic/packet/QuicPacket;)V lostFramei lostPacketlambda$assemble$1%(Lnet/luminis/quic/frame/QuicFrame;)Iflambda$static$0 SourceFilePacketAssembler.java NestMembersBootstrapMethodss tuv wx"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;z(Ljava/lang/Object;)I| } ijj  $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;Csupplier does not produce frame of right (max) size:  >  frame:   dePacketAssembler[]  lTT InnerClasses%java/lang/invoke/MethodHandles$Lookupjava/lang/invoke/MethodHandlesLookup! WX12!"3BX14 56g*+,-Y7 9:849:; 6 * *+*,*-**7<= >?@AB8> 9: ;    <"=>66#6*-):-Y/::*0[*6Q*;?E:GK)QUYW*_ci*mp6 3*s)*v*;yE: G6 *}k*:  K6  %Y:  Kp :  Y*sKd6   d d6 * :    d6 * :   ? :    Y   Ϳ  `6  Q ?йYW =  `3QUYW*_ci G`6 6 *ԙ5׹(*WYQUYW׹*۸p: Y*޷: *** ** 7CMOPRT&U0V?ZM[T\_]sezf~klnopqvwyz{|}(2@GQ\ip{ %(+BJP\gtx8?@ _AB BCD QED \F G@ @CD }HF 9:IDJDKLMLNDOPQBRS;TD &HF U4_AV \W }HX QY&HX ZTs [[LZE 7PZ:@ >b;@"1\h62*78 9:66*7 8 9:6!+׹, Y,78 !9:!OP!QBU !QYZ1]+,6w*.Z.B Y*+,N7Y*,N#Y*+,N Y -*!"-7* $69JMbemu8H6OPJOPbOPw9:wKLwMLm OPZ $L^_6e*+*&*7 89:`XU `41abc64 *)78  9: de6>=*4*,U!+,N*,-ȱ7 '7=8*'f@;gD>QB>hPZ 4 ij6/*7y8 k@ lT6+7,8 k@m6! /U7,nopq,ry{~rr