#NEWLINE# def scatter( self , method , args = { #NEWLINE# #INDENT# #NEWLINE# #UNINDENT# } , nowait = False , timeout = None , **kwargs ) : #NEWLINE# #INDENT# 'Broadcast method to all agents.\n\n        if nowait is False, returns generator to iterate over the results.\n\n        :keyword limit: Limit number of reads from the queue.\n            Unlimited by default.\n        :keyword timeout: the timeout (in float seconds) waiting for replies.\n            Default is :attr:`default_timeout`.\n\n         **Examples**\n\n        ``scatter`` is a generator (if nowait is False)::\n            >>> res = scatter()\n            >>> res.next() # one event consumed, or timed out.\n\n            >>> res = scatter(limit=2):\n            >>> for i in res:  # two events consumed or timeout\n            >>>     pass\n\n        See :meth:`call_or_cast` for a full list of supported\n        arguments.\n\n        ' #NEWLINE# timeout = ( timeout if ( timeout is not None ) else self . default_timeout ) #NEWLINE# r = self . call_or_cast ( method , args , type = ACTOR_TYPE . SCATTER , nowait = nowait , timeout = timeout , ** kwargs ) #NEWLINE# if ( not nowait ) : #NEWLINE# #INDENT# return r . gather ( timeout = timeout , ** kwargs )