code: def read_blocks(stream):
      
      while True:
          header = _read_header(stream)
          block  = _read_block(header[1], stream)
          yield (header, block)
docs: Generate parsed blocks from input stream