import asyncio
from mavsdk import System
import time

async def print_connect(drone):
    async for state in drone.core.connection_state():
        print(f"{state}")


async def run():
    
    drone = System()
    await drone.connect(system_address="udp://:14550",  timeout=10)

    # drone = System(mavsdk_server_address='localhost', port=50053)
    # await drone.connect()
    
    print("Connected to drone!")

    asyncio.ensure_future(print_connect(drone))

    drone.core.connection_state()

    while True:
        await asyncio.sleep(1)


asyncio.get_event_loop().run_until_complete(run())






print("Finish")