xjUdZddlmZddlmZddlmZddlmZddl m Z m Z m Z m Z mZmZmZmZgdZdZ ed Gd d Zed Gd dZed GddZed GddZeezezezZ ddZeeedZded<ehedZded< ddZddZy) zTyped event vocabulary for `subscriptions/listen` (2026-07-28, SEP-2575), shared by server and client. Every event is a level trigger ("this changed, refetch if you care"), so both sides bound buffers by dedupe. ) annotations)Mapping) dataclass)Any)NotificationParamsPromptListChangedNotificationResourceListChangedNotificationResourceUpdatedNotification!ResourceUpdatedNotificationParamsServerNotificationSubscriptionFilterToolListChangedNotification) LISTEN_STREAM_METHODSSUBSCRIPTION_ID_META_KEYPromptsListChangedResourceUpdatedResourcesListChanged ServerEventToolsListChangedevent_from_wire event_matchesevent_to_notificationz&io.modelcontextprotocol/subscriptionIdT)frozenceZdZdZy)rzThe server's tool list changed.N__name__ __module__ __qualname____doc__l/mnt/ssd/data/Dropbox/adrian/sandbox/mcp-query/venv/lib/python3.12/site-packages/mcp/shared/subscriptions.pyrr(s)r!rceZdZdZy)rz!The server's prompt list changed.Nrr r!r"rr-s+r!rceZdZdZy)rz#The server's resource list changed.Nrr r!r"rr2s-r!rceZdZUdZded<y)rz  22|  ' c3 "s+ + r!ct|tr|jduSt|tr|jduSt|t r|j duS|j|vS)zWhether `event` is within the stream's honored filter (`uris`: the honored resource subscriptions as a set). The admission predicate both sides share: server delivery and client intake honor only what was acknowledged.T)r,rtools_list_changedrprompts_list_changedrresources_list_changedr')honoredurisr-s r"rresg%)*))T11%+,++t33%-.--55 99 r!N)r-rr.zdict[str, Any]returnr )r4r&r+zMapping[str, Any] | Noner;zServerEvent | None)r9r r:r1r-rr;bool) r __future__rcollections.abcr dataclassesrtypingr mcp_typesrrr r r r r r__all__rrrrrrrr/r( frozensetrrrr r!r"rDs& ##!    Dr $*** $,,, $... $   !336JJ_\ El)9(:*<*>,@,B0, )22l4H2lJk2l(m~mI  r!