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

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

src/k/a/kamaelia-HEAD/Code/Python/Kamaelia/Kamaelia/Internet/TCPServer.py   kamaelia(Download)
             self.send(newReader(CSA, ((CSA, "ReadReady"), newsock)), "_selectorSignal")            
             self.send(newWriter(CSA, ((CSA, "SendReady"), newsock)), "_selectorSignal")            
             self.addChildren(CSA)
             self.link((CSA, "CreatorFeedback"),(self,"_feedbackFromCSA"))
#             return CSA

src/k/a/kamaelia-HEAD/Code/Python/Kamaelia/Kamaelia/Protocol/HTTP/Handlers/Minimal.py   kamaelia(Download)
        self.link((self.filereader, "outbox"), (self, "_fileread"))
        self.link((self.filereader, "signal"), (self, "_filecontrol"))
        self.addChildren(self.filereader)
        self.filereader.activate()
        yield 1

src/k/a/kamaelia-HEAD/Sketches/RJL/Packages/Kamaelia/Community/RJL/Kamaelia/Protocol/Torrent/TorrentPatron.py   kamaelia(Download)
        if newTorrentService:
            newTorrentService.activate()
            self.addChildren(newTorrentService)
 
        # link to and register with the TorrentService

src/k/a/kamaelia-HEAD/Sketches/MPS/Axon.DSL/Axon/DSL/Backplane.py   kamaelia(Download)
 
        yield newComponent(self.splitter)
        self.addChildren(self.splitter)
        self.splitter = None
        # FIXME: If we had a way of simply getting this to "exec" a new component in our place,
        self.link( (plug,"outbox"), (self,"outbox"), passthrough=2)
        self.link( (plug,"signal"), (self,"signal"), passthrough=2)
        self.addChildren(plug)
        yield newComponent(plug)
        # wait until all child component has terminated

src/k/a/kamaelia-HEAD/Sketches/RJL/Kamaelia/Community/RJL/Kamaelia/Protocol/Torrent/TorrentPatron.py   kamaelia(Download)
        if newTorrentService:
            newTorrentService.activate()
            self.addChildren(newTorrentService)
 
        # link to and register with the TorrentService

src/k/a/kamaelia-HEAD/Sketches/RJL/SMTP/SMTPServer.py   kamaelia(Download)
        self.queueinterface = funccreateinterface(uniqueidservice)
        self.queueinterface.activate()
        self.addChildren(self.queueinterface)
 
        self.link((self, "dq1interface"), (self.queueinterface, "inbox"))

src/k/a/kamaelia-HEAD/Code/Python/Kamaelia/Kamaelia/Protocol/Torrent/TorrentPatron.py   kamaelia(Download)
        if newTorrentService:
            newTorrentService.activate()
            self.addChildren(newTorrentService)
 
        # link to and register with the TorrentService

src/k/a/kamaelia-HEAD/Sketches/JMB/Descartes/Static/Minimal.py   kamaelia(Download)
        self.link((self.filereader, "outbox"), (self, "_fileread"))
        self.link((self.filereader, "signal"), (self, "_filecontrol"))
        self.addChildren(self.filereader)
        self.filereader.activate()
        yield 1

src/k/a/kamaelia-HEAD/Sketches/JL/AIM_/AIMHarness.py   kamaelia(Download)
        self.loginer = LoginHandler.LoginHandler(screenname, password).activate()
        self.link((self.loginer, "signal"), (self, "internal inbox")) #quite a hack, sending other data out through "signal"
        self.addChildren(self.loginer)
        self.debugger.addDebugSection("AIMHarness.main", 5)
 

src/k/a/kamaelia-HEAD/Code/Python/Kamaelia/Kamaelia/Protocol/FortuneCookieProtocol.py   kamaelia(Download)
      assert self.debugger.note("FortuneCookieProtocol.main", 1, self.name, "Linked in")
 
      self.addChildren(myDataSource)
      assert self.debugger.note("FortuneCookieProtocol.main", 1, self.name, "Added Child", myDataSource)
      return newComponent(  myDataSource  )

Previous  4 | 5 | 6 | 7 | 8 | 9 | 10 | 11 | 12  Next