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.