#NEWLINE# def __init__( self , director , peer ) : #NEWLINE# #INDENT# if _debug : #NEWLINE# #INDENT# TCPClientActor . _debug ( '__init__ %r %r' , director , peer ) #NEWLINE# #UNINDENT# TCPClient . __init__ ( self , peer ) #NEWLINE# self . director = director #NEWLINE# self . timeout = director . timeout #NEWLINE# if ( self . timeout > 0 ) : #NEWLINE# #INDENT# self . timer = FunctionTask ( self . idle_timeout ) #NEWLINE# self . timer . install_task ( ( _time ( ) + self . timeout ) ) #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# self . timer = None #NEWLINE# #UNINDENT# self . flushTask = None #NEWLINE# self . director . add_actor ( self )