(self, name=None)
| 356 | |
| 357 | class Source(Pipe, ObjectPipe[Any]): |
| 358 | def __init__(self, name=None): |
| 359 | # type: (Optional[str]) -> None |
| 360 | ObjectPipe.__init__(self, name) |
| 361 | Pipe.__init__(self, name=name) |
| 362 | self.is_exhausted = False |
| 363 | |
| 364 | def _read_message(self): |
| 365 | # type: () -> Message |