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

Class AsyncStream

diffusers_helper/thread_utils.py:73–76  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

71
72
73class AsyncStream:
74 def __init__(self):
75 self.input_queue = FIFOQueue()
76 self.output_queue = FIFOQueue()

Callers 4

demo_gradio.pyFile · 0.90
processFunction · 0.90
demo_gradio_f1.pyFile · 0.90
processFunction · 0.90

Calls

no outgoing calls

Tested by

no test coverage detected