#NEWLINE# def listen( self , timeout ) : #NEWLINE# #INDENT# while True : #NEWLINE# #INDENT# response = self . transport . run ( None , toTimeDeltaOrNone ( timeout ) ) #NEWLINE# if ( response is None ) : #NEWLINE# #INDENT# break #NEWLINE# #UNINDENT# if ( response and ( not isInternalActorSystemMessage ( response . message ) ) ) : #NEWLINE# #INDENT# return response . message #NEWLINE# #UNINDENT# #UNINDENT# return None