def __iter__()

in instrumentation/elastic-opentelemetry-instrumentation-openai/src/opentelemetry/instrumentation/openai/wrappers.py [0:0]

• 10 lines of code
• 3 McCabe index (conditional complexity)

    def __iter__(self):
        stream = self.__wrapped__
        try:
            for chunk in stream:
                self.process_chunk(chunk)
                yield chunk
        except Exception as exc:
            self.end(exc)
            raise
        self.end()