(settings: Settings)
Run the server tasks. Will not return.
Run the server tasks. Will not return.
Run the server tasks . Will not return .
async def run(settings: Settings) -> None:
    """Run the server tasks. Will not return."""
    queue: Queue = Queue()

    subtask = asyncio.create_task(
        _subscriber_server_task(
            create_publisher(settings.subscriber_address.connection_string()), queue
        )
    )
    pubtask = asyncio.create_task(
        _publisher_server_task(
            create_pull(settings.publisher_address.connection_string()), queue
        )
    )
    await asyncio.gather(subtask, pubtask)
async def run ( settings : Settings ) -> None : queue : Queue = Queue ( ) subtask = asyncio . create_task ( _subscriber_server_task ( create_publisher ( settings . subscriber_address . connection_string ( ) ) , queue ) ) pubtask = asyncio . create_task ( _publisher_server_task ( create_pull ( settings . publisher_address . connection_string ( ) ) , queue ) ) await asyncio . gather ( subtask , pubtask )