def batch_receive()

in pulsar/__init__.py [0:0]

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

    def batch_receive(self):
        """
        Batch receiving messages.

        This calls blocks until has enough messages or wait timeout, more details to see {@link BatchReceivePolicy}.
        """
        messages = []
        msgs = self._consumer.batch_receive()
        for msg in msgs:
            m = Message()
            m._message = msg
            messages.append(m)
        return messages