Skip to content

Commit 6571107

Browse files
committed
Update select example to use Receiver.triggered
Signed-off-by: Sahas Subramanian <[email protected]>
1 parent 23ccbe8 commit 6571107

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

src/frequenz/channels/_select.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -376,14 +376,14 @@ async def select( # noqa: DOC503
376376
import datetime
377377
from typing import assert_never
378378
379-
from frequenz.channels import ReceiverStoppedError, select, selected_from
379+
from frequenz.channels import ReceiverStoppedError, select
380380
from frequenz.channels.timer import SkipMissedAndDrift, Timer, TriggerAllMissed
381381
382382
timer1 = Timer(datetime.timedelta(seconds=1), TriggerAllMissed())
383383
timer2 = Timer(datetime.timedelta(seconds=0.5), SkipMissedAndDrift())
384384
385385
async for selected in select(timer1, timer2):
386-
if selected_from(selected, timer1):
386+
if timer1.triggered(selected):
387387
# Beware: `selected.message` might raise an exception, you can always
388388
# check for exceptions with `selected.exception` first or use
389389
# a try-except block. You can also quickly check if the receiver was
@@ -393,7 +393,7 @@ async def select( # noqa: DOC503
393393
continue
394394
print(f"timer1: now={datetime.datetime.now()} drift={selected.message}")
395395
timer2.stop()
396-
elif selected_from(selected, timer2):
396+
elif timer2.triggered(selected):
397397
# Explicitly handling of exceptions
398398
match selected.exception:
399399
case ReceiverStoppedError():

0 commit comments

Comments
 (0)