БГ
import asyncio
def get_connections_factory(addr, unixsocket):
if unixsocket:
connect = asyncio.open_unix_connection
else:
connect = asyncio.open_connection
async def factory(coro):
return connect(addr)
return factory