+
    ûwÖi  ã                   óþ   € R t ^ RIHtHt ^ RIHt ^ RIHtHt ]	t
]]
.]R,          3,          t]. ]R,          3,          t] ! R R4      4       t] ! R R4      4       t]],          R,          t] ! R	 R
4      4       tR# )z±
Message wrapper with metadata support.

This module defines a wrapper type that combines JSONRPCMessage with metadata
to support transport-specific features like resumability.
)Ú	AwaitableÚCallable)Ú	dataclass)ÚJSONRPCMessageÚ	RequestIdNc                   ó8   a € ] tR t^t o RtRtRtV 3R ltRtV t	R# )ÚClientMessageMetadataz%Metadata specific to client messages.Nc                ót   <€ V ^8„  d   Qh/ S[ R,          ;R&   S[S[ .S[R,          3,          R,          ;R&   # )é   NÚresumption_tokenÚon_resumption_token_update)ÚResumptionTokenr   r   )ÚformatÚ__classdict__s   "€ÚF/home/ubuntu/.local/lib/python3.14/site-packages/mcp/shared/message.pyÚ__annotate__Ú"ClientMessageMetadata.__annotate__   s:   ø‡ ‚ ñ &¨Õ,Ñ3ñ	 ñ
 !)©/Ð):¹IÀd½OÐ)KÕ LÈtÕ SÑZò ó    © )
Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__Ú__doc__r   r   Ú__annotate_func__Ú__static_attributes__Ú__classdictcell__©r   s   @r   r   r      s   ø‡ € á/à/3ÐØVZÐ÷ ƒ r   r   c                   ó@   a € ] tR t^t o RtRtRtRtRtV 3R lt	Rt
V tR# )ÚServerMessageMetadataz%Metadata specific to server messages.Nc                ó‚   <€ V ^8„  d   Qh/ S[ R,          ;R&   S[R,          ;R&   S[R,          ;R&   S[R,          ;R&   # )r
   NÚrelated_request_idÚrequest_contextÚclose_sse_streamÚclose_standalone_sse_stream)r   ÚobjectÚCloseSSEStreamCallback)r   r   s   "€r   r   Ú"ServerMessageMetadata.__annotate__   sL   ø‡ ‚ ñ " DÕ(Ñ/ñ	 ñ ˜d•]Ñ)ñ ñ -¨tÕ3Ñ:ñ ñ "8¸$Õ!>ÑEò r   r   )r   r   r   r   r   r!   r"   r#   r$   r   r   r   r   s   @r   r   r      s&   ø‡ € á/à+/Ðà%)€Oà6:ÐàAEÐ÷ ƒ r   r   c                   ó4   a € ] tR t^-t o RtRtV 3R ltRtV tR# )ÚSessionMessagezAA message with specific metadata for transport-specific features.Nc                ó2   <€ V ^8„  d   Qh/ S[ ;R&   S[;R&   # )r
   ÚmessageÚmetadata)r   ÚMessageMetadata)r   r   s   "€r   r   ÚSessionMessage.__annotate__-   s   ø‡ ‚ ñ Ññ	 ñ
 Ñ$ò r   r   )	r   r   r   r   r   r,   r   r   r   r   s   @r   r)   r)   -   s   ø‡ € áKð !%€H÷ ƒ r   r)   )r   Úcollections.abcr   r   Údataclassesr   Ú	mcp.typesr   r   Ústrr   ÚResumptionTokenUpdateCallbackr&   r   r   r-   r)   r   r   r   Ú<module>r4      sª   ðñ÷ 0Ý !ç /à€à (¨/Ð):¸IÀd½OÐ)KÕ LÐ ð " " i°¥oÐ"5Õ6Ð ð ÷[ð [ó ð[ð ÷	Fð 	Fó ð	Fð (Ð*?Õ?À$ÕF€ð ÷%ð %ó ò%r   