ó
    €Ïà  ã                   óN   • S SK JrJr  S SKJr  S SKJr  S SKJr   " S S\5      r	g)é    )ÚABCÚabstractmethod)ÚCallable)ÚPubsubMessage)ÚSequencedMessagec                   óX   • \ rS rSrSr\S\S\4S j5       r\	S\
\/\4   4S j5       rSrg	)
ÚMessageTransformeré   zU
A MessageTransformer turns Pub/Sub Lite message protos into Pub/Sub message protos.
ÚsourceÚreturnc                 ó   • g)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Ú	transformÚMessageTransformer.transform   s   € ð 	ó    Útransformerc                 ó6   ^ •  " U 4S jS[         5      nU" 5       $ )Nc                   ó.   >• \ rS rSrS\S\4U 4S jjrSrg)Ú;MessageTransformer.of_callable.<locals>.CallableTransformeré*   r   r   c                 ó   >• T" U5      $ )Nr   )r   r   r   s     €r   r   ÚEMessageTransformer.of_callable.<locals>.CallableTransformer.transform+   s   ø€ Ù" 6Ó*Ð*r   r   N)Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__r   r   r   Ú__static_attributes__)r   s   €r   ÚCallableTransformerr   *   s   ø† ð+Ð(8ð +¸]÷ +ò +r   r    )r	   )r   r    s   ` r   Úof_callableÚMessageTransformer.of_callable(   s   ø€ ÷	+Ô"4ô 	+ñ #Ó$Ð$r   r   N)r   r   r   r   Ú__doc__r   r   r   r   Ústaticmethodr   r!   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   