(self, in_buffer_size: int = 1, out_buffer_size: int = 1)
| 73 | |
| 74 | class Node: |
| 75 | def __init__(self, in_buffer_size: int = 1, out_buffer_size: int = 1) -> None: |
| 76 | self.input: Queue = Queue(maxsize=in_buffer_size) |
| 77 | self.output: Queue = Queue(maxsize=out_buffer_size) |
| 78 | self.in_buffer_size = in_buffer_size |
| 79 | self.out_buffer_size = out_buffer_size |
| 80 | |
| 81 | @abstractmethod |
| 82 | def start(self): |
no outgoing calls
no test coverage detected