| 253 | |
| 254 | class Pipe(metaclass=_PipeMeta): |
| 255 | def __init__(self, name=None): |
| 256 | # type: (Optional[str]) -> None |
| 257 | self.sources = set() # type: Set['Pipe'] |
| 258 | self.sinks = set() # type: Set['Sink'] |
| 259 | self.high_sources = set() # type: Set['Pipe'] |
| 260 | self.high_sinks = set() # type: Set['Sink'] |
| 261 | self.trigger_sources = set() # type: Set['Pipe'] |
| 262 | self.trigger_sinks = set() # type: Set['TriggerSink'] |
| 263 | if name is None: |
| 264 | name = "%s" % (self.__class__.__name__) |
| 265 | self.name = name |
| 266 | |
| 267 | def _send(self, msg): |
| 268 | # type: (Any) -> None |