jeans/core
jeans/core
1
0
Fork 0
mirror of https://github.com/home-assistant/core.git synced 2025-07-26 06:37:52 +00:00
Code Issues Packages Projects Releases Wiki Activity

Defer preload stream start on startup (#75801)

Browse Source
This commit is contained in:
uvjustin 2022-08-08 23:15:31 +08:00 committed by GitHub
parent 9f240d5bab
commit 6540bed59d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
homeassistant/components/camera/__init__.py
View File

@ -39,7 +39,7 @@ from homeassistant.const import (
ATTR_ENTITY_ID, ATTR_ENTITY_ID,
CONF_FILENAME, CONF_FILENAME,
CONTENT_TYPE_MULTIPART, CONTENT_TYPE_MULTIPART,
EVENT_HOMEASSISTANT_START, EVENT_HOMEASSISTANT_STARTED,
SERVICE_TURN_OFF, SERVICE_TURN_OFF,
SERVICE_TURN_ON, SERVICE_TURN_ON,
) )
@ -374,7 +374,7 @@ async def async_setup(hass: HomeAssistant, config: ConfigType) -> bool:
stream.add_provider("hls") stream.add_provider("hls")
await stream.start() await stream.start()
hass.bus.async_listen_once(EVENT_HOMEASSISTANT_START, preload_stream) hass.bus.async_listen_once(EVENT_HOMEASSISTANT_STARTED, preload_stream)
@callback @callback
def update_tokens(time: datetime) -> None: def update_tokens(time: datetime) -> None:

6
tests/components/camera/test_init.py
View File

@ -13,7 +13,7 @@ from homeassistant.components.websocket_api.const import TYPE_RESULT
from homeassistant.config import async_process_ha_core_config from homeassistant.config import async_process_ha_core_config
from homeassistant.const import ( from homeassistant.const import (
ATTR_ENTITY_ID, ATTR_ENTITY_ID,
EVENT_HOMEASSISTANT_START, EVENT_HOMEASSISTANT_STARTED,
STATE_UNAVAILABLE, STATE_UNAVAILABLE,
) )
from homeassistant.exceptions import HomeAssistantError from homeassistant.exceptions import HomeAssistantError
@ -374,7 +374,7 @@ async def test_no_preload_stream(hass, mock_stream):
) as mock_stream_source: ) as mock_stream_source:
mock_stream_source.return_value = io.BytesIO() mock_stream_source.return_value = io.BytesIO()
await async_setup_component(hass, "camera", {DOMAIN: {"platform": "demo"}}) await async_setup_component(hass, "camera", {DOMAIN: {"platform": "demo"}})
hass.bus.async_fire(EVENT_HOMEASSISTANT_START) hass.bus.async_fire(EVENT_HOMEASSISTANT_STARTED)
await hass.async_block_till_done() await hass.async_block_till_done()
assert not mock_request_stream.called assert not mock_request_stream.called
@ -396,7 +396,7 @@ async def test_preload_stream(hass, mock_stream):
hass, "camera", {DOMAIN: {"platform": "demo"}} hass, "camera", {DOMAIN: {"platform": "demo"}}
) )
await hass.async_block_till_done() await hass.async_block_till_done()
hass.bus.async_fire(EVENT_HOMEASSISTANT_START) hass.bus.async_fire(EVENT_HOMEASSISTANT_STARTED)
await hass.async_block_till_done() await hass.async_block_till_done()
assert mock_create_stream.called assert mock_create_stream.called