#NEWLINE# def __init__( self , events ) : #NEWLINE# #INDENT# threading . Thread . __init__ ( self ) #NEWLINE# self . __queue = Queue . Queue ( ) #NEWLINE# self . __queue . put ( ( wsclient . WebSocketClient . ON_CONNECTED , None ) ) #NEWLINE# for event in self : #NEWLINE# #INDENT# self . __queue . put ( event ) #NEWLINE# #UNINDENT# self . __queue . put ( ( wsclient . WebSocketClient . ON_DISCONNECTED , None ) ) #NEWLINE# self . __stop = False