code: def bz2_decompress_stream(src):
      
      dec = bz2.BZ2Decompressor()
      for block in src:
          decoded = dec.decompress(block)
          if decoded:
              yield decoded
docs: Decompress data from `src`.
  
      Args:
          src (iterable): iterable that yields blocks of compressed data
  
      Yields:
          blocks of uncompressed data