Simple data generator with streamz

market_sim_stream.py

from streamz import Stream

def market_step(market_inputs):
    return {'market_movement': market_inputs['market_movement']}

def write(x):
    print(x)

def f(n=5):
    source = Stream(asynchronous=True)  # Configure the stream for asynchronous operation
    source.map(market_step).rate_limit(0.500).sink(write)

    for x in range(n):
        source.emit({'market_movement':x})  # Emit values into the stream

f(3)