deepgeek/gradio-webrtc
2
0
Fork 0
mirror of https://github.com/HumanAIGC-Engineering/gradio-webrtc.git synced 2026-02-04 17:39:23 +08:00
Code Issues Packages Projects Releases Wiki Activity

fixes (#145)

Browse Source
This commit is contained in:
Freddy Boulton
2025-03-07 14:15:37 -05:00
committed by GitHub
parent 11dae295da
commit 6748a8df49
3 changed files with 5 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
backend/fastrtc/stream.py
View File

@@ -183,7 +183,7 @@ class Stream(WebRTCConnectionMixin):
if component in additional_output_components if component in additional_output_components
] ]
for component in additional_output_components: for component in additional_output_components:
if component not in same_components: if component in same_components:
same_components.append(component) same_components.append(component)
if self.modality == "video" and self.mode == "receive": if self.modality == "video" and self.mode == "receive":
with gr.Blocks() as demo: with gr.Blocks() as demo:
@@ -230,6 +230,7 @@ class Stream(WebRTCConnectionMixin):
assert self.additional_outputs_handler assert self.additional_outputs_handler
output_video.on_additional_outputs( output_video.on_additional_outputs(
self.additional_outputs_handler, self.additional_outputs_handler,
inputs=additional_output_components,
outputs=additional_output_components, outputs=additional_output_components,
) )
elif self.modality == "video" and self.mode == "send": elif self.modality == "video" and self.mode == "send":
@@ -275,6 +276,7 @@ class Stream(WebRTCConnectionMixin):
assert self.additional_outputs_handler assert self.additional_outputs_handler
output_video.on_additional_outputs( output_video.on_additional_outputs(
self.additional_outputs_handler, self.additional_outputs_handler,
inputs=additional_output_components,
outputs=additional_output_components, outputs=additional_output_components,
) )
elif self.modality == "video" and self.mode == "send-receive": elif self.modality == "video" and self.mode == "send-receive":

9
frontend/shared/StaticAudio.svelte
View File

@@ -36,14 +36,6 @@
stop: undefined; stop: undefined;
}>(); }>();
onMount(() => {
window.setInterval(() => {
if (stream_state == "open") {
dispatch("tick");
}
}, 1000);
});
async function start_stream(value: string): Promise<string> { async function start_stream(value: string): Promise<string> {
if (value === "start_webrtc_stream") { if (value === "start_webrtc_stream") {
stream_state = "waiting"; stream_state = "waiting";
@@ -55,6 +47,7 @@
case "connected": case "connected":
console.info("connected"); console.info("connected");
stream_state = "open"; stream_state = "open";
dispatch("tick");
break; break;
case "disconnected": case "disconnected":
console.info("closed"); console.info("closed");

9
frontend/shared/StaticVideo.svelte
View File

@@ -27,14 +27,6 @@
let stream_state = "closed"; let stream_state = "closed";
onMount(() => {
window.setInterval(() => {
if (stream_state == "open") {
dispatch("tick");
}
}, 1000);
});
$: if (value === "start_webrtc_stream") { $: if (value === "start_webrtc_stream") {
_webrtc_id = Math.random().toString(36).substring(2); _webrtc_id = Math.random().toString(36).substring(2);
value = _webrtc_id; value = _webrtc_id;
@@ -43,6 +35,7 @@
switch (pc.connectionState) { switch (pc.connectionState) {
case "connected": case "connected":
stream_state = "open"; stream_state = "open";
dispatch("tick");
break; break;
case "disconnected": case "disconnected":
stop(pc); stop(pc);