def generator(f):
    @processor
    def new_func(stream, *args, **kwargs):
        for item in stream:
            yield item
        for item in f(*args, **kwargs):
            yield item
    return update_wrapper(new_func, f)
Similar to the :func:`processor` but passes through old values
dataset/ETHPy150Open pallets/click/examples/imagepipe/imagepipe.py/generator