ó
    €Ï  ã                   óL   • S SK JrJr  S SKJr  S SKJr  S SKJr   " S S\\S9r	g)	é    )ÚabstractmethodÚABCMeta)ÚAsyncContextManager)ÚPubSubMessage)ÚMessageMetadatac                   ó4   • \ rS rSrSr\S\S\4S j5       rSr	g)Ú	Publisheré   z6
A Pub/Sub Lite asynchronous wire protocol publisher.
ÚmessageÚreturnc              ƒ   ó   #   • [        5       e7f)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ÚpublishÚPublisher.publish   s   é € ô "Ó#Ð#ùs   ‚© N)
Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__Ú__doc__r   r   r   r   Ú__static_attributes__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   