(self, pipe)
| 100 | self.active_sinks.add(pipe) |
| 101 | |
| 102 | def get_pipe_list(self, pipe): |
| 103 | # type: (Pipe) -> Set[Any] |
| 104 | def flatten(p, # type: Any |
| 105 | li, # type: Set[Pipe] |
| 106 | ): |
| 107 | # type: (...) -> None |
| 108 | li.add(p) |
| 109 | for q in p.sources | p.sinks | p.high_sources | p.high_sinks: |
| 110 | if q not in li: |
| 111 | flatten(q, li) |
| 112 | pl = set() # type: Set[Pipe] |
| 113 | flatten(pipe, pl) |
| 114 | return pl |
| 115 | |
| 116 | def _add_pipes(self, *pipes): |
| 117 | # type: (*Pipe) -> Set[Pipe] |