Did I find the right examples for you? yes no      Crawl my project      Python Jobs

All Samples(11)  |  Call(11)  |  Derive(0)  |  Import(0)

src/k/a/kamaelia-HEAD/Sketches/MPS/Examples/AIM/MultiAIMBot.py   kamaelia(Download)
        while not self.dataReady("control"):
            yield 1
            for message in self.Inbox():
                print "PROCESSING MESSAGE", message
                if self.demuxFilter(message):

src/k/a/kamaelia-HEAD/Sketches/MPS/List/TaggingPluggableProcessor.py   kamaelia(Download)
    def main(self):
        self.lookup = {}
        while not self.dataReady("control"):
            for processor_request in self.Inbox("processor"):
                self.add_processor(processor_request)
 
            for data in self.Inbox("inbox"):
    def send_on_results(self):
        inbox_ready = self.anyReady()
        while inbox_ready:
            bundle = self.lookup[inbox_ready]
            for message in self.Inbox(inbox_ready):

src/k/a/kamaelia-HEAD/Sketches/MPS/VideoConf/DemuxRemuxTuple.py   kamaelia(Download)
          if self.policy == None:
              # Default policy: discard all messages sent to the main inbox
              for msg in self.Inbox("inbox"):
                  i = 0
                  for c in self.components:
              # Default policy, pass on all control messages to all sub components
              # Shutdown the PAR component if the message is a shutdownMicroprocess message
              for msg in self.Inbox("control"):
                  for c in self.components:
 

src/k/a/kamaelia-HEAD/Sketches/MPS/DemuxRemuxTuple.py   kamaelia(Download)
          if self.policy == None:
              # Default policy: discard all messages sent to the main inbox
              for msg in self.Inbox("inbox"):
                  i = 0
                  for c in self.components:
              # Default policy, pass on all control messages to all sub components
              # Shutdown the PAR component if the message is a shutdownMicroprocess message
              for msg in self.Inbox("control"):
                  for c in self.components:
 

src/k/a/kamaelia-HEAD/Code/Python/Kamaelia/Kamaelia/UI/OpenGL/OpenGLDisplay.py   kamaelia(Download)
                    events.append(event)
 
            for _ in self.Inbox("events"): pass # clear pending event messages
 
            if events != []:

src/k/a/kamaelia-HEAD/Sketches/MPS/Axon.DSL/Axon/DSL/MultiAIMBot.py   kamaelia(Download)
        while not self.dataReady("control"):
            yield 1
            for message in self.Inbox():
                print "PROCESSING MESSAGE", message
                if self.demuxFilter(message):

src/k/a/kamaelia-HEAD/Sketches/MPS/BugReports/FixTests/Kamaelia/Kamaelia/UI/OpenGL/OpenGLDisplay.py   kamaelia(Download)
                    events.append(event)
 
            for _ in self.Inbox("events"): pass # clear pending event messages
 
            if events != []: