#NEWLINE# def _on_read( self , handle , events , error ) : #NEWLINE# #INDENT# if error : #NEWLINE# #INDENT# handle . stop ( ) #NEWLINE# self . poller = None #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# res = None #NEWLINE# try : #NEWLINE# #INDENT# res = self . sock . accept ( ) #NEWLINE# #UNINDENT# except socket . error : #NEWLINE# #INDENT# exc_info = sys . exc_info ( ) #NEWLINE# ex = exc_info [ 1 ] #NEWLINE# if ( ( ex . args [ 0 ] != EWOULDBLOCK ) or ( self . timeout == 0.0 ) ) : #NEWLINE# #INDENT# self . task . throw ( * exc_info ) #NEWLINE# #UNINDENT# exc_clear ( ) #NEWLINE# #UNINDENT# if ( res is not None ) : #NEWLINE# #INDENT# ( client , addr ) = res #NEWLINE# self . _on_connection ( client , addr )