Update app.py

app.py

@@ -14,6 +14,15 @@ rtc_configuration = {
 def flip_vertically(image):
     return np.flip(image, axis=0)
 
+# Server-side function to process video stream
+def process_stream(webrtc_input):
+    # This function will receive frames from the WebRTC input
+    for frame in webrtc_input:
+        if frame is not None:
+            # Process the frame (e.g., flip vertically)
+            processed_frame = flip_vertically(frame)
+            yield processed_frame
+
 # Gradio app setup
 with gr.Blocks() as demo:
     gr.HTML("<h1 style='text-align: center'>Real-Time Webcam Stream with FastRTC</h1>")
@@ -34,12 +43,11 @@ with gr.Blocks() as demo:
         rtc_configuration=rtc_configuration,
     )
     
-    # Process video frames in real time using change event
-    webrtc_input.change(
-        fn=flip_vertically,
+    # Connect input to output through the processing function
+    demo.load(
+        fn=process_stream,
         inputs=[webrtc_input],
         outputs=[webrtc_output],
-        _js="() => {}",  # Ensures continuous streaming
         queue=True,
         every=0.1,  # Process frames every 0.1 seconds for real-time effect
     )