def METHOD_NAME(self, o, *args, **kw):
    registry = ProxyRegistry()
    obj = self.inject_proxies(o, registry)
    for chunk in super().METHOD_NAME(obj, *args, **kw):
        yield registry.extract(chunk)
    registry.verify()