async def METHOD_NAME():
    mock_tunnel_community = Mock()
    mock_tunnel_community.send_data = lambda *_: None
    dispatcher = TunnelDispatcher(mock_tunnel_community)
    yield dispatcher
    await dispatcher.shutdown_task_manager()