Ѯh UgdZddlmZmZddlmZddlmZmZm Z m Z ddl m Z m Z mZddlmZmZe dZedZed e Zee eeefeefZe ed <eeefZe ed <ed eeefZdeeefdeeeffdZdeddfdZdeeefdefdZdeeefdefdZdeeeeeffdeeeffdZdeeeeeffdeeeeffdZdeee eeeffdeeeeefffdZy))AnyFlowFlow async_flowflow flow_exprrun_async_flow run_sync_flow sync_flow) Awaitable Generator)wraps)AnyCallableUnioncast) ParamSpec TypeAliasTypeVar) await_if_corois_coroPTArgR)defaultrrTFlow)boundfuncreturnc|SN)rs i/home/www/academy-backend.kofcorporation.com/venv/lib/python3.12/site-packages/fastapi_pagination/flow.pyrr#s KobjNc8t|rtd|dy)Nz Coroutine z is not allowed in sync flow)r TypeError)r$s r"_check_not_coror''s#s|*SE)EFGGr#genc: |jd}t| |j|}t|#t$rt$r}|j |}Yd}~)d}~wwxYw#t$r$}t t |jcYd}~Sd}~wwxYwr )sendr' StopIteration BaseExceptionthrowrrvaluer(resexcs r"rr,s "hhtn %hhsm$!   %iin % "Asyy!!"sCA-=A-A*A% A-%A**A-- B6BBBc@K |jd} t|d{}|j|}&7#t$rt$r}|j |}Yd}~+d}~wwxYw#t$r$}t t |jcYd}~Sd}~wwxYwwr )r*rr+r,r-rrr.r/s r"rr=s "hhtn %)#..hhsm.    %iin % "Asyy!!"s`BA.><>A.>A+A&!A.&A++A.. B7BBBBBc|tdtjdtjdtffd }|S)Nargskwargsrc&t|i|Sr )rr4r5rs r"wrapperzsync_flow..wrapperNsT426233r#r rr4r5rrr8s` r"r r Ms= 4[4qvv44a44 Nr#c|tdtjdtjdtffd }|S)Nr4r5rcBKt|i|d{S7wr )rr7s r"r8zasync_flow..wrapperVs"#D$$9&$9::::s r9r:s` r"rrUs= 4[;QVV;qxx;A;; Nr#exprc tdtjdtjdtt t fffd }|S)Nr4r5rc?@K|i|}tt|Swr )rr)r4r5r0r=s r" flow_wrapperzflow_expr..flow_wrapper^s%$)&))As|s)r rr4r5rrr)r=r@s` r"rr]sF 4[AFFahh4Q< r#) __all__collections.abcr r functoolsr typingrrrrtyping_extensionsrrrfastapi_pagination.utilsrrrrrr__annotations__rrrr'rrr rrr!r#r"rHs  1--;;; cNv C )D/4  i #q&\!tCH~.x5!hq%x&8HHH "tCF|"1"" "d36l "! " HQS!V _-(1a4.Xac1fo.8Ay|O3LHQilAo 667HQSRSV _