(self)
| 93 | return self.Q.qsize() > 0 |
| 94 | |
| 95 | def stop(self): |
| 96 | # indicate that the thread should be stopped |
| 97 | self.stopped = True |
| 98 | # wait until stream resources are released (producer thread might be still grabbing frame) |
| 99 | self.thread.join() |
nothing calls this directly
no outgoing calls
no test coverage detected