In [1]:

    

import logging
logging.basicConfig(level=logging.DEBUG)

import pipecat.device.clock
import pipecat.limit
import pipecat.record
import pipecat.utility


    

In [2]:

    

pipe = pipecat.device.clock.metronome(rate=pipecat.quantity(0.5, pipecat.units.seconds))
pipe = pipecat.utility.add_timestamp(pipe)
pipe = pipecat.limit.duration(pipe, duration=pipecat.quantity(6, pipecat.units.seconds))

for record in pipe:
    pipecat.record.dump(record)


    

    




timestamp: 2016-12-06T06:33:31.633377+00:00

timestamp: 2016-12-06T06:33:32.138212+00:00

timestamp: 2016-12-06T06:33:32.639820+00:00

timestamp: 2016-12-06T06:33:33.142289+00:00

timestamp: 2016-12-06T06:33:33.642992+00:00

timestamp: 2016-12-06T06:33:34.143606+00:00

timestamp: 2016-12-06T06:33:34.648458+00:00

timestamp: 2016-12-06T06:33:35.151751+00:00

timestamp: 2016-12-06T06:33:35.652313+00:00

timestamp: 2016-12-06T06:33:36.152598+00:00

timestamp: 2016-12-06T06:33:36.652729+00:00

timestamp: 2016-12-06T06:33:37.153394+00:00







    




INFO:pipecat:Iteration stopped after 6 second time limit.






    




timestamp: 2016-12-06T06:33:37.653530+00:00