(self, pipe)
| 90 | self.send(_cmd) |
| 91 | |
| 92 | def add_one_pipe(self, pipe): |
| 93 | # type: (Pipe) -> None |
| 94 | self.active_pipes.add(pipe) |
| 95 | if isinstance(pipe, Source): |
| 96 | self.active_sources.add(pipe) |
| 97 | if isinstance(pipe, Drain): |
| 98 | self.active_drains.add(pipe) |
| 99 | if isinstance(pipe, Sink): |
| 100 | self.active_sinks.add(pipe) |
| 101 | |
| 102 | def get_pipe_list(self, pipe): |
| 103 | # type: (Pipe) -> Set[Any] |