def next()

in amazon_transcribe/eventstream.py [0:0]

• 8 lines of code
• 4 McCabe index (conditional complexity)

    def next(self) -> EventStreamMessage:
        """Provides the next available message parsed from the stream"""
        if len(self._data) < _PRELUDE_LENGTH:
            raise StopIteration()

        if self._prelude is None:
            self._prelude = self._parse_prelude()

        if len(self._data) < self._prelude.total_length:
            raise StopIteration()

        return self._parse_message()