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

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

src/k/a/kamaelia-HEAD/Sketches/MPS/Examples/AIM/MultiAIMBot.py   kamaelia(Download)
                     c += 1
                     message = ("message", self.user, line )
                     self.send(message, "to_aim")
 
            for message in self.Inbox("from_aim"):
                 if len(message) == 3:
                     if message[0] == "message":
                         text = message[2]+"\n"
                         self.send(text, "to_user")
        if self.dataReady("control"):
            print "GOT CONTROL MESSAGE"
            self.send(self.recv("control"), "signal")
        else: 
            print "SOME OTHER REASON"
            self.send(Axon.Ipc.ProducerFinished(), "signal")

src/k/a/kamaelia-HEAD/Sketches/MPS/Examples/AIM/AIMBot.py   kamaelia(Download)
                     time.sleep(self.ratelimit)
                     message = sendTo(self.user, line ) # FIXME: Crap name
                     self.send(message, "to_aim")
 
            for message in self.Inbox("from_aim"):
                 if len(message) == 3:
                     if message[0] == "message":
                         text = message[2]+"\n"
                         self.send(text, "to_user")
                self.pause()
        if self.dataReady("control"):
            self.send(self.recv("control"), "signal")
        else:
           self.send(Axon.Ipc.ProducerFinished(), "signal")

src/k/a/kamaelia-HEAD/Sketches/MPS/BugReports/FixTests/Kamaelia/Examples/UsingChassis/Pipeline/Feedback.py   kamaelia(Download)
    def main(self):
        model = "B"
        while not self.dataReady("control"):
            self.send( model, "outbox")
            for i in self.Inbox("inbox"):
                model = i
            model = self.mutateModel(model)
            time.sleep(0.4)
        self.send(self.recv("control"), "signal")

src/k/a/kamaelia-HEAD/Code/Python/Kamaelia/Examples/UsingChassis/Pipeline/Feedback.py   kamaelia(Download)
    def main(self):
        model = "B"
        while not self.dataReady("control"):
            self.send( model, "outbox")
            for i in self.Inbox("inbox"):
                model = i
            model = self.mutateModel(model)
            time.sleep(0.4)
        self.send(self.recv("control"), "signal")

src/k/a/kamaelia-HEAD/Sketches/MPS/BugReports/FixTests/Kamaelia/Examples/TCP_Systems/HTTP/KamaeliaWebServer.py   kamaelia(Download)
           "headers"    : self.response_headers,
        }
        self.send(resource, "outbox")
        for fragment in R:
            page = {
              "data" : fragment,
            }
            self.send(page, "outbox")
        self.send(Axon.Ipc.producerFinished(self), "signal")

src/k/a/kamaelia-HEAD/Code/Python/Kamaelia/Examples/TCP_Systems/HTTP/KamaeliaWebServer.py   kamaelia(Download)
           "headers"    : self.response_headers,
        }
        self.send(resource, "outbox")
        for fragment in R:
            page = {
              "data" : fragment,
            }
            self.send(page, "outbox")
        self.send(Axon.Ipc.producerFinished(self), "signal")

src/k/a/kamaelia-HEAD/Sketches/MPS/BugReports/FixTests/Kamaelia/Examples/UsingChassis/PAR/par_shutdown_simple.py   kamaelia(Download)
    def main(self):
        time.sleep(self.TTL)
        self.send(Axon.Ipc.producerFinished(), "signal")
 
class ChattySlowShutdown(Axon.ThreadedComponent.threadedcomponent):
            print self.name, "Shutting down slowly"
            time.sleep(1)
        self.send(self.recv("control"), "signal")
 
Pipeline(

src/k/a/kamaelia-HEAD/Code/Python/Kamaelia/Examples/UsingChassis/PAR/par_shutdown_simple.py   kamaelia(Download)
    def main(self):
        time.sleep(self.TTL)
        self.send(Axon.Ipc.producerFinished(), "signal")
 
class ChattySlowShutdown(Axon.ThreadedComponent.threadedcomponent):
            print self.name, "Shutting down slowly"
            time.sleep(1)
        self.send(self.recv("control"), "signal")
 
Pipeline(

src/k/a/kamaelia-HEAD/Sketches/MPS/BugReports/FixTests/Kamaelia/Examples/UsingChassis/Graphline/LinkedShutdown.py   kamaelia(Download)
    def main(self):
        i = 0
        for i in self.tosend:
            time.sleep(1.0)
            self.send(Axon.Ipc.producerFinished(), self.box)

src/k/a/kamaelia-HEAD/Sketches/MPS/BugReports/FixTests/Kamaelia/Examples/UsingChassis/Graphline/FailShutdown.py   kamaelia(Download)
    def main(self):
        i = 0
        for i in self.tosend:
            time.sleep(1.0)
            self.send(Axon.Ipc.producerFinished(), self.box)

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