7  java/lang/Object()V   net/luminis/quic/Receiver isClosingZ   changing  socketLjava/net/DatagramSocket;  logLnet/luminis/quic/log/Logger;   abortCallbackLjava/util/function/Consumer;java/lang/Thread !run1(Lnet/luminis/quic/Receiver;)Ljava/lang/Runnable;#receiver % &)(Ljava/lang/Runnable;Ljava/lang/String;)V ( )*receiverThreadLjava/lang/Thread; , -. setDaemon(Z)V0(java/util/concurrent/LinkedBlockingQueue / 3 45receivedPacketsQueue$Ljava/util/concurrent/BlockingQueue; 789 :;java/net/DatagramSocketgetReceiveBufferSize()I= >?makeConcatWithConstants(I)Ljava/lang/String; ABC DEnet/luminis/quic/log/Loggerdebug(Ljava/lang/String;)VGjava/net/SocketException I Jstart L M interrupt OPQ RS"java/util/concurrent/BlockingQueuetake()Ljava/lang/Object;Unet/luminis/quic/RawPacket OW XYisEmpty()Z [\] ^_java/util/concurrent/TimeUnitSECONDSLjava/util/concurrent/TimeUnit; Oa bcpoll4(JLjava/util/concurrent/TimeUnit;)Ljava/lang/Object;ejava/net/DatagramPacket dg h([BI)V 7j klreceive(Ljava/net/DatagramPacket;)V nop qrjava/time/Instantnow()Ljava/time/Instant; Tt u0(Ljava/net/DatagramPacket;Ljava/time/Instant;I)V Ow xyadd(Ljava/lang/Object;)Z{java/net/SocketTimeoutException}9Ignoring socket closed exception, because changing socket A D*(Ljava/lang/String;Ljava/lang/Exception;)VTerminating receive loopjava/io/IOException%IOException while receiving datagrams A error*(Ljava/lang/String;Ljava/lang/Throwable;)V  java/util/function/Consumeraccept(Ljava/lang/Object;)Vclosing receiverjava/lang/Throwable 7 close  MAX_DATAGRAM_SIZEI ConstantValue Signature4Ljava/util/function/Consumer;BLjava/util/concurrent/BlockingQueue;V(Ljava/net/DatagramSocket;Lnet/luminis/quic/log/Logger;Ljava/util/function/Consumer;)VCodeLineNumberTableLocalVariableTablethisLnet/luminis/quic/Receiver;LocalVariableTypeTable StackMapTablem(Ljava/net/DatagramSocket;Lnet/luminis/quic/log/Logger;Ljava/util/function/Consumer;)Vshutdownget()Lnet/luminis/quic/RawPacket; Exceptionsjava/lang/InterruptedExceptionhasMore(I)Lnet/luminis/quic/RawPacket;timeout timeReceivedLjava/time/Instant; rawPacketLnet/luminis/quic/RawPacket; socketErrorLjava/net/SocketException; receiveBuffer[BreceivedPacketLjava/net/DatagramPacket;eLjava/io/IOException;fatalLjava/lang/Throwable;counter changeAddress(Ljava/net/DatagramSocket;)V newSocket oldSocket lambda$new$0 SourceFile Receiver.javaBootstrapMethods  "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;    >$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;Socket receive buffer size:  InnerClasses%java/lang/invoke/MethodHandles$Lookupjava/lang/invoke/MethodHandlesLookup!B)*45B B  X*** *+*,*-*Y*"$'*'+*/Y12,+6<@:CRUF6 1. /23460788C;R>U<W?*XXXX XU7AFJ6*'H BC ? **'KFG H  7 *2NTK  YG*2VO @F*2Z`TY <*iܼMdY,,fN*-im:TY-s:*2vW):$:* *|~* *@IM**,*,*@M*,*,CFzCKFz}zv]` abd"f'g7hCvFjHvKmMnTpaqitlwoyz}{~|~\ '7 M]R~+: CdzDFFM  Bb*M*+* ,  /*6