sascha/esphome
1
0
Fork 0
mirror of https://github.com/esphome/esphome.git synced 2025-10-22 03:33:52 +01:00
Code Issues Releases Wiki Activity

tweak

Browse Source
This commit is contained in:
J. Nick Koston
2025-10-15 19:29:55 -10:00
parent 92d54ffb09
commit a999349fa5
1 changed files with 6 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
esphome/components/sensor/__init__.py
View File

@@ -463,7 +463,8 @@ async def min_filter_to_code(config, filter_id):
# Saves 99.98% memory for large windows (e.g., 20KB → 4 bytes for window_size=5000)
if window_size == send_every:
# Use streaming filter - O(1) memory instead of O(n)
return cg.Pvariable(filter_id, StreamingMinFilter, window_size, send_first_at)
rhs = cg.new_Pvariable(StreamingMinFilter, window_size, send_first_at)
return cg.Pvariable(filter_id, rhs)
# Use sliding window filter - maintains ring buffer
return cg.new_Pvariable(filter_id, window_size, send_every, send_first_at)
@@ -488,7 +489,8 @@ async def max_filter_to_code(config, filter_id):
# Optimization: Use streaming filter for batch windows (window_size == send_every)
if window_size == send_every:
return cg.Pvariable(filter_id, StreamingMaxFilter, window_size, send_first_at)
rhs = cg.new_Pvariable(StreamingMaxFilter, window_size, send_first_at)
return cg.Pvariable(filter_id, rhs)
return cg.new_Pvariable(filter_id, window_size, send_every, send_first_at)
@@ -516,9 +518,8 @@ async def sliding_window_moving_average_filter_to_code(config, filter_id):
# Optimization: Use streaming filter for batch windows (window_size == send_every)
if window_size == send_every:
return cg.Pvariable(
filter_id, StreamingMovingAverageFilter, window_size, send_first_at
)
rhs = cg.new_Pvariable(StreamingMovingAverageFilter, window_size, send_first_at)
return cg.Pvariable(filter_id, rhs)
return cg.new_Pvariable(filter_id, window_size, send_every, send_first_at)