view flax/Ports.py @ 798:5c158d37f1ce

autoretry websocket. fix rdflib quad patching. only rerun handlers that asked for the affected subj-preds. Ignore-this: 31e03cf07e5d460ea5c72d7beccefe7
author drewp@bigasterisk.com
date Mon, 16 Jul 2012 00:49:57 +0000
parents 45b12307c695
children
line wrap: on
line source

# super rough code

class AbstractPort:
    def __init__(self):
        pass
    def put_data(self, value):
        pass
    def get_data(self):
        pass

class Port(AbstractPort):
    "Connects from a node to exactly one node."
    def __init__(self, value=None):
        AbstractPort.__init__(self)
        self.value = value
    def put_data(self, value):
        self.value = value
    def get_data(self):
        return self.value

class MultiPort(AbstractPort):
    "Connects from a node to any number of nodes."
    def __init__(self, values=None):
        AbstractPort.__init__(self)
        self.values = values
    def put_data(self, values):
        self.values = values
    def get_data(self):
        return self.values