ó
    €ÏH  ã                   óN   • S SK Jr  S SKJr  S SKJr  S SKJrJr   " S S\5      r	g)é    )ÚFuture)ÚMapping)ÚManagedEventLoop)ÚSinglePublisherÚAsyncSinglePublisherc            	       ó|   ^ • \ rS rSr% \\S'   \\S'   S\4U 4S jjr SS\S\	S\
\	\	4   S	S
4S jjrS rS rSrU =r$ )ÚSinglePublisherImplé   Ú_managed_loopÚ_underlyingÚ
underlyingc                 óN   >• [         TU ]  5         [        S5      U l        Xl        g )NÚPublisherLoopThread)ÚsuperÚ__init__r   r   r   )Úselfr   Ú	__class__s     €ÚNlib/third_party/google/cloud/pubsublite/cloudpubsub/internal/publisher_impl.pyr   ÚSinglePublisherImpl.__init__   s"   ø€ Ü‰ÑÔÜ-Ð.CÓDˆÔØ%Õó    ÚdataÚordering_keyÚattrsÚreturnzFuture[str]c                 óp   • U R                   R                  U R                  R                  " SXS.UD65      $ )N)r   r   © )r   Úsubmitr   Úpublish)r   r   r   r   s       r   r   ÚSinglePublisherImpl.publish$   s9   € ð ×!Ñ!×(Ñ(Ø×Ñ×$Ò$ÐS¨$ÑSÈUÑSó
ð 	
r   c                 ó¼   • U R                   R                  5         U R                   R                  U R                  R	                  5       5      R                  5         U $ ©N)r   Ú	__enter__r   r   Ú
__aenter__Úresult)r   s    r   r"   ÚSinglePublisherImpl.__enter__+   sE   € Ø×Ñ×$Ñ$Ô&Ø×Ñ×!Ñ! $×"2Ñ"2×"=Ñ"=Ó"?Ó@×GÑGÔIØˆr   c                 óÂ   • U R                   R                  U R                  R                  XU5      5      R	                  5         U R                   R                  XU5        g r!   )r   r   r   Ú	__aexit__r$   Ú__exit__)r   Ú_SinglePublisherImpl__exc_typeÚ_SinglePublisherImpl__exc_valueÚ_SinglePublisherImpl__tracebacks       r   r(   ÚSinglePublisherImpl.__exit__0   sI   € Ø×Ñ×!Ñ!Ø×Ñ×&Ñ& zÀÓLó	
ç
‰&Œ(Ø×Ñ×#Ñ# J¸[ÕIr   )r   r   )Ú )Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__r   Ú__annotations__r   r   ÚbytesÚstrr   r   r"   r(   Ú__static_attributes__Ú__classcell__)r   s   @r   r	   r	      s`   ø‡ Ø#Ó#Ø%Ó%ð&Ð#7÷ &ð 02ñ
Øð
Ø),ð
Ø<CÀCÈÀHÑ<Mð
à	õ
ò÷
Jð Jr   r	   N)
Úconcurrent.futuresr   Útypingr   Ú?google.cloud.pubsublite.cloudpubsub.internal.managed_event_loopr   Ú=google.cloud.pubsublite.cloudpubsub.internal.single_publisherr   r   r	   r   r   r   Ú<module>r;      s%   ðõ &Ý õ÷ôJ˜/õ Jr   