(self, name, args)
| 7 | @register(inputs=['inp']) |
| 8 | class Sink: |
| 9 | def __init__(self, name, args): |
| 10 | self.data_n = args['data_n'] |
| 11 | self.node_n = args['node_n'] |
| 12 | self.count = 0 |
| 13 | |
| 14 | def exec(self): |
| 15 | envelope = self.inp.recv() |
nothing calls this directly
no outgoing calls
no test coverage detected