parameters: (settings: Settings)
docstring: Run the server tasks. Will not return.
docstring_summary: Run the server tasks. Will not return.
docstring_tokens: Run the server tasks . Will not return .
function: 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)
function_tokens: 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 )