Add API-modernize-todo on `experimental._pubsub.fan_out_to_ctxs`

SDOF_pre_sin_testing_XPSBACKUP
Tyler Goodlet 2025-04-06 14:46:25 -04:00
parent ddb299488a
commit 4621c528ac
1 changed files with 2 additions and 0 deletions

View File

@ -45,6 +45,8 @@ __all__ = ['pub']
log = get_logger('messaging')
# TODO! this needs to reworked to use the modern
# `Context`/`MsgStream` APIs!!
async def fan_out_to_ctxs(
pub_async_gen_func: typing.Callable, # it's an async gen ... gd mypy
topics2ctxs: dict[str, list],