def _listener_wrapper()

in pulsar/__init__.py [0:0]

• 9 lines of code
• 1 McCabe index (conditional complexity)

def _listener_wrapper(listener, schema):
    def wrapper(consumer, msg):
        c = Consumer()
        c._consumer = consumer
        m = Message()
        m._message = msg
        m._schema = schema
        listener(c, m)
    return wrapper