Streams_in_parallel.py

api = Savoir(rpcuser, rpcpassword, rpchost, rpcport, chainName)

def fetchParallel(streamName, streamLen): 
    p = mp.Pool(processes=2)
    args = [(streamName, False, streamLen, streamLen//2), (streamName False, streamLen//2, 0)]
    start = time()
    p.starmap(api.liststreamitems, args)
    end = time()
    return end-start


def fetchNormal(streamName, streamLen):
    start = time()
    api.liststreamitems(streamName, False, streamLen, 0)
    end = time()
    return end-start
    
# Both functions return similar values. I'd expect fetchParallel to be half of fetchNormal.