Skip to content

Commit

Permalink
v0.23.4: Fix inaccurate doc strings.
Browse files Browse the repository at this point in the history
  • Loading branch information
rmlibre committed Jun 6, 2024
1 parent af29d18 commit 06ccff8
Showing 1 changed file with 8 additions and 6 deletions.
14 changes: 8 additions & 6 deletions aiootp/asynchs/concurrency_interface.py
Original file line number Diff line number Diff line change
Expand Up @@ -51,8 +51,9 @@ def _run_async_func(
**kwargs: t.Any,
) -> None:
"""
Used by the class to handle retreiving return values from new
async or sync processes / threads spawned using a pool.
Used by the class to retrieve return values from an async or
sync `func` run in a new process / thread by storing the result
in a shared `state` container.
"""
if is_async_function(func):
run = new_event_loop().run_until_complete
Expand All @@ -69,8 +70,9 @@ def _run_func(
**kwargs: t.Any,
) -> None:
"""
Used by the class to handle retreiving return values from new
sync processes / threads spawned using a pool.
Used by the class to retrieve return values from a sync `func`
run in a new process / thread by storing the result in a shared
`state` container.
"""
state.append(func(*args, **kwargs))

Expand All @@ -82,8 +84,8 @@ def _get_result(
**kwargs: t.Any,
) -> t.Any:
"""
Used by the class to handle retreiving return values from new
processes spawned using the process pool.
Returns the result of `func` run in a new process / thread using
the class' pool.
"""
if is_async_function(func):
run = new_event_loop().run_until_complete
Expand Down

0 comments on commit 06ccff8

Please sign in to comment.