happyly.listening.listener.EarlyAckExecutor

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

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

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