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

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

src/k/a/kamaelia-HEAD/Sketches/MPS/Experiments/Likefile2/likefile/deprecated/ThreadWrap.py   kamaelia(Download)
   def main(self):
      """Main loop."""
      self.addChildren(self.comp)
 
      self.link((self,"_outbox"), (self.comp,"inbox"))
      self.link((self,"_signal"), (self.comp,"control"))
      self.link((self.comp,"outbox"), (self,"_inbox"))
      self.link((self.comp,"signal"), (self,"_control"))

src/k/a/kamaelia-HEAD/Sketches/MPS/Experiments/Likefile2/likefile/LikeFile.py   kamaelia(Download)
   def main(self):
      """Main loop."""
      self.addChildren(self.comp)
 
      self.link((self,"_outbox"), (self.comp,"inbox"))
      self.link((self,"_signal"), (self.comp,"control"))
      self.link((self.comp,"outbox"), (self,"_inbox"))
      self.link((self.comp,"signal"), (self,"_control"))

src/k/a/kamaelia-HEAD/Code/Python/Axon/Axon/Handle.py   kamaelia(Download)
   def main(self):
      """Main loop."""
      self.addChildren(self.comp)
 
      self.link((self,"_outbox"), (self.comp,"inbox"))
      self.link((self,"_signal"), (self.comp,"control"))
      self.link((self.comp,"outbox"), (self,"_inbox"))
      self.link((self.comp,"signal"), (self,"_control"))

src/k/a/kamaelia-HEAD/Code/Python/Kamaelia/Kamaelia/Apps/SocialBookmarks/TwitterStream.py   kamaelia(Download)
                                    ("TRANSFORMER", "outbox") : ("self", "outbox"),}
                    ).activate()
        L = self.link((self.datacapture, "outbox"), (self, "tweetsin"))
 
        # Print("Connecting", repr(L), self.datacapture)
                    # Print("We have a datacapture component, so need it to shutdown - call it's .stop() method ... (hmm, not correct really and would work with graphline...)", self)
 
                    L = self.link((self, "_signal"), (self.datacapture, "control"))
                    self.send(producerFinished(), "_signal")
 
#                sys.exit(0) # FIXME Brutal, but effective
#                self.scheduler.stop() # FIXME Brutal, but effective
                L = self.link((self, "_signal"), (self.datacapture, "control"))
                self.send(producerFinished(), "_signal")
 

src/k/a/kamaelia-HEAD/Sketches/AB/Bookmarks-Dev/SocialBookmarks/TwitterStream.py   kamaelia(Download)
                                    ("TRANSFORMER", "outbox") : ("self", "outbox"),}
                    ).activate()
        self.link((self.datacapture, "outbox"), (self, "tweetsin"))
 
    def main(self):

src/k/a/kamaelia-HEAD/Sketches/AB/backup/Bookmarks/TwitterStream.py   kamaelia(Download)
                                    ("TRANSFORMER", "outbox") : ("self", "outbox"),}
                    ).activate()
        self.link((self.datacapture, "outbox"), (self, "tweetsin"))
 
    def main(self):

src/k/a/kamaelia-HEAD/Sketches/MPS/BugReports/FixTests/Axon/Axon/Handle.py   kamaelia(Download)
   def main(self):
      """Main loop."""
      self.addChildren(self.comp)
 
      self.link((self,"_outbox"), (self.comp,"inbox"))
      self.link((self,"_signal"), (self.comp,"control"))
      self.link((self.comp,"outbox"), (self,"_inbox"))
      self.link((self.comp,"signal"), (self,"_control"))

src/k/a/kamaelia-HEAD/Sketches/MPS/BugReports/FixTests/Kamaelia/Kamaelia/Apps/SocialBookmarks/TwitterStream.py   kamaelia(Download)
                                    ("TRANSFORMER", "outbox") : ("self", "outbox"),}
                    ).activate()
        L = self.link((self.datacapture, "outbox"), (self, "tweetsin"))
 
        # Print("Connecting", repr(L), self.datacapture)
                    # Print("We have a datacapture component, so need it to shutdown - call it's .stop() method ... (hmm, not correct really and would work with graphline...)", self)
 
                    L = self.link((self, "_signal"), (self.datacapture, "control"))
                    self.send(producerFinished(), "_signal")
 
#                sys.exit(0) # FIXME Brutal, but effective
#                self.scheduler.stop() # FIXME Brutal, but effective
                L = self.link((self, "_signal"), (self.datacapture, "control"))
                self.send(producerFinished(), "_signal")
 

src/k/a/kamaelia-HEAD/Tests/Python/Axon/test_ThreadedComponent.py   kamaelia(Download)
            def main(self):
                for i in range(10):
                    linkage = self.link( (self,"outbox"),(self,"inbox") )
                    self.unlink(thelinkage=linkage)