Ë
    €Ïà  ã                   óN   — 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«      Z	y)é    )ÚABCÚabstractmethod)ÚCallable)ÚPubsubMessage)ÚSequencedMessagec                   óL   — e Zd ZdZededefd„«       Zede	egef   fd„«       Z
y)ÚMessageTransformerz]
    A MessageTransformer turns Pub/Sub Lite message protos into Pub/Sub message protos.
    ÚsourceÚreturnc                  ó   — y)zÈTransform a SequencedMessage to a PubsubMessage.

        Args:
          source: The message to transform.

        Raises:
          GoogleAPICallError: To fail the client if raised inline.
        N© )Úselfr
   s     úJlib/third_party/google/cloud/pubsublite/cloudpubsub/message_transformer.pyÚ	transformzMessageTransformer.transform   s   € ð 	ó    Útransformerc                 ó4   ‡ —  G ˆ fd„dt         «      } |«       S )Nc                   ó"   •— e Zd Zdedefˆ fd„Zy)ú;MessageTransformer.of_callable.<locals>.CallableTransformerr
   r   c                 ó   •—  ‰|«      S )Nr   )r   r
   r   s     €r   r   zEMessageTransformer.of_callable.<locals>.CallableTransformer.transform+   s   ø€ Ù" 6Ó*Ð*r   N)Ú__name__Ú
__module__Ú__qualname__r   r   r   )r   s   €r   ÚCallableTransformerr   *   s   ø„ ð+Ð(8ð +¸]ö +r   r   )r	   )r   r   s   ` r   Úof_callablezMessageTransformer.of_callable(   s   ø€ ö	+Ô"4ô 	+ñ #Ó$Ð$r   N)r   r   r   Ú__doc__r   r   r   r   Ústaticmethodr   r   r   r   r   r	   r	      sS   „ ñð ð	Ð 0ð 	°]ò 	ó ð	ð ð% Ð+;Ð*<¸mÐ*KÑ!Lò %ó ñ%r   r	   N)
Úabcr   r   Útypingr   Úgoogle.pubsub_v1r   Úgoogle.cloud.pubsublite_v1r   r	   r   r   r   Ú<module>r"      s   ð÷ $Ý å *å 7ô%˜õ %r   