MCPcopy
hub / github.com/lllyasviel/FramePack / next

Method next

diffusers_helper/thread_utils.py:64–70  ·  view source on GitHub ↗
(self)

Source from the content-addressed store, hash-verified

62 return None
63
64 def next(self):
65 while True:
66 with self.lock:
67 if self.queue:
68 return self.queue.pop(0)
69
70 time.sleep(0.001)
71
72
73class AsyncStream:

Callers 2

processFunction · 0.80
processFunction · 0.80

Calls 1

popMethod · 0.80

Tested by

no test coverage detected