Êþº¾ 4 J 9 : ; <
= >
? @ A B
readHeader '()Lcom/mysql/cj/protocol/MessageHeader;
Exceptions C Signature ()TH; probeHeader Code LineNumberTable LocalVariableTable this %Lcom/mysql/cj/protocol/MessageReader; LocalVariableTypeTable -Lcom/mysql/cj/protocol/MessageReader
; readMessage Z(Ljava/util/Optional;Lcom/mysql/cj/protocol/MessageHeader;)Lcom/mysql/cj/protocol/Message; !(Ljava/util/Optional;TH;)TM; probeMessage reuse Ljava/util/Optional; header %Lcom/mysql/cj/protocol/MessageHeader; Ljava/util/Optional; TH; 6(Ljava/util/Optional;I)Lcom/mysql/cj/protocol/Message; expectedType I (Ljava/util/Optional;I)TM;
skipPacket ()V pushMessageListener *(Lcom/mysql/cj/protocol/MessageListener;)V l 'Lcom/mysql/cj/protocol/MessageListener; ,Lcom/mysql/cj/protocol/MessageListener; /(Lcom/mysql/cj/protocol/MessageListener;)V getMessageSequence ()B resetMessageSequence
undecorateAll '()Lcom/mysql/cj/protocol/MessageReader; /()Lcom/mysql/cj/protocol/MessageReader| ;
undecorate start stopAfterNextMessage ^Ljava/lang/Object;
SourceFile MessageReader.java
8com/mysql/cj/exceptions/CJOperationNotSupportedException
Not supported D E F G H I #com/mysql/cj/protocol/MessageReader java/lang/Object java/io/IOException (com/mysql/cj/exceptions/ExceptionFactory createException J(Ljava/lang/Class;Ljava/lang/String;)Lcom/mysql/cj/exceptions/CJException; java/util/Optional empty ()Ljava/util/Optional;
C *¹ ° :
m *+,¹ ° [
! e ¸ À ¿ l " #
$ % & | |