
    ~                     2    S SK Jr  S SKJr   " S S\5      rg)    )ContextManager)FailedPreconditionc                   ,    \ rS rSrS rS rS rS rSrg)RequireStarted   c                     SU l         g )NF_startedselfs    Clib/third_party/google/cloud/pubsublite/internal/require_started.py__init__RequireStarted.__init__   s	        c                 L    U R                   (       a  [        S5      eSU l         U $ )Nz__enter__ called twice.Tr
   r   r   s    r   	__enter__RequireStarted.__enter__   s!    ==$%>??r   c                 <    U R                   (       d  [        S5      eg )Nz __enter__ has never been called.r   r   s    r   require_startedRequireStarted.require_started   s    }}$%GHH r   c                 $    U R                  5         g )N)r   )r   exc_type	exc_value	tracebacks       r   __exit__RequireStarted.__exit__"   s    r   r	   N)	__name__
__module____qualname____firstlineno__r   r   r   r   __static_attributes__ r   r   r   r      s    Ir   r   N)typingr   google.api_core.exceptionsr   r   r#   r   r   <module>r&      s    " 9^ r   