Skip to content

Commit f78e5eb

Browse files
committed
Reimplement selected_from based on Receiver.triggered
Signed-off-by: Sahas Subramanian <[email protected]>
1 parent ffc361d commit f78e5eb

File tree

1 file changed

+2
-4
lines changed

1 file changed

+2
-4
lines changed

src/frequenz/channels/_select.py

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -269,9 +269,7 @@ def selected_from(
269269
Returns:
270270
Whether the given receiver was selected.
271271
"""
272-
if handled := selected._recv is receiver: # pylint: disable=protected-access
273-
selected._handled = True # pylint: disable=protected-access
274-
return handled
272+
return receiver.triggered(selected)
275273

276274

277275
class SelectError(Error):
@@ -378,7 +376,7 @@ async def select( # noqa: DOC503
378376
import datetime
379377
from typing import assert_never
380378
381-
from frequenz.channels import ReceiverStoppedError, select, selected_from
379+
from frequenz.channels import ReceiverStoppedError, select
382380
from frequenz.channels.timer import SkipMissedAndDrift, Timer, TriggerAllMissed
383381
384382
timer1 = Timer(datetime.timedelta(seconds=1), TriggerAllMissed())

0 commit comments

Comments
 (0)