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/SingleServer.py   kamaelia(Download)
 
      self.link((self.myPLS,"protocolHandlerSignal"),(self,"_oobinfo"))
      self.addChildren(self.myPLS)
      yield _Axon.Ipc.newComponent(self.myPLS)
      while 1:
         self.rejectedCSAs.append(newCSA)
 
      self.addChildren(newCSA)
      return _Axon.Ipc.newComponent(newCSA)
 
         self.link((handler, "signal"), (server, "control"))
 
         self.addChildren(server, handler)
         yield _Axon.Ipc.newComponent(*(self.children))
         while 1:

src/k/a/kamaelia-HEAD/Sketches/Old/StreamingTextServer.py   kamaelia(Download)
        ss = SimpleServer(protocol=streamingTextServerProtocol, port=1500).activate()
#        self.addChildren(rfa,splitter, ss)
        self.addChildren(str,splitter, ss)
#        return rfa, ss, splitter
        return str, ss, splitter

src/k/a/Kamaelia-0.6.0/Kamaelia/Internet/ThreadedTCPClient.py   Kamaelia(Download)
      def initialiseComponent(self):
         self.client = ThreadedTCPClient("127.0.0.1",self.serverport)
         self.addChildren(self.client,self.display,self.displayerr)
         self.addChildren(self.server, self.display)
         self.link((self.client,"outbox"), (self.display,"inbox") )

src/k/a/Kamaelia-0.6.0/Kamaelia/Internet/SingleServer.py   Kamaelia(Download)
   def main(self):
      self.myPLS = TCPServer(listenport=self.listenport)
      self.link((self.myPLS,"protocolHandlerSignal"),(self,"_oobinfo"))
      self.addChildren(self.myPLS)
      yield _Axon.Ipc.newComponent(self.myPLS)
         self.rejectedCSAs.append(newCSA)
 
      self.addChildren(newCSA)
      return _Axon.Ipc.newComponent(newCSA)
 
         self.link((handler, "signal"), (server, "control"))
 
         self.addChildren(server, handler)
         yield _Axon.Ipc.newComponent(*(self.children))
         while 1:

src/k/a/kamaelia-HEAD/Sketches/JMB/simplechat.py   kamaelia(Download)
        sub = SubscribeTo("JID")
        self.link((sub, 'outbox'), (self, 'jid'))
        self.addChildren(sub)
        sub.activate()
 
    def initComponents(self):
        sub = SubscribeTo("JID")
        self.link((sub, 'outbox'), (self, 'jid'))
        self.addChildren(sub)
        sub.activate()
 
        sub = SubscribeTo("CONSOLE")
        self.link((sub, 'outbox'), (self, 'inbox'))
        self.addChildren(sub)
    def initComponents(self):
        sub = SubscribeTo("JID")
        self.link((sub, 'outbox'), (self, 'jid'))
        self.addChildren(sub)
        sub.activate()
 
        pub = PublishTo("DISCO_FEAT")
        self.link((self, 'features-announce'), (pub, 'inbox'))
        self.addChildren(pub)

src/k/a/kamaelia-HEAD/Code/Python/Kamaelia/Kamaelia/Util/Chargen.py   kamaelia(Download)
 
        self.link((chargen,"outbox"), (display,"inbox"))
        self.addChildren(chargen, display)
        yield Axon.Ipc.newComponent(*(self.children))
        while 1:

src/k/a/kamaelia-HEAD/Code/Python/Kamaelia/Kamaelia/Internet/Multicast_receiver.py   kamaelia(Download)
 
        self.link((receiver,"outbox"), (display,"inbox"))
        self.addChildren(receiver, display)
        yield Axon.Ipc.newComponent(*(self.children))
        while 1:

src/k/a/kamaelia-HEAD/Sketches/JTL/ThreadedTCPClient.py   kamaelia(Download)
      def initialiseComponent(self):
         self.client = ThreadedTCPClient("127.0.0.1",self.serverport, delay=1)
         self.addChildren(self.server,self.client,self.display)
#         self.addChildren(self.server, self.display)
         self.link((self.client,"outbox"), (self.display,"inbox") )

src/k/a/kamaelia-HEAD/Sketches/DL/Kamaelia/Util/Chargen.py   kamaelia(Download)
 
        self.link((chargen,"outbox"), (display,"inbox"))
        self.addChildren(chargen, display)
        yield Axon.Ipc.newComponent(*(self.children))
        while 1:

src/k/a/kamaelia-HEAD/Code/Python/Kamaelia/Kamaelia/Apps/SocialBookmarks/WithSSLProxySupport.py   kamaelia(Download)
                    if self.components[source[0]] != self:
                        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():
                    if self.components[sink[0]] != self:
                        self.link((self.components[sink[0]], "signal"), (self, "_control"))
                        self.addChildren( self.components[sink[0]])
    def main(self):
        # Print( "With component starting...")
        self.addChildren(self.item)
        self.item.activate()
 

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