Ë
    €Ï  ã                   óR   — d dl mZmZ d dlmZ d dlmZ d dlmZ  G d„ dee¬«      Z	y)	é    )ÚabstractmethodÚABCMeta)ÚAsyncContextManager)ÚPubSubMessage)ÚMessageMetadatac                   ó*   — e Zd ZdZededefd„«       Zy)Ú	Publisherz>
    A Pub/Sub Lite asynchronous wire protocol publisher.
    ÚmessageÚreturnc              ƒ   ó   K  — t        «       ‚­w)zõ
        Publish the provided message.

        Args:
          message: The message to be published.

        Returns:
          Metadata about the published message.

        Raises:
          GoogleAPICallError: On a permanent error.
        )ÚNotImplementedError)Úselfr
   s     úBlib/third_party/google/cloud/pubsublite/internal/wire/publisher.pyÚpublishzPublisher.publish   s   è ø€ ô "Ó#Ð#ùs   ‚N)Ú__name__Ú
__module__Ú__qualname__Ú__doc__r   r   r   r   © ó    r   r	   r	      s)   „ ñð ð$ ]ð $°ò $ó ñ$r   r	   )Ú	metaclassN)
Úabcr   r   Útypingr   Ú google.cloud.pubsublite_v1.typesr   Úgoogle.cloud.pubsublite.typesr   r	   r   r   r   Ú<module>r      s"   ð÷ (Ý &Ý :Ý 9ô$Ð#¨wö $r   