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

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

src/k/a/kamaelia-HEAD/Sketches/MPS/Examples/LUGRadio/likefile.py   kamaelia(Download)
        for childSink, parentSource in self.childInboxMapping.iteritems():
            self.inQueues[childSink] = Queue.Queue(self.queuelengths)
            self.link((self, parentSource),(self.child, childSink))
 
        # This outbox is used to tell the output wrapper when to shut down.

src/k/a/kamaelia-HEAD/Sketches/MH/Timer/Timer.py   kamaelia(Download)
                    handle, target = msg[1], msg[2]
                    boxname = self.addOutbox("outbox")
                    linkage = self.link( (self,boxname), target[0], passthrough=target[1])
                    self.mappings[handle] = (boxname,linkage)
 

src/k/a/kamaelia-HEAD/Sketches/MH/RTP/Selector.py   kamaelia(Download)
        if selectable not in meta:
            outbox = self.addOutbox(boxBase)
            L = self.link((self, outbox), replyService)
            meta[selectable] = replyService, outbox, L
            selectables.append(selectable)

src/k/a/kamaelia-HEAD/Code/Python/Kamaelia/Kamaelia/Internet/Selector.py   kamaelia(Download)
        if selectable not in meta:
            outbox = self.addOutbox(boxBase)
            L = self.link((self, outbox), replyService)
            meta[selectable] = replyService, outbox, L
            selectables.append(selectable)

src/k/a/Kamaelia-0.6.0/Kamaelia/Internet/Selector.py   Kamaelia(Download)
        if selectable not in meta:
            outbox = self.addOutbox(boxBase)
            L = self.link((self, outbox), replyService)
            meta[selectable] = replyService, outbox, L
            selectables.append(selectable)

src/k/a/kamaelia-HEAD/Sketches/MPS/Experiments/Likefile2/likefile/deprecated/componentWrapperInput.py   kamaelia(Download)
        for childSink, parentSource in self.childInboxMapping.iteritems():
            self.inQueues[childSink] = Queue.Queue(self.queuelengths)
            self.link((self, parentSource),(self.child, childSink))
 
        # This outbox is used to tell the output wrapper when to shut down.

src/k/a/kamaelia-HEAD/Sketches/MH/exceptions/Axon/experimental/_pprocess_support.py   kamaelia(Download)
        for childSink, parentSource in self.childInboxMapping.iteritems():
            self.inQueues[childSink] = Queue.Queue(self.queuelengths)
            self.link((self, parentSource),(self.child, childSink))
 
        # This outbox is used to tell the output wrapper when to shut down.

src/k/a/kamaelia-HEAD/Code/Python/Axon/Axon/experimental/_pprocess_support.py   kamaelia(Download)
        for childSink, parentSource in items:
            self.inQueues[childSink] = queue.Queue(self.queuelengths)
            self.link((self, parentSource),(self.child, childSink))
 
        # This outbox is used to tell the output wrapper when to shut down.

src/k/a/Kamaelia-0.6.0/Axon/experimental/_pprocess_support.py   Kamaelia(Download)
        for childSink, parentSource in self.childInboxMapping.iteritems():
            self.inQueues[childSink] = Queue.Queue(self.queuelengths)
            self.link((self, parentSource),(self.child, childSink))
 
        # This outbox is used to tell the output wrapper when to shut down.

src/k/a/kamaelia-HEAD/Sketches/MPS/BugReports/FixTests/Kamaelia/Kamaelia/Internet/Selector.py   kamaelia(Download)
        if selectable not in meta:
            outbox = self.addOutbox(boxBase)
            L = self.link((self, outbox), replyService)
            meta[selectable] = replyService, outbox, L
            selectables.append(selectable)

  1 | 2  Next