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

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

src/k/a/kamaelia-HEAD/Sketches/MPS/Experiments/ExampleRunner.py   kamaelia(Download)
    def main(self):
        yield self.system("ls")
        for i in self.Inbox("inbox"):
           print i
 
        yield self.system("fortune")
        for i in self.Inbox("inbox"):
 
        yield self.system("ls")
        for i in self.Inbox("inbox"):
           print i
        yield 1

src/k/a/kamaelia-HEAD/Sketches/MPS/Examples/OneShot_Race.py   kamaelia(Download)
   def main(self):
       print "CLIENT CONNECT", self.peer, self.peerport
       while not self.dataReady("control"):
           for msg in self.Inbox("inbox"):
               print "msg", self.peer, self.peerport
    def main(self):
        while 1:
            for i in self.Inbox("inbox"):
                sys.stdout.write(repr(i)+"\n")
                sys.stdout.flush()

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

src/k/a/kamaelia-HEAD/Sketches/JMB/SignalsExample.py   kamaelia(Download)
    def main(self):
        not_done = True
        while not_done:
            for msg in self.Inbox('control'):
                if isinstance(msg, producerFinished):

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

src/k/a/kamaelia-HEAD/Code/Python/Kamaelia/Kamaelia/Apps/SocialBookmarks/ComponentBoxTracer.py   kamaelia(Download)
            yield 1
 
            for data in self.Inbox("inbox"):
                self.send(data, "_to_inbox")
                self.send(["inbox", data], "_to_tracer_inbox")
 
            for data in self.Inbox("control"):
                self.send(["control", data], "_to_tracer_inbox")
 
            for data in self.Inbox("_from_outbox"):
                self.send(data, "outbox")
                self.send(["outbox", data], "_to_tracer_inbox")
 
            for data in self.Inbox("_from_signal"):

src/k/a/kamaelia-HEAD/Sketches/AB/Bookmarks-Dev/SocialBookmarks/ComponentBoxTracer.py   kamaelia(Download)
            yield 1
 
            for data in self.Inbox("inbox"):
                self.send(data, "_to_inbox")
                self.send(["inbox", data], "_to_tracer_inbox")
 
            for data in self.Inbox("control"):
                self.send(["control", data], "_to_tracer_inbox")
 
            for data in self.Inbox("_from_outbox"):
                self.send(data, "outbox")
                self.send(["outbox", data], "_to_tracer_inbox")
 
            for data in self.Inbox("_from_signal"):

src/k/a/kamaelia-HEAD/Sketches/AB/backup/Bookmarks/ComponentBoxTracer.py   kamaelia(Download)
            yield 1
 
            for data in self.Inbox("inbox"):
                self.send(data, "_to_inbox")
                self.send(["inbox", data], "_to_tracer_inbox")
 
            for data in self.Inbox("control"):
                self.send(["control", data], "_to_tracer_inbox")
 
            for data in self.Inbox("_from_outbox"):
                self.send(data, "outbox")
                self.send(["outbox", data], "_to_tracer_inbox")
 
            for data in self.Inbox("_from_signal"):

src/k/a/kamaelia-HEAD/Sketches/MPS/Bookmarks/ComponentBoxTracer.py   kamaelia(Download)
            yield 1
 
            for data in self.Inbox("inbox"):
                self.send(data, "_to_inbox")
                self.send(["inbox", data], "_to_tracer_inbox")
 
            for data in self.Inbox("control"):
                self.send(["control", data], "_to_tracer_inbox")
 
            for data in self.Inbox("_from_outbox"):
                self.send(data, "outbox")
                self.send(["outbox", data], "_to_tracer_inbox")
 
            for data in self.Inbox("_from_signal"):

src/k/a/kamaelia-HEAD/Code/Python/Kamaelia/Kamaelia/Apps/SocialBookmarks/WithSSLProxySupport.py   kamaelia(Download)
        yield 1
        message = producerFinished() #default
        for message in self.Inbox("control"): # Change to *last received* message ?
            pass
        self.send(message, "signal")
    def checkControl(self):
        for message in self.Inbox("control"): # Cleanly clear the inbox
            self.control_message = message
        if isinstance(self.control_message,shutdownMicroprocess):
            raise ShutdownNow
        try:
            while True:
                for data in self.Inbox("inbox"):
                    buff.feed(data)
                while buff.chompable():
    def handleGraphstepShutdown(self):
                dontcontinue = False
                message = None
                for message in self.Inbox("_control"):
                    if isinstance(message,status):
    def checkControl(self):
        # Print( "Checking Control" )
        for message in self.Inbox("control"): # Cleanly clear the inbox
            self.control_message = message
        if self.control_message:

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