happyly.listening.listener.EarlyAckListener

class happyly.listening.listener.EarlyAckListener(subscriber, handler, deserializer, serializer=<happyly.serialization.dummy.DummySerde object>, publisher=None)

Bases: happyly.listening.listener.ListenerWithAck, typing.Generic

Acknowledge-aware BaseListener, which performs ack() right after on_received() callback is finished.