k7i SSKJr SSKJr SSKJrJrJrJr "SS5r "SS5r "SS 5r "S S \ 5r S \4S jrg))contextmanager)count) HeaderFieldsMessage MessageFlag MessageTypec \rSrSrSrSrSrg)MessageFiltersc00Ul[5UlgN)filtersr filter_idsselfs K/home/james-whalen/.local/lib/python3.13/site-packages/jeepney/io/common.py__init__MessageFilters.__init__s 'c## URR5H)nURRU5(dM%Uv M+ g7fr )rvaluesrulematches)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%s6$636cURRR[RS5nX R ;aUR UR U5 gg)zoDispatch an incoming message which may be a reply Returns True if a task was waiting for it, otherwise False. TF)headerfieldsgetr reply_serialr= set_result)rmsg rep_serials rdispatchReplyMatcher.dispatch3sM ZZ&&**<+D+DbI  & MM* % 0 0 5rNexccUc [S5nUR0so lUR5HnURU5 M g)z4Throw an error in any task still waiting for a replyNz(D-Bus router closed before reply arrived) RouterClosedr=r set_exception)rrOfuturesfuts rdrop_allReplyMatcher.drop_all?sA ;IJC!%>>#C   c "$rr<r ) rrrr rrrBrM ExceptionrUr!r"rrr9r9%s1&& #I##rr9c\rSrSrSrSrg)rQHzRaised 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. r"N)rrrr __doc__r!r"rrrQrQHs   rrQrKcURR[R:wa#[ SURRS35e[ R URR-(a [S5eg)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) rF message_typer method_call TypeErrorrno_reply_expectedflags ValueError)rKs rcheck_replyablercRsl zz+"9"99 # 7 78;< <$$szz'7'77JKK8rN) contextlibr itertoolsrjeepneyrrrrr r$r9rWrQrcr"rrrgsJ%CC( # #F 9 LLr