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

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

src/k/a/kamaelia-HEAD/Sketches/MPS/Experiments/Likefile2/likefile/LikeFile.py   kamaelia(Download)
 
          while self.dataReady("_inbox"):
              self.outboundData.put( (self.recv("_inbox"), "outbox") )
          while self.dataReady("_control"):
              self.outboundData.put( (self.recv("_control"), "signal") )

src/k/a/kamaelia-HEAD/Code/Python/Kamaelia/Kamaelia/Apps/SocialBookmarks/TwitterStream.py   kamaelia(Download)
    def finished(self):
        while self.dataReady("control"):
            msg = self.recv("control")
            # Print("Message on control inbox", msg)
            if isinstance(msg, producerFinished) or isinstance(msg, shutdownMicroprocess):
                    self.datacapture = None
                    # Print("We now believe the subcomponent is dead. Probably erroneously...", self)
                recvdata = self.recv("inbox")
                keywords = recvdata[0]
                if len(keywords) > 400:
            while self.dataReady("tweetsin"):
                counter = 0
                tweetdata = self.recv("tweetsin")
                if tweetdata[0] == "\r\n":
                    blanklinecount += 1

src/k/a/kamaelia-HEAD/Code/Python/Axon/Axon/Handle.py   kamaelia(Download)
 
          while self.dataReady("_inbox"):
              self.outboundData.put( (self.recv("_inbox"), "outbox") )
          while self.dataReady("_control"):
              self.outboundData.put( (self.recv("_control"), "signal") )

src/k/a/kamaelia-HEAD/Sketches/MPS/Systems/AIM/AIM_NotHere.py   kamaelia(Download)
                    self.pause()
            while self.dataReady("inbox"):
                x = repr(self.recv("inbox"))
                print x
 
    def main(self):
        while not self.shutdown() and not self.quit:
            while self.dataReady("inbox"):
                data = self.recv("inbox")
#                print repr(data)
            return True
        while self.dataReady("control"):
            msg=self.recv("control")
            if isinstance(msg,producerFinished) or isinstance(msg,shutdownMicroprocess):
                self.shutdownMessage = msg

src/k/a/kamaelia-HEAD/Sketches/MPS/Experiments/Likefile2/likefile/deprecated/ThreadWrap.py   kamaelia(Download)
 
          while self.dataReady("_inbox"):
              self.outboundData.put( (self.recv("_inbox"), "outbox") )
          while self.dataReady("_control"):
              self.send(self.recv("_control"), "signal")

src/k/a/kamaelia-HEAD/Code/Python/Kamaelia/Kamaelia/Apps/SocialBookmarks/BBCProgrammes.py   kamaelia(Download)
    def finished(self):
        while self.dataReady("control"):
            msg = self.recv("control")
            if isinstance(msg, producerFinished) or isinstance(msg, shutdownMicroprocess):
                self.send(msg, "signal")
    def main(self):
        while not self.finished():
            if self.dataReady("inbox"):
                channel = self.recv("inbox")
                time.sleep(1) # Temporary delay to ensure not hammering /programmes
                        self.pause()  # Add timeout ?
#                        yield 1
                    recvdata = self.recv("datain")
                    if recvdata[0] == "OK":
                        content = recvdata[1]
                    self.pause()  # FIXME Add timeout?
#                    yield 1
                recvdata = self.recv("datain")
                if recvdata[0] == "OK":
                    content = recvdata[1]

src/k/a/kamaelia-HEAD/Code/Python/Kamaelia/Kamaelia/Codec/Speex.py   kamaelia(Download)
            while self.dataReady("inbox"):
 
                 data = self.recv("inbox")
                 #print data
                 ret = speexobj.encode(data)
 
            while self.dataReady("control"):
                msg = self.recv("control")
                if isinstance(msg, (Axon.Ipc.shutdownMicroprocess,Axon.Ipc.producerFinished)):
                    shutdown=True
            while self.dataReady("inbox"):
 
                data = self.recv("inbox")
                ret = speexobj.decode(data)
 
 
            while self.dataReady("control"):
                msg = self.recv("control")
                if isinstance(msg, (Axon.Ipc.shutdownMicroprocess,Axon.Ipc.producerFinished)):
                    shutdown=True

src/k/a/kamaelia-HEAD/Sketches/AB/Bookmarks-Dev/SocialBookmarks/TwitterStream.py   kamaelia(Download)
    def finished(self):
        while self.dataReady("control"):
            msg = self.recv("control")
            if isinstance(msg, producerFinished) or isinstance(msg, shutdownMicroprocess):
                self.send(msg, "signal")
                    self.datacapture.stop()
                    self.datacapture = None
                recvdata = self.recv("inbox")
                keywords = recvdata[0]
                if len(keywords) > 400:
            while self.dataReady("tweetsin"):
                counter = 0
                tweetdata = self.recv("tweetsin")
                if tweetdata[0] == "\r\n":
                    blanklinecount += 1

src/k/a/kamaelia-HEAD/Sketches/AB/backup/Bookmarks/TwitterStream.py   kamaelia(Download)
    def finished(self):
        while self.dataReady("control"):
            msg = self.recv("control")
            if isinstance(msg, producerFinished) or isinstance(msg, shutdownMicroprocess):
                self.send(msg, "signal")
                    self.datacapture.stop()
                    self.datacapture = None
                recvdata = self.recv("inbox")
                keywords = recvdata[0]
                if len(keywords) > 400:
            while self.dataReady("tweetsin"):
                counter = 0
                tweetdata = self.recv("tweetsin")
                if tweetdata[0] == "\r\n":
                    blanklinecount += 1

src/k/a/kamaelia-HEAD/Sketches/AB/Bookmarks-Dev/SocialBookmarks/Requester.py   kamaelia(Download)
    def finished(self):
        while self.dataReady("control"):
            msg = self.recv("control")
            if isinstance(msg, producerFinished) or isinstance(msg, shutdownMicroprocess):
                self.send(msg, "signal")
        while not self.dataReady("whatson"):
            pass
        data = self.recv("whatson")
        if data == None:
            pid = None
                while not self.dataReady("datain"):
                    pass
                recvdata = self.recv("datain")
 
                if recvdata[0] == "OK":
                while not self.dataReady("datain"):
                    pass
                recvdata = self.recv("datain")
                if recvdata[0] == "OK":
                    versiondata = recvdata[1]
                        while not self.dataReady("search"):
                            pass
                        twitdata = self.recv("search")
                        screenname = ""
                        try:

  1 | 2 | 3 | 4 | 5 | 6 | 7 | 8 | 9  Next