"jjSSKJr SSKrSSKJrJr SSKJr SSKJ r SSK J r J r J r JrJr SSKJr SSKJr SS KJr \"S 5r\"S \S 9r\"S \SS9r\\\\ \/\S4r"SS\ \5r"SS\ \\45r\SSj5r\SSj5rSSjr\SSj5rSSjrg)) annotationsN) AwaitableCallable) lru_cache) MethodType)AnyGenericProtocolTypeVaroverload UserError)AgentStreamEvent) RunContext CapabilityTEventT)bound BoundEventTT)r contravariantc\rSrSrSSjrSrg)_BoundEventMethodcgN)selfctxevents _/home/mande/repo/quber/.venv/lib/python3.13/site-packages/pydantic_ai/capabilities/_on_event.py__call___BoundEventMethod.__call__sUXrN)rzRunContext[Any]rrreturnzAwaitable[None])__name__ __module__ __qualname____firstlineno__r __static_attributes__rr"rrrsXr"rcj\rSrSrSrS SjrS Sjr\S Sj5r\S Sj5rSSjrSr g )_OnEventMethodzFDescriptor created by [`on_event`][pydantic_ai.capabilities.on_event].cXlX lgrfunc event_types)rr.r/s r__init___OnEventMethod.__init__s  &r"c&US:Xa [S5eg)Non_eventz`@on_event` cannot decorate a method named 'on_event': that name is the dispatcher that invokes the marked listeners. Rename the method, e.g. `_on_event`.r )rownernames r __set_name___OnEventMethod.__set_name__s" : U  r"cgrrrinstancer4s r__get___OnEventMethod.__get__&shkr"cgrrr9s rr;r<)sehr"c8UcU$[URU5$r)rr.r9s rr;r<,s   K$))X..r")r/r.N)r.!_EventMethod[CapabilityT, EventT]r/ztuple[type[EventT], ...])r4 type[Any]r5strr#None)r:rBr4type[CapabilityT]r##_OnEventMethod[CapabilityT, EventT])r:rr4rCr#z_BoundEventMethod[EventT])r:zCapabilityT | Noner4rCr#z?_OnEventMethod[CapabilityT, EventT] | _BoundEventMethod[EventT]) r$r%r&r'__doc__r0r6r r;r(rr"rr*r*sJP'kk hh/*/3D/ H/r"r*cgrr)r.s rr3r34suxr"cgrr)r/s rr3r38s Z]r"c^[T5S:Xa,[R"TS=n5(a [US5$SU4SjjnU$)auMark an async capability method as an event listener. Pass event classes to filter with `isinstance`, or use the decorator bare to receive every [`AgentStreamEvent`][pydantic_ai.messages.AgentStreamEvent]. Naming the classes is also what lets dispatch skip the capability entirely for events it doesn't listen to, so prefer it over a bare marker when you know the types. rrc>[UT5$r)r*r-s r decoratoron_event..decoratorOsdK00r")r.r?r#rD)leninspect isfunctionr*)r/r.rKs` rr3r3>sE ;1!3!3KN4JD!K!KdB''1 r"c0n[UR5HJnURR5H)up4[ U[ 5(aXAU'M X1;dM'X M+ ML [ UR55$)zHCollect marked methods in definition order, including inherited methods.)reversed__mro____dict__items isinstancer*tuplevalues)clsmethodsbaser5values rcollect_on_event_methodsr\Usg46G%==..0KD%00 % M 1& ! ""r"c@^[U4Sj[U555$)zDWhether any method on `cls` marked with `@on_event` accepts `event`.c3~># UH2oR(+=(d [TUR5v M4 g7fr)r/rU).0methodrs r $marked_listens_to..ds1VsF  G*UF4F4F"GGVss:=)anyr\)rXrs `rmarked_listens_tordbs# VnorVs r")r.z+_EventMethod[CapabilityT, AgentStreamEvent]r#z-_OnEventMethod[CapabilityT, AgentStreamEvent])r/z type[EventT]r#zRCallable[[_EventMethod[CapabilityT, EventT]], _OnEventMethod[CapabilityT, EventT]])r/rr#z_OnEventMethod[CapabilityT, AgentStreamEvent] | Callable[[_EventMethod[CapabilityT, EventT]], _OnEventMethod[CapabilityT, EventT]])rXr@r#z$tuple[_OnEventMethod[Any, Any], ...])rXr@rrr#bool) __future__rrNcollections.abcrr functoolsrtypesrtypingrr r r r pydantic_ai.exceptionsrpydantic_ai.messagesrpydantic_ai.toolsrrrr _EventMethodrr*r3r\rdrr"rros"/<<,1(m$ !1 2m+;4P jov> $OP Y-Y/W[&01/8 x x ]]W] ] Y.  #  #r"