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

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

src/k/a/kamaelia-HEAD/Sketches/MPS/BugReports/FixTests/Kamaelia/Examples/DVB_Systems/Macro.py   kamaelia(Download)
        print uid,"Transcoder pipethough =",transcoder.name
 
        data_linkage = self.link( (self,"inbox"), (transcoder,"inbox"), passthrough=1 )
        ctrl_linkage = self.link( (self,"_stop"), (transcoder,"control"))
        done_linkage = self.link( (transcoder,"signal"), (self,"_transcodingcomplete") )

src/k/a/kamaelia-HEAD/Sketches/MPS/BugReports/FixTests/Axon/Examples/SynchronousLinks/basic_syncLinksAcceptanceTest.py   kamaelia(Download)
    def main(self):
        producer = Producer().activate()
        consumer = SlowConsumer().activate()
        self.link((producer,"outbox"),(consumer, "inbox"),synchronous=True)
        self.addChildren(producer, consumer)
    def main(self):
        producer = Producer().activate()
        consumer = SlowConsumer().activate()
        self.link((producer,"outbox"),(consumer, "inbox"),pipewidth=1)
        self.addChildren(producer, consumer)

src/k/a/kamaelia-HEAD/Code/Python/Kamaelia/Examples/DVB_Systems/Macro.py   kamaelia(Download)
        print uid,"Transcoder pipethough =",transcoder.name
 
        data_linkage = self.link( (self,"inbox"), (transcoder,"inbox"), passthrough=1 )
        ctrl_linkage = self.link( (self,"_stop"), (transcoder,"control"))
        done_linkage = self.link( (transcoder,"signal"), (self,"_transcodingcomplete") )

src/k/a/kamaelia-HEAD/Code/Python/Axon/Examples/SynchronousLinks/basic_syncLinksAcceptanceTest.py   kamaelia(Download)
    def main(self):
        producer = Producer().activate()
        consumer = SlowConsumer().activate()
        self.link((producer,"outbox"),(consumer, "inbox"),synchronous=True)
        self.addChildren(producer, consumer)
    def main(self):
        producer = Producer().activate()
        consumer = SlowConsumer().activate()
        self.link((producer,"outbox"),(consumer, "inbox"),pipewidth=1)
        self.addChildren(producer, consumer)

src/k/a/kamaelia-HEAD/Sketches/MPS/Examples/LUGRadio/Macro.py   kamaelia(Download)
        print uid,"Transcoder pipethough =",transcoder.name
 
        data_linkage = self.link( (self,"inbox"), (transcoder,"inbox"), passthrough=1 )
        ctrl_linkage = self.link( (self,"_stop"), (transcoder,"control"))
        done_linkage = self.link( (transcoder,"signal"), (self,"_transcodingcomplete") )

src/k/a/Kamaelia-0.6.0/Examples/DVB_Systems/Macro.py   Kamaelia(Download)
        print uid,"Transcoder pipethough =",transcoder.name
 
        data_linkage = self.link( (self,"inbox"), (transcoder,"inbox"), passthrough=1 )
        ctrl_linkage = self.link( (self,"_stop"), (transcoder,"control"))
        done_linkage = self.link( (transcoder,"signal"), (self,"_transcodingcomplete") )

src/k/a/kamaelia-HEAD/Sketches/MPS/BugReports/FixTests/Kamaelia/Examples/DVB_Systems/PersonalVideoRecorder.py   kamaelia(Download)
    def main(self):
        # first, get the service ID for this channel
        #
        channelLookup = Subscribe(self.fromChannelLookup, [self.channel_name]).activate()
        self.link( (channelLookup,"outbox"), (self, "_fromChannelLookup") )
    def main(self):
        # first, get the service ID for this channel
        #
        channelLookup = Subscribe(self.fromChannelLookup, [self.channel_name]).activate()
        self.link( (channelLookup,"outbox"), (self, "_fromChannelLookup") )
                             ).activate()
 
        fromPAT_linkage = self.link( (pat_parser,"outbox"),(self,"_fromPAT") )
 
        # wait until we get data back from the PAT
                             ).activate()
 
        fromPMT_linkage = self.link( (pmt_parser,"outbox"),(self,"_fromPMT") )
 
        # wait until we get data back from the PMT
        cat = CAT.getcat()
        service = cat.retrieveService(self.fromDemuxer)
        self.link((self,"_toDemuxer"),service)
 
        while 1:

src/k/a/kamaelia-HEAD/Code/Python/Kamaelia/Examples/DVB_Systems/PersonalVideoRecorder.py   kamaelia(Download)
    def main(self):
        # first, get the service ID for this channel
        #
        channelLookup = Subscribe(self.fromChannelLookup, [self.channel_name]).activate()
        self.link( (channelLookup,"outbox"), (self, "_fromChannelLookup") )
    def main(self):
        # first, get the service ID for this channel
        #
        channelLookup = Subscribe(self.fromChannelLookup, [self.channel_name]).activate()
        self.link( (channelLookup,"outbox"), (self, "_fromChannelLookup") )
                             ).activate()
 
        fromPAT_linkage = self.link( (pat_parser,"outbox"),(self,"_fromPAT") )
 
        # wait until we get data back from the PAT
                             ).activate()
 
        fromPMT_linkage = self.link( (pmt_parser,"outbox"),(self,"_fromPMT") )
 
        # wait until we get data back from the PMT
        cat = CAT.getcat()
        service = cat.retrieveService(self.fromDemuxer)
        self.link((self,"_toDemuxer"),service)
 
        while 1:

src/k/a/kamaelia-HEAD/Sketches/MPS/Experiments/ExampleRunner.py   kamaelia(Download)
        def Y(X, outbox,signal,inbox,control):
            L1 = self.link((X, signal), (self, control))
            L2 = self.link((X, outbox), (self, inbox))
            X.activate()
            yield 1

src/k/a/Kamaelia-0.6.0/Examples/DVB_Systems/PersonalVideoRecorder.py   Kamaelia(Download)
    def main(self):
        # first, get the service ID for this channel
        #
        channelLookup = Subscribe(self.fromChannelLookup, [self.channel_name]).activate()
        self.link( (channelLookup,"outbox"), (self, "_fromChannelLookup") )
    def main(self):
        # first, get the service ID for this channel
        #
        channelLookup = Subscribe(self.fromChannelLookup, [self.channel_name]).activate()
        self.link( (channelLookup,"outbox"), (self, "_fromChannelLookup") )
                             ).activate()
 
        fromPAT_linkage = self.link( (pat_parser,"outbox"),(self,"_fromPAT") )
 
        # wait until we get data back from the PAT
                             ).activate()
 
        fromPMT_linkage = self.link( (pmt_parser,"outbox"),(self,"_fromPMT") )
 
        # wait until we get data back from the PMT
        cat = CAT.getcat()
        service = cat.retrieveService(self.fromDemuxer)
        self.link((self,"_toDemuxer"),service)
 
        while 1:

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