In [1]:

    

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

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


    

In [2]:

    

a = pipecat.device.clock.metronome(pipecat.quantity(.25, pipecat.units.seconds))
a = pipecat.utility.add_field(a, "id", "a")
a = pipecat.utility.add_timestamp(a)

b = pipecat.device.clock.metronome(pipecat.quantity(1, pipecat.units.seconds))
b = pipecat.utility.add_field(b, "id", "b")
b = pipecat.utility.add_timestamp(b)

pipe = pipecat.connect.multiplex(a, b)
pipe = pipecat.limit.count(pipe, count=10)

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


    

    




id: a
timestamp: 2016-12-06T06:32:26.326341+00:00

id: b
timestamp: 2016-12-06T06:32:26.326696+00:00

id: a
timestamp: 2016-12-06T06:32:26.576770+00:00

id: a
timestamp: 2016-12-06T06:32:26.829274+00:00

id: a
timestamp: 2016-12-06T06:32:27.079391+00:00

id: b
timestamp: 2016-12-06T06:32:27.330572+00:00

id: a
timestamp: 2016-12-06T06:32:27.333998+00:00

id: a
timestamp: 2016-12-06T06:32:27.586940+00:00

id: a
timestamp: 2016-12-06T06:32:27.838739+00:00







    




INFO:pipecat:Iteration stopped after 10 records.






    




id: a
timestamp: 2016-12-06T06:32:28.090908+00:00

In [ ]: