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

All Samples(25)  |  Call(1)  |  Derive(13)  |  Import(11)

src/k/a/kamaelia-HEAD/Sketches/MPS/Examples/LUGRadio/likefile.py   kamaelia(Download)
class componentWrapperInput(Axon.ThreadedComponent.threadedadaptivecommscomponent):
    """A wrapper that takes a child component and waits on an event from the foreground, to signal that there is 
    queued data to be placed on the child's inboxes."""
    def __init__(self, child, extraInboxes = None):
        super(componentWrapperInput, self).__init__()

src/k/a/kamaelia-HEAD/Code/Python/Kamaelia/Kamaelia/Internet/Selector.py   kamaelia(Download)
from Kamaelia.IPC import newReader, removeReader, newWriter, removeWriter, newExceptional, removeExceptional
import Axon.CoordinatingAssistantTracker as cat
from Axon.ThreadedComponent import threadedadaptivecommscomponent
import time
#import sys,traceback
class Selector(threadedadaptivecommscomponent): #Axon.AdaptiveCommsComponent.AdaptiveCommsComponent): # SmokeTests_Selector.test_SmokeTest
    """\
    Selector() -> new Selector component
 
    Use Selector.getSelectorService(...) in preference as it returns an

src/k/a/kamaelia-HEAD/Sketches/MH/Timer/Timer.py   kamaelia(Download)
import time
 
from Axon.ThreadedComponent import threadedadaptivecommscomponent
 
# events are a single value 'when' - representing the time
# the event should trigger
 
 
class _TimerCore(threadedadaptivecommscomponent): # (AdaptiveCommsComponent):

src/k/a/kamaelia-HEAD/Sketches/MH/RTP/Selector.py   kamaelia(Download)
from Kamaelia.IPC import newReader, removeReader, newWriter, removeWriter, newExceptional, removeExceptional
import Axon.CoordinatingAssistantTracker as cat
from Axon.ThreadedComponent import threadedadaptivecommscomponent
import time
#import sys,traceback
class _SelectorCore(threadedadaptivecommscomponent): #Axon.AdaptiveCommsComponent.AdaptiveCommsComponent): # SmokeTests_Selector.test_SmokeTest
    """\
    Selector() -> new Selector component
 
    Use Selector.getSelectorService(...) in preference as it returns an

src/k/a/kamaelia-HEAD/Sketches/MPS/Experiments/Likefile2/likefile/deprecated/componentWrapperInput.py   kamaelia(Download)
# -------------------------------------------------------------------------
 
from Axon.ThreadedComponent import threadedadaptivecommscomponent
from Axon.AxonExceptions import noSpaceInBox
import Queue
class componentWrapperInput(threadedadaptivecommscomponent):
    """A wrapper that takes a child component and waits on an event from the foreground, to signal that there is 
    queued data to be placed on the child's inboxes."""
    def __init__(self, child, inboxes = DEFIN):
        super(componentWrapperInput, self).__init__()

src/k/a/kamaelia-HEAD/Sketches/MH/exceptions/Axon/experimental/_pprocess_support.py   kamaelia(Download)
from Axon.Scheduler import scheduler
from Axon.Component import component
from Axon.ThreadedComponent import threadedadaptivecommscomponent
from Axon.AdaptiveCommsComponent import AdaptiveCommsComponent
from Axon.AxonExceptions import noSpaceInBox
class componentWrapperInput(threadedadaptivecommscomponent):
    """A wrapper that takes a child component and waits on an event from the foreground, to signal that there is 
    queued data to be placed on the child's inboxes."""
    def __init__(self, child, inboxes = DEFIN):
        super(componentWrapperInput, self).__init__()

src/k/a/kamaelia-HEAD/Code/Python/Axon/Axon/experimental/_pprocess_support.py   kamaelia(Download)
from Axon.Scheduler import scheduler
from Axon.Component import component
from Axon.ThreadedComponent import threadedadaptivecommscomponent
from Axon.AdaptiveCommsComponent import AdaptiveCommsComponent
from Axon.AxonExceptions import noSpaceInBox
class componentWrapperInput(threadedadaptivecommscomponent):
    """A wrapper that takes a child component and waits on an event from the foreground, to signal that there is 
    queued data to be placed on the child's inboxes."""
    def __init__(self, child, inboxes = DEFIN):
        super(componentWrapperInput, self).__init__()

src/k/a/Kamaelia-0.6.0/Kamaelia/Internet/Selector.py   Kamaelia(Download)
from Kamaelia.IPC import newReader, removeReader, newWriter, removeWriter, newExceptional, removeExceptional
import Axon.CoordinatingAssistantTracker as cat
from Axon.ThreadedComponent import threadedadaptivecommscomponent
import time
#import sys,traceback
class Selector(threadedadaptivecommscomponent): #Axon.AdaptiveCommsComponent.AdaptiveCommsComponent): # SmokeTests_Selector.test_SmokeTest
    """\
    Selector() -> new Selector component
 
    Use Selector.getSelectorService(...) in preference as it returns an

src/k/a/Kamaelia-0.6.0/Axon/experimental/_pprocess_support.py   Kamaelia(Download)
from Axon.Scheduler import scheduler
from Axon.Component import component
from Axon.ThreadedComponent import threadedadaptivecommscomponent
from Axon.AdaptiveCommsComponent import AdaptiveCommsComponent
from Axon.AxonExceptions import noSpaceInBox
class componentWrapperInput(threadedadaptivecommscomponent):
    """A wrapper that takes a child component and waits on an event from the foreground, to signal that there is 
    queued data to be placed on the child's inboxes."""
    def __init__(self, child, inboxes = DEFIN):
        super(componentWrapperInput, self).__init__()

src/k/a/kamaelia-HEAD/Tests/Python/Axon/test_ThreadedComponent.py   kamaelia(Download)
import unittest
import sys
from Axon.ThreadedComponent import threadedcomponent, threadedadaptivecommscomponent
# import thread,Queue,threading
import threading
    def test_smoketest_init(self):
        """__init__ - class constructor is called with no arguments."""
        c = threadedadaptivecommscomponent()
 
        self.assert_(len(c.inboxes.keys()) == 2, "by default, has 2 inboxes")
        class T(threadedadaptivecommscomponent):
            def __init__(self):
                super(T,self).__init__()
                self.toTestCase = queue.Queue()
                self.fromTestCase = queue.Queue()
        class T(threadedadaptivecommscomponent):
            def __init__(self,dst):
                super(T,self).__init__()
                self.toTestCase = queue.Queue()
                self.fromTestCase = queue.Queue()

  1 | 2  Next