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

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

src/k/a/kamaelia-HEAD/Sketches/MH/new_splitter/Splitter.py   kamaelia(Download)
import Axon
from Axon.AdaptiveCommsComponent import AdaptiveCommsComponent
from Axon.Ipc import producerFinished, shutdownMicroprocess, ipc
from Axon import Ipc
 
 
class addsink(ipc):
class removesink(ipc):
    """Message specifying a target component and inbox(es) to be unwired from data sources"""
    def __init__(self, sink, sinkbox="inbox", sinkcontrol = None):
        self.sink = sink
        self.sinkbox = sinkbox

src/k/a/kamaelia-HEAD/Sketches/MPS/Axon.DSL/Axon/DSL/Splitter.py   kamaelia(Download)
 
import Axon.AdaptiveCommsComponent
from Axon.Ipc import producerFinished, shutdownMicroprocess, ipc
from Axon.Linkage import linkage
from Axon import Ipc
 
 
class addsink(ipc):
class removesink(ipc):
    """\
    removesink(sink[,sinkbox][,sinkcontrol]) -> new removesink message.
 
    Message specifying a target component and inbox(es), requesting they be

src/k/a/kamaelia-HEAD/Code/Python/Kamaelia/Kamaelia/Util/Splitter.py   kamaelia(Download)
 
import Axon.AdaptiveCommsComponent
from Axon.Ipc import producerFinished, shutdownMicroprocess, ipc
from Axon.Linkage import linkage
from Axon import Ipc
 
 
class addsink(ipc):
class removesink(ipc):
    """\
    removesink(sink[,sinkbox][,sinkcontrol]) -> new removesink message.
 
    Message specifying a target component and inbox(es), requesting they be

src/k/a/kamaelia-HEAD/Sketches/MH/OnDemandBackplane/Splitter.py   kamaelia(Download)
 
import Axon.AdaptiveCommsComponent
from Axon.Ipc import producerFinished, shutdownMicroprocess, ipc
from Axon.Linkage import linkage
from Axon import Ipc
 
 
class addsink(ipc):
class removesink(ipc):
    """\
    removesink(sink[,sinkbox][,sinkcontrol]) -> new removesink message.
 
    Message specifying a target component and inbox(es), requesting they be

src/k/a/kamaelia-HEAD/Sketches/JL/IRC/ircShakespeare.py   kamaelia(Download)
from Axon.Component import component
from Axon.AdaptiveCommsComponent import AdaptiveCommsComponent
from Axon.Ipc import producerFinished, shutdownMicroprocess, ipc, newComponent
from Axon import Ipc
import time

src/k/a/kamaelia-HEAD/Sketches/MH/ircShakespeare.py   kamaelia(Download)
from Axon.Component import component
from Axon.AdaptiveCommsComponent import AdaptiveCommsComponent
from Axon.Ipc import producerFinished, shutdownMicroprocess, ipc, newComponent
from Axon import Ipc
import time

src/k/a/Kamaelia-0.6.0/Kamaelia/Util/Splitter.py   Kamaelia(Download)
 
import Axon.AdaptiveCommsComponent
from Axon.Ipc import producerFinished, shutdownMicroprocess, ipc
from Axon.Linkage import linkage
from Axon import Ipc
 
 
class addsink(ipc):
class removesink(ipc):
    """\
    removesink(sink[,sinkbox][,sinkcontrol]) -> new removesink message.
 
    Message specifying a target component and inbox(es), requesting they be

src/k/a/kamaelia-HEAD/Sketches/JL/AIM_/gen.py   kamaelia(Download)
import md5
from Axon.Component import component
from Axon.Ipc import WaitComplete, ipc
from OSCARClient import OSCARClient
from oscarutil import *

src/k/a/kamaelia-HEAD/Sketches/MPS/BugReports/FixTests/Kamaelia/Kamaelia/Util/TestResult.py   kamaelia(Download)
 
from Axon.Component import component
from Axon.Ipc import producerFinished, shutdownMicroprocess,ipc
from Axon.AxonExceptions import AxonException
 
class StopSystem(ipc):

src/k/a/kamaelia-HEAD/Sketches/MPS/BugReports/FixTests/Kamaelia/Kamaelia/Util/Splitter.py   kamaelia(Download)
 
import Axon.AdaptiveCommsComponent
from Axon.Ipc import producerFinished, shutdownMicroprocess, ipc
from Axon.Linkage import linkage
from Axon import Ipc
 
 
class addsink(ipc):
class removesink(ipc):
    """\
    removesink(sink[,sinkbox][,sinkcontrol]) -> new removesink message.
 
    Message specifying a target component and inbox(es), requesting they be

  1 | 2  Next