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

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

src/k/a/kamaelia-HEAD/Sketches/MPS/List/TaggingPluggableProcessor.py   kamaelia(Download)
                    self.removeChild(child)   # deregisters linkages for us
 
            if self.anyReady():
                # Means that we have data waiting from a processor
                self.send_on_results()
 
            if not self.anyReady():
    def send_on_results(self):
        inbox_ready = self.anyReady()
        while inbox_ready:
            bundle = self.lookup[inbox_ready]
            for message in self.Inbox(inbox_ready):
                self.send( (bundle["tag"], message), "outbox")
            inbox_ready = self.anyReady()

src/k/a/kamaelia-HEAD/Code/Python/Kamaelia/Kamaelia/Apps/JsonRPC/BDJsonRPC.py   kamaelia(Download)
                    print ('Dispatch:', dispatch_info)
                self.send(dispatch_info, self.worker_box_names[worker_num]['to'])
            if self.anyReady():
                for worker_num in range(len(self.workers)):
                    boxname = self.worker_box_names[worker_num]['from']
                            self.task_data[worker_num] = None  # mark that worker as done
                    yield 1
            if not self.anyReady():
                self.pause()
            yield 1

src/k/a/kamaelia-HEAD/Sketches/Contrib/jsonrpc/bdjsonrpc.py   kamaelia(Download)
                    print 'Dispatch:', dispatch_info
                self.send(dispatch_info, self.worker_box_names[worker_num]['to'])
            if self.anyReady():
                for worker_num in range(len(self.workers)):
                    boxname = self.worker_box_names[worker_num]['from']
                            self.task_data[worker_num] = None  # mark that worker as done
                    yield 1
            if not self.anyReady():
                self.pause()
            yield 1

src/k/a/kamaelia-HEAD/Code/Python/Kamaelia/Kamaelia/UI/OpenGL/OpenGLDisplay.py   kamaelia(Download)
            self.handleEvents()
            self.updateDisplay()
            while not self.anyReady():
                self.pause()
                yield 1

src/k/a/kamaelia-HEAD/Code/Python/Kamaelia/Kamaelia/Chassis/ConnectedServer.py   kamaelia(Download)
    def main(self):
        self.initialiseServerSocket()
        while 1:
            while not self.anyReady():
                self.pause()

src/k/a/kamaelia-HEAD/Sketches/JMB/Descartes/DescartesCore.py   kamaelia(Download)
    def main(self):
        self.initialiseServerSocket()
        while 1:
            while not self.anyReady():
                self.pause()

src/k/a/kamaelia-HEAD/Sketches/MPS/ConnectedServer.py   kamaelia(Download)
    def main(self):
        self.initialiseServerSocket()
        while 1:
            while not self.anyReady():
                self.pause()

src/k/a/kamaelia-HEAD/Sketches/JT/Jam/library/trunk/Kamaelia/Apps/Jam/Audio/Polyphony.py   kamaelia(Download)
                        self.voices[index] = None
                        self.send((address, arguments), "voice%i" % index)
            if not self.anyReady():
                self.pause()
            yield 1
                    index = arguments[0]
                    self.send((address, arguments), "voice%i" % index)
            if not self.anyReady():
                self.pause()
            yield 1

src/k/a/kamaelia-HEAD/Sketches/MPS/VideoConf/DemuxRemuxTuple.py   kamaelia(Download)
 
          # If there's nothing to do, then sleep
          while not self.anyReady() and not shutdown and not self.childrenDone():
              self.pause()
              yield 1

src/k/a/kamaelia-HEAD/Sketches/JT/Jam/library/trunk/Kamaelia/Apps/Jam/Internet/UDPDispatcher.py   kamaelia(Download)
                for peer in self.peers:
                    self.send(data, "outbox_%s_%s" % peer)
            if not self.anyReady():
                self.pause()
            yield 1

  1 | 2 | 3  Next