A possibly useful async2sync convertor

run_coro.py

import asyncio
from inspect import iscoroutine, isasyncgen
from concurrent.futures import ThreadPoolExecutor

import nest_asyncio
nest_asyncio.apply()

def _iter_coro(r):
    loop = asyncio.get_event_loop()
    if loop.is_running():
        with ThreadPoolExecutor() as ex:
            try:
                while True: yield ex.submit(loop.run_until_complete, r.__anext__()).result()
            except StopAsyncIteration: return

def run_coro(r):
    "Run coroutine `r` if it is one, otherwise just return `r` directly"
    if isasyncgen(r): return _iter_coro(r)
    if not iscoroutine(r): return r
    loop = asyncio.get_event_loop()
    if loop.is_running():
        with ThreadPoolExecutor() as ex: return ex.submit(asyncio.run, r).result()
    return loop.run_until_complete(r)

async def g():
    for i in range(10): yield i

for i in run_coro(g()): print(i, end=' ')

async def f(msgs:list):
    async with AsyncAnthropic().messages.stream(model=models[1], messages=mk_msgs(msgs), max_tokens=20) as s:
        async for o in s.text_stream: yield o

for o in run_coro(f('hi')): print(o, end='')