(*args, **kargs)
| 73 | dname = attr[6:] |
| 74 | if dname in self.pipes: |
| 75 | def f(*args, **kargs): |
| 76 | # type: (*Any, **Any) -> Pipe |
| 77 | k = self.pipes[dname] |
| 78 | p = k(*args, **kargs) # type: Pipe |
| 79 | self.add(p) |
| 80 | return p |
| 81 | return f |
| 82 | raise AttributeError(attr) |
| 83 |