dddlmZmZddlmZddlmZddlmZGddeZ Gdde Z y ) )ABCabstractmethod)CallableFailedPrecondition) PubsubMessagec4eZdZdZededegdffdZy) NackHandlerzd A NackHandler handles calls to the nack() method which is not expressible in Pub/Sub Lite. messageackNcy)aHandle a negative acknowledgement. ack must eventually be called. This method will be called on an event loop and should not block. Args: message: The nacked message. ack: A callable to acknowledge the underlying message. This must eventually be called. Raises: GoogleAPICallError: To fail the client if raised inline. Nselfr r s Clib/third_party/google/cloud/pubsublite/cloudpubsub/nack_handler.pyon_nackzNackHandler.on_nacks )__name__ __module__ __qualname____doc__rrrrrrrr r s2  }  8BH3E    rr c&eZdZdedegdffdZy)DefaultNackHandlerr r Nctd)NzpYou may not nack messages by default when using a PubSub Lite client. See NackHandler for how to customize this.rrs rrzDefaultNackHandler.on_nack,s    r)rrrrrrrrrrr+s } 8BH3E rrN) abcrrtypingrgoogle.api_core.exceptionsrgoogle.pubsub_v1rr rrrrrs+$9* # *  r