def bz2_decompress_stream(src):
dec = bz2.BZ2Decompressor()<EOL>for block in src:<EOL><INDENT>decoded = dec.decompress(block)<EOL>if decoded:<EOL><INDENT>yield decoded<EOL><DEDENT><DEDENT>
Decompress data from `src`.

    Args:
        src (iterable): iterable that yields blocks of compressed data

    Yields:
        blocks of uncompressed data