a !f@s^ddlZddlZddlZddlZddlZddlZedZGdddeZ GdddeZ dS)Nz\r\n\r\n|\r\r|\n\nc@s@eZdZd ddZddZddZd d Zd d Zej rs2      zSSEClient.__next__)Nr) __name__ __module__ __qualname__rrr$r%r:sixPY2r)rrrrrs (rc@s<eZdZedZd ddZddZed d Z d d Z dS)r1z#(?P[^:]*):?( ?(?P.*))?rmessageNcCs||_||_||_||_dSr)r3eventr4r )rr3rAr4r rrrrnszEvent.__init__cCstg}|jr|d|j|jdkr4|d|j|jrJ|d|j|dd|jdDd|dS) Nzid: %sr@z event: %sz retry: %scss|]}d|VqdS)zdata: %sNr).0drrr zEvent.dump..r&z )r4appendrAr extendr3r/r0)rlinesrrrdumpts z Event.dumpcCs|}|dD]}|j|}|dur:td|tq|d}|d}|dkr\q|dkr|jr|d|j|f|_q||_q|d kr||_q|d kr||_ q|d krt ||_ q|S) z| Given a possibly-multiline string representing an SSE message, parse it and return a Event object. r&NzInvalid SSE line: "%s"namevaluerr3z%s %srAr4r ) r/sse_line_patternmatchwarningswarn SyntaxWarning groupdictr3rAr4intr )clsrawr9linemrJrKrrrr2s*    z Event.parsecCs|jSr)r3r#rrr__str__sz Event.__str__)rr@NN) r;r<r=r compilerLrrI classmethodr2rWrrrrr1js    #r1) r r,rN threadingr>rrXr"objectrr1rrrrs \