live # l=J4Apbѿ L """ Commonly used hooks for on_setattr. """ from __future__ import absolute_import, division, print_function from . import _config from .exceptions import FrozenAttributeError def pipe(*setters): """ Run all *setters* and return the return value of the last one. .. versionadded:: 20.1.0 """ def wrapped_pipe(instance, attrib, new_value): rv = new_value for setter in setters: rv = setter(instance, attrib, rv) return rv return wrapped_pipe def frozen(_, __, ___): """ Prevent an attribute to be modified. .. versionadded:: 20.1.0 """ raise FrozenAttributeError() def validate(instance, attrib, new_value): """ Run *attrib*'s validator on *new_value* if it has one. .. versionadded:: 20.1.0 """ if _config._run_validators is False: return new_value v = attrib.validator if not v: return new_value v(instance, attrib, new_value) return new_value def convert(instance, attrib, new_value): """ Run *attrib*'s converter -- if it has one -- on *new_value* and return the result. .. versionadded:: 20.1.0 """ c = attrib.converter if c: return c(new_value) return new_value NO_OP = object() """ Sentinel for disabling class-wide *on_setattr* hooks for certain attributes. Does not work in `pipe` or within lists. .. versionadded:: 20.1.0 """ !l=JJj"TٸӪbѿ 0;lY>*e6Aq\e1h _a=JJj"Tٸbѿ? :P7s~dZddlZddlZddlZddlZddlZeedredz ZddlmZddlm Z ddlm Z dd lm Z dd lm Z dd l mZdd lmZd ZdeddZdeddZeedrdeddZdeddZGdde jZGddee jZGddZGddZdS)) StreamReader StreamWriterStreamReaderProtocolopen_connection start_serverNAF_UNIX)open_unix_connectionstart_unix_server) coroutines)events) exceptions)format_helpers) protocols)logger)sleepi)limitc K tj}t||}t|| |j fd||fi|d{V\}}t | ||}||fS)NrlooprcSNprotocolsz!open_connection..1s)r get_running_looprrcreate_connectionr) hostportrkwdsrreader transport_writerrs @rrrs"  " $ $D D 1 1 1F#F666H//$..(,........LIq )Xvt < rcnK tjfd}j|||fi|d{VS)NcNt}t|}|SNrrrrr%rclient_connected_cbrrs rfactoryzstart_server..factoryNs6E555'0C-1333r)r r create_server)r.r"r#rr$r/rs` ` @rrr6st(  " $ $D $#GT4@@4@@ @ @ @ @ @ @@rcK tj}t||}t|||jfd|fi|d{V\}}t |||}||fS)NrrcSrrrsrrz&open_unix_connection..b