continuous non-line delimited json stream

parser.py

import subprocess, json


def parse_json_dynamic(stream):
    dec = json.JSONDecoder()
    buf = ''
    for chunk in stream:
        buf += chunk
        while True:
            try:
                obj, idx = dec.raw_decode(buf)
            except json.JSONDecodeError:
                break
            yield obj
            buf = buf[idx:].lstrip()


import io
f = io.StringIO()
f.write("{\n")
f.write(' "hello": "world",\n')
f.write(' "nice": "test"\n')
f.write("}\n")
f.write("{\n")
f.write(' "hello": "world",\n')
f.write(' "nice": "test"\n')
f.write("}\n")
f.seek(0)

for obj in parse_json_dynamic(f):
    print(obj)