+ >a ^RIHt^RIHt^RIHtHtHtHt!RR4t !RR4t !RR 4t !R R ] 4t R R ltR#))contextmanager)count) HeaderFieldsMessage MessageFlag MessageTypec,a]tRt^toRtRtRtVtR#)MessageFiltersc2/Vn\4VnR#N)filtersr filter_idsselfs&1lib/python3.14/site-packages/jeepney/io/common.py__init__MessageFilters.__init__s 'c#"VPP4F*pVPPV4'gK&VxK, R#5ir )r valuesrulematches)rmessagehandles&& rrMessageFilters.matches s6ll))+F{{""7++ ,s Context manager to capture a reply for the given serial numberNr@)rserialfutures&&&rcatchReplyMatcher.catch)s5!' f &L f% f%s7%747c VPPP\PR4pW P 9d%VP V,P V4R#R#)zoDispatch an incoming message which may be a reply Returns True if a task was waiting for it, otherwise False. TF)headerfieldsgetr reply_serialrA set_result)rmsg rep_serials&& rdispatchReplyMatcher.dispatch3sM ZZ&&**<+D+DbI  & MM* % 0 0 5rNc <V^8dQhRS[/#)r'exc) Exception)r(r#s"rr)ReplyMatcher.__annotate__?s##I#rc Vf \R4pVP/uq nVP4FpVPV4K R#)z4Throw an error in any task still waiting for a replyNz(D-Bus router closed before reply arrived) RouterClosedrAr set_exception)rrTfuturesfuts&& rdrop_allReplyMatcher.drop_all?sA ;IJC!%>>#C   c "$rr@r ) rrrrrrrFrQr\r r!r"s@rr>r>%s2&& ###rr>c]tRt^HtRtRtR#)rXzRaised in tasks waiting for a reply when the router is closed This will also be raised if the receiver task crashes, so tasks are not stuck waiting for a reply that can never come. The router object will not be usable after this is raised. N)rrrr__doc__r r_rrrXrXHs   rrXc$V^8dQhR\/#)r'rO)r)r(s"rr)r)RsLLLrcVPP\P8wd$\ RVPP R24h\ P VPP,'d \R4hR#)z4Raise an error if we wouldn't expect a reply for msgz,Only method call messages have replies (not )z/This message has the no_reply_expected flag setN) rJ message_typer method_call TypeErrorrno_reply_expectedflags ValueError)rOs&rcheck_replyablerjRso zz+"9"99 # 7 78;< <$$szz'7'777JKK8rN) contextlibr itertoolsrjeepneyrrrrr r%r>rUrXrjr_rrrnsB%CC( # #F 9 Lr