Last active
November 2, 2022 13:41
-
-
Save mturoci/e6b54ea59ea9aad4c6d8f8edad17ee1d to your computer and use it in GitHub Desktop.
Temporary workaround to prevent 1st frame from being dropped during streaming.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| # Image / Stream | |
| # Display an image and continuously update it in real time. | |
| # --- | |
| import io | |
| import time | |
| import uuid | |
| import cv2 | |
| from h2o_wave import app, Q, ui, main | |
| import numpy as np | |
| frame_count = 256 | |
| def create_random_image(bgr): | |
| frame = np.zeros((512, 512, 3), dtype=np.uint8) | |
| frame[0:-1, 0:-1] = bgr | |
| _, img = cv2.imencode('.jpg', frame) | |
| return io.BytesIO(img) | |
| @app('/demo') | |
| async def serve(q: Q): | |
| # Mint a unique name for our image stream | |
| stream_name = f'stream/demo/{uuid.uuid4()}.jpeg' | |
| # Send image | |
| endpoint = await q.site.uplink(stream_name, 'image/jpeg', create_random_image([255, 0, 0])) | |
| # Display image | |
| q.page['qux'] = ui.form_card(box='1 1 4 7', items=[ui.image('Image Stream', path=endpoint)]) | |
| await q.page.save() | |
| for i in range(0, 3): | |
| d = { | |
| 0: [[255, 0, 0], 'Blue'], | |
| 1: [[0, 255, 0], 'Green'], | |
| 2: [[0, 0, 255], 'Red'], | |
| } | |
| # Send image (use stream name as before). | |
| await q.site.uplink(stream_name, 'image/jpeg', create_random_image(d[i][0])) | |
| print(f'{i} -> {d[i][1]}') | |
| await q.sleep(1) | |
| await q.site.unlink(stream_name) |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment