
                         d    S SK JrJr  S SKJr  S SKJr  S SKJr   " S S\5      r	 " S S\	5      r
g	)
    )ABCabstractmethod)CallableFailedPrecondition)PubsubMessagec                   >    \ rS rSrSr\S\S\/ S4   4S j5       rSr	g)NackHandler   z\
A NackHandler handles calls to the nack() method which is not expressible in Pub/Sub Lite.
messageackNc                     g)aH  Handle 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.
N selfr   r   s      Clib/third_party/google/cloud/pubsublite/cloudpubsub/nack_handler.pyon_nackNackHandler.on_nack   s     	    r   )
__name__
__module____qualname____firstlineno____doc__r   r   r   r   __static_attributes__r   r   r   r
   r
      s2     } 8BH3E  r   r
   c                   0    \ rS rSrS\S\/ S4   4S jrSrg)DefaultNackHandler+   r   r   Nc                     [        S5      e)NzpYou may not nack messages by default when using a PubSub Lite client. See NackHandler for how to customize this.r   r   s      r   r   DefaultNackHandler.on_nack,   s     
 	
r   r   )r   r   r   r   r   r   r   r   r   r   r   r   r   +   s    
} 
8BH3E 
r   r   N)abcr   r   typingr   google.api_core.exceptionsr   google.pubsub_v1r   r
   r   r   r   r   <module>r%      s+    $  9 *# *
 
r   