Function janus_kafka::noop_publisher_ack_handler [−][src]
pub async fn noop_publisher_ack_handler<M, A>(
handler: A
) -> Result<(), A::Error> where
M: MessageExt,
A: AckHandler,
<A as AckHandler>::Output: Future<Output = Result<M, (M, A::Error)>>,
Awaits each future returned by the publisher ack handler.