cvb/StreamingAsync

# CVBpy Example Script
#
# 1. Open the CVMock.vin driver.
# 2. Asynchronously acquire images.
# 3. Measure the frame rate and print results.
#
# Note: can be extended to multible cameras.


import os
import asyncio
import cvb




rate_counter = None

async def async_acquire(port):
    global rate_counter
    with cvb.DeviceFactory.open(os.path.join(cvb.install_path(), "drivers", "CVMock.vin"), port=port) as device:
        stream = device.stream()
        stream.start()

        rate_counter = cvb.RateCounter()

        for i in range(0, 100):
            result = await  stream.wait_async()
            image, status = result.value
            rate_counter.step()
            if status == cvb.WaitStatus.Ok:
                print("Buffer index: " + str(image.buffer_index) + " from stream: " + str(port))

        stream.abort()
    



watch = cvb.StopWatch()

loop = asyncio.get_event_loop()
loop.run_until_complete(asyncio.gather(
    async_acquire(port=0))) 
loop.close()

duration = watch.time_span

print("Acquired on port 0 with " + str(rate_counter.rate) + " fps")
print("Overall measurement time: " +str(duration / 1000) + " seconds")