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-0.6.0/Kamaelia/Protocol/MimeRequestComponent.py   Kamaelia(Download)
         self.link((decoder, "outbox"), (self, "inbox"))
 
         self.addChildren(reader,decoder)
         yield newComponent(*(self.children))
 

src/k/a/kamaelia-HEAD/Sketches/MPS/ProxyHTTP/https.py   kamaelia(Download)
                if self.components[source[0]] not in self.childComponents():
                    self.link((self.components[source[0]], "signal"), (self, "_control"))
                    self.addChildren( self.components[source[0]])
                    self.components[source[0]].activate()
 
                if self.components[sink[0]] not in self.childComponents():
                    self.link((self.components[sink[0]], "signal"), (self, "_control"))
                    self.addChildren( self.components[sink[0]])
    def main(self):
        self.addChildren(self.item)
        self.item.activate()
 
        dontcontinue = False

src/k/a/kamaelia-HEAD/Sketches/PO/KamPlanet/FeedParserFactory.py   kamaelia(Download)
    def initiateInternalSplitter(self):
        self.internalSplitter = PlugSplitter()
        self.link((self,'_signal'), (self.internalSplitter, 'control'))
        self.addChildren(self.internalSplitter)
        self.internalSplitter.activate()
                feed = self.recv("inbox")
                child = self.createChild(feed)
                self.addChildren(child)
                child.activate()
 

src/k/a/kamaelia-HEAD/Code/Python/Kamaelia/Kamaelia/Protocol/HTTP/HTTPRequestHandler.py   kamaelia(Download)
        self.link((self, "_handleroutbox"), (self.handler, "inbox"))
        self.link((self, "_handlersignal"), (self.handler, "control"))
        self.addChildren(self.handler) 
        self.handler.activate()
 

src/k/a/kamaelia-HEAD/Sketches/MH/RTP/Multicast_transceiver.py   kamaelia(Download)
      selectorService, selectorShutdownService, newSelector = Selector.getSelectorServices(self.tracker)
      if newSelector:
         self.addChildren(newSelector)
 
      CSA = ConnectedSocketAdapter(sock, selectorService, sendTo=self.remote) #  self.createConnectedSocket(sock)
      self.addChildren(CSA)

src/k/a/kamaelia-HEAD/Sketches/MH/RTP/Multicast_transceiver_threaded.py   kamaelia(Download)
        recver.activate()
 
        self.addChildren(sender,recver)
 
        while 1:

src/k/a/kamaelia-HEAD/Code/Python/Kamaelia/Kamaelia/Util/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/Code/Python/Kamaelia/Kamaelia/Protocol/AIM/AIMHarness.py   kamaelia(Download)
        self.loginer = Kamaelia.Protocol.AIM.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/Sketches/MPS/Axon.DSL/Axon/DSL/Carousel.py   kamaelia(Download)
    def instantiateNewChild(self, args):
        # create new child
        newChild = self.factory(args)
        self.addChildren( newChild )
 

src/k/a/kamaelia-HEAD/Code/Python/Kamaelia/Kamaelia/Chassis/Carousel.py   kamaelia(Download)
    def instantiateNewChild(self, args):
        # create new child
        newChild = self.factory(args)
        self.addChildren( newChild )
 

Previous  2 | 3 | 4 | 5 | 6 | 7 | 8 | 9 | 10  Next