U ª€ljƒ ã@sˆUdZddlmZmZddlmZmZmZmZm Z ddl m Z m Z e dƒZ e dƒZe dƒZe ee e dœd d „Zee gefee ee d œd d „Zee eeedœdd„Zee egefeee gefdœdd„Zeegefee gefee gefdœdd„Zee jeeeƒe dƒƒƒZeee ge dfed<ee gefegee fe dœdd„Zeege fege fdœdd„ZdS)z1 General functional-style helpers for disttrial. é)ÚpartialÚwraps)Ú AwaitableÚCallableÚIterableÚOptionalÚTypeVar)ÚDeferredÚsucceedÚ_AÚ_BÚ_C)ÚdefaultÚoptionalÚreturncCs|dkr |S|S)z Get a definite value from an optional value. @param default: The value to return if the optional value is missing. @param optional: The optional value to return if it exists. N©)rrrrúB/tmp/pip-unpacked-wheel-aghyhbke/twisted/trial/_dist/functional.pyÚ fromOptionalsr)Ú conditionÚxsrccs"|D]}||ƒr|VqqqdS)z† @return: An iterable over C{xs} that stops when C{condition} returns ``False`` based on the value of iterated C{xs}. Nr)rrÚxrrrÚ takeWhilesr)ÚaÚbrcÃs|IdH|IdHS)z³ Wait for one action to complete and then another. If either action fails, failure is propagated. If the first action fails, the second action is not waited on. Nr)rrrrrÚsequence+s r)Úfrcstˆƒ‡fdd„ƒ}|S)zc Create a function like another but with the order of the first two arguments flipped. cs ˆ||ƒS©Nr)rr©rrrÚg<szflip..g©r©rrrrrÚflip6sr!)ÚfxÚfyrcs"tˆƒtˆƒ‡‡fdd„ƒƒ}|S)z‰ Create a function that calls one function with an argument and then another function with the result of the first function. cs ˆˆ|ƒƒSrr)r©r"r#rrrIszcompose..gr)r"r#rrr$rÚcomposeCsr%NÚ discardResult)Ú predicateÚactionrcÃs|ƒIdH}||ƒs|SqdS)zò Call a function repeatedly until its result fails to satisfy a predicate. @param predicate: The check to apply. @param action: The function to call. @return: The result of C{action} which did not satisfy C{predicate}. Nr)r'r(ÚresultrrrÚ iterateWhileXs r*csd‰tdœ‡‡fdd„ }|S)z’ Wrap a function with another that automatically passes an integer counter of the number of calls that have gone through the wrapper. r)rcsz ˆˆƒ}W5ˆd7‰X|S)Nér)r)©Úcounterrrrrrs  zcountingCalls..g)r r rr,rÚ countingCallsksr.)Ú__doc__Ú functoolsrrÚtypingrrrrrZtwisted.internet.deferr r r r r rÚboolrrr!r%Z fromCoroutiner&Ú__annotations__r*Úintr.rrrrÚs( $  ( 0þ ý