#NEWLINE# def next( self ) : #NEWLINE# #INDENT# ' Receives a message. If method is rep, must send reply before going to next(). The\n            message is unmarshalled and returned.\n        ' #NEWLINE# if ( ( not self . setup . block ) and ( not self . sock . poll ( timeout = 100 ) ) ) : #NEWLINE# #INDENT# raise StopIteration ( ) #NEWLINE# #UNINDENT# res = self . _decode ( self . sock . recv ( ) ) #NEWLINE# self . setup . debug ( 'Received %r from %s' , res , self . setup . point ) #NEWLINE# if self . active : #NEWLINE# #INDENT# return self . rpc ( res ) #NEWLINE# #UNINDENT# return self