From fbf823293954ee35aaf6d3cc9139b1929b47f395 Mon Sep 17 00:00:00 2001 From: Ivan Nikolic Date: Fri, 16 Jan 2026 15:50:59 +0800 Subject: [PATCH] small docs clarification --- docs/api/sensor_streams/advanced_streams.md | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/docs/api/sensor_streams/advanced_streams.md b/docs/api/sensor_streams/advanced_streams.md index c7db7c98bd..41199d4366 100644 --- a/docs/api/sensor_streams/advanced_streams.md +++ b/docs/api/sensor_streams/advanced_streams.md @@ -151,7 +151,10 @@ from reactivex import operators as ops from dimos.utils.reactive import getter_hot source = rx.interval(0.1).pipe(ops.take(10)) -get_val = getter_hot(source, timeout=5.0) + +get_val = getter_hot(source, timeout=5.0) # blocks until first message, with 5s timeout +# alternatively not to block (but get_val() might return None) +# get_val = getter_hot(source, nonblocking = True) print("first call:", get_val()) # instant - value already there time.sleep(0.35)