Module ImportFrom alias alias Import alias Import alias Import alias Import alias Import alias Import alias Import alias ImportFrom alias ImportFrom alias alias alias ImportFrom alias ImportFrom alias ImportFrom alias Import alias TryExcept body Import alias ImportFrom alias ImportFrom alias handlers ExceptHandler type NameLoad body Import alias identifier ImportFrom alias ImportFrom alias Assign NameStore Call NameLoad Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr Assign TupleStore NameStore NameStore TupleLoad AttributeLoad NameLoad attr AttributeLoad NameLoad attr Assign NameStore Call AttributeLoad NameLoad attr Assign NameStore Str Assign NameStore NameLoad Assign NameStore Dict Assign NameStore NameLoad Assign NameStore NameLoad FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad NameLoad attr NameLoad decorator_list ClassDef bases NameLoad body Expr Str FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Expr Str Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Return AttributeLoad NameLoad attr decorator_list NameLoad FunctionDef arguments args NameParam defaults body Return Call NameLoad AttributeLoad NameLoad attr decorator_list decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults Str kwarg body If BoolOpAnd CompareIn Str NameLoad CompareIn SubscriptLoad NameLoad Index Str NameLoad body Assign NameStore Call AttributeLoad NameLoad attr SubscriptLoad NameLoad Index Str Assign SubscriptStore NameLoad Index Str Call AttributeLoad NameLoad attr Assign SubscriptStore NameLoad Index Str NameLoad Assign SubscriptStore NameLoad Index Str NameLoad If CompareEq NameLoad Str body Assign NameStore Str Assign SubscriptStore NameLoad Index Str NameLoad Assign NameStore Call AttributeLoad NameLoad attr NameLoad Expr Call Call NameLoad AttributeLoad NameLoad attr NameLoad NameLoad decorator_list FunctionDef arguments args defaults vararg kwarg body Pass decorator_list ClassDef bases NameLoad body FunctionDef arguments args NameParam NameParam defaults body Assign AttributeStore NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults vararg kwarg body Assign NameStore Call NameLoad NameLoad NameLoad Return Call NameLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Assign NameStore Call AttributeLoad NameLoad attr NameLoad For TupleStore NameStore NameStore Call NameLoad NameLoad body If CompareLtE NameLoad NameLoad body Assign NameStore Call AttributeLoad NameLoad attr NameLoad NameLoad NameLoad orelse Assign NameStore NameLoad Expr Call NameLoad NameLoad NameLoad NameLoad Assign AttributeStore NameLoad attr NameLoad decorator_list decorator_list ClassDef bases AttributeLoad NameLoad attr NameLoad body FunctionDef arguments args NameParam NameParam defaults kwarg body Expr Call AttributeLoad Call NameLoad NameLoad NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr Call NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body If Call NameLoad AttributeLoad NameLoad attr NameLoad body Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr Str Call AttributeLoad AttributeLoad NameLoad attr attr Str Str Assign NameStore Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr Assign NameStore Call AttributeLoad NameLoad attr Call AttributeLoad AttributeLoad NameLoad attr attr Str Num orelse Assign NameStore Call AttributeLoad NameLoad attr Assign NameStore Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr Assign NameStore Call AttributeLoad Str attr Call AttributeLoad NameLoad attr Str NameLoad AttributeLoad NameLoad attr If AttributeLoad NameLoad attr body Assign NameStore Call AttributeLoad NameLoad attr Str Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad decorator_list decorator_list FunctionDef arguments args defaults body Assign NameStore Call NameLoad Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr NameLoad Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults NameLoad Str body Expr Str Global identifier identifier identifier If CompareNotIn NameLoad NameLoad body Raise Call NameLoad Call AttributeLoad Str attr NameLoad Call AttributeLoad Str attr NameLoad If NameLoad body Return Assign NameStore NameLoad Assign NameStore NameLoad Assign NameStore Call NameLoad NameLoad Expr Call AttributeLoad Call AttributeLoad NameLoad attr attr NameLoad Assign AttributeStore NameLoad attr NameLoad Assign NameStore Dict Str Str Str Str Str Str AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr Expr Call AttributeLoad Call AttributeLoad NameLoad attr attr SubscriptLoad NameLoad Index NameLoad For NameStore NameLoad body Expr Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str TryExcept body Return Call AttributeLoad Str attr AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr Call NameLoad AttributeLoad NameLoad attr handlers ExceptHandler type NameLoad body Return Call AttributeLoad Str attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str Return AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Expr Str TryExcept body Assign NameStore Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr keyword NameLoad Return Call AttributeLoad NameLoad attr handlers ExceptHandler type NameLoad body Return Call AttributeLoad Str attr NameLoad decorator_list Assign NameStore Call NameLoad FunctionDef arguments args NameParam NameParam defaults NameLoad NameLoad body If BoolOpAnd CompareIsNot NameLoad NameLoad CompareIsNot NameLoad NameLoad body Raise Call NameLoad Str Assign NameStore Call NameLoad keyword AttributeLoad NameLoad attr If CompareIsNot NameLoad NameLoad body Expr Call NameLoad NameLoad NameLoad orelse If CompareIsNot NameLoad NameLoad body Expr Call NameLoad NameLoad NameLoad Return NameLoad decorator_list FunctionDef arguments args NameParam defaults body Return Call NameLoad keyword NameLoad decorator_list FunctionDef arguments args NameParam defaults NameLoad body Assign NameStore Call NameLoad Expr Call NameLoad NameLoad NameLoad Return NameLoad decorator_list FunctionDef arguments args NameParam defaults vararg kwarg body TryExcept body Assign NameStore Call NameLoad NameLoad NameLoad handlers ExceptHandler type NameLoad body Return Call NameLoad Call NameLoad orelse If Call NameLoad NameLoad NameLoad body Return NameLoad orelse If Call NameLoad NameLoad body Return Call AttributeLoad NameLoad attr NameLoad keyword AttributeLoad NameLoad attr orelse Return Call NameLoad NameLoad decorator_list FunctionDef arguments args NameParam defaults body Return BoolOpOr Call NameLoad NameLoad Call NameLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults vararg kwarg body Assign NameStore Call AttributeLoad NameLoad attr NameLoad NameLoad NameLoad Return Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults Num body Expr Str Assign NameStore AttributeLoad AttributeLoad NameLoad attr attr Return Call NameLoad BinOpMult NameLoad Num NameLoad keyword NameLoad keyword NameLoad decorator_list FunctionDef arguments args NameParam defaults body Return Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam defaults NameLoad body Expr Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults NameLoad body If CompareIs NameLoad NameLoad body Assign NameStore Call NameLoad orelse If Call NameLoad NameLoad NameLoad body Assign NameStore Call NameLoad Call NameLoad NameLoad NameLoad NameLoad orelse If UnaryOpNot Call NameLoad NameLoad NameLoad body Raise Call NameLoad Str Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults NameLoad body Expr Str If NameLoad body Return Call NameLoad Call NameLoad NameLoad NameLoad NameLoad Return Call NameLoad Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Str FunctionDef arguments args NameParam defaults body TryExcept body Assign NameStore Call AttributeLoad NameLoad attr If NameLoad body Assign NameStore Call NameLoad NameLoad If CompareIsNot NameLoad NameLoad body Assign AttributeStore NameLoad attr NameLoad handlers ExceptHandler type NameLoad body If NameLoad body Expr Call NameLoad Call NameLoad decorator_list Return Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults NameLoad body Expr Str Return Call AttributeLoad NameLoad attr keyword NameLoad NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str For NameStore NameLoad body Expr Call AttributeLoad NameLoad attr NameLoad Global identifier Assign NameStore NameLoad decorator_list FunctionDef arguments args defaults body Return NameLoad decorator_list
N/A __future__ absolute_import print_function N/A os N/A sys N/A time N/A weakref N/A functools N/A traceback N/A logging datetime datetime txaio.interfaces IFailedFuture ILogger log_levels txaio._iotype guess_stream_needs_encoding txaio._common _BatchedTimer txaio _Config N/A six N/A N/A N/A asyncio asyncio iscoroutine asyncio Future N/A N/A N/A ImportError N/A N/A trollius asyncio trollius iscoroutine trollius Future N/A config N/A _Config N/A N/A config loop N/A N/A asyncio get_event_loop N/A N/A _stderr _stdout N/A N/A sys stderr N/A sys stdout N/A _loggers N/A N/A weakref WeakSet N/A _log_level info N/A _started_logging False N/A _categories N/A N/A using_twisted False N/A using_asyncio True add_log_categories N/A N/A categories N/A N/A N/A N/A N/A _categories update categories N/A FailedFuture N/A IFailedFuture N/A N/A 
    This provides an object with any features from Twisted's Failure
    that we might need in Autobahn classes that use FutureMixin.

    We need to encapsulate information from exceptions so that
    errbacks still have access to the traceback (in case they want to
    print it out) outside of "except" blocks.
     __init__ N/A N/A self type_ value traceback N/A N/A N/A 
        These are the same parameters as returned from ``sys.exc_info()``

        :param type_: exception type
        :param value: the Exception instance
        :param traceback: a traceback object
         N/A N/A self _type type_ N/A N/A self _value value N/A N/A self _traceback traceback N/A value N/A N/A self N/A N/A N/A N/A self _value N/A property __str__ N/A N/A self N/A N/A N/A N/A str N/A self value N/A N/A _log N/A N/A logger level format N/A kwargs N/A N/A N/A N/A log_category kwargs N/A N/A kwargs N/A log_category _categories N/A N/A format N/A N/A _categories get N/A kwargs N/A log_category N/A N/A kwargs N/A log_time N/A N/A time time N/A N/A kwargs N/A log_level level N/A N/A kwargs N/A log_format format N/A N/A level trace N/A N/A level debug N/A N/A kwargs N/A txaio_trace True N/A msg N/A N/A format format kwargs N/A N/A N/A getattr N/A logger _logger level msg N/A _no_op N/A N/A N/A args kw N/A N/A N/A _TxaioLogWrapper N/A ILogger N/A __init__ N/A N/A self logger N/A N/A N/A N/A self _logger logger N/A N/A N/A self _set_log_level _log_level N/A emit N/A N/A self level N/A args kwargs N/A N/A func N/A getattr self level N/A N/A func args kwargs N/A _set_log_level N/A N/A self level N/A N/A N/A target_level N/A N/A log_levels index level N/A N/A idx name N/A enumerate log_levels N/A N/A N/A idx target_level N/A N/A log_method N/A N/A functools partial _log self name N/A N/A log_method _no_op N/A N/A setattr self name log_method N/A N/A self _log_level level N/A N/A _TxaioFileHandler N/A N/A logging Handler object N/A __init__ N/A N/A self fileobj N/A kw N/A N/A N/A N/A N/A super _TxaioFileHandler self __init__ kw N/A N/A self _file fileobj N/A N/A self _encode N/A guess_stream_needs_encoding fileobj N/A emit N/A N/A self record N/A N/A N/A N/A isinstance N/A record args dict N/A N/A fmt N/A N/A N/A record args get log_format N/A N/A N/A record args get log_message N/A message N/A N/A fmt format N/A record args N/A dt N/A N/A datetime fromtimestamp N/A N/A N/A record args get log_time 0 N/A N/A message N/A N/A record getMessage N/A dt N/A N/A datetime fromtimestamp N/A record created N/A msg N/A N/A {0} {1}{2} format N/A N/A dt strftime %Y-%m-%dT%H:%M:%S%z message N/A os linesep N/A N/A self _encode N/A N/A msg N/A N/A msg encode utf8 N/A N/A N/A N/A self _file write msg N/A N/A make_logger N/A N/A N/A N/A N/A logger N/A _TxaioLogWrapper N/A N/A logging getLogger N/A N/A N/A _loggers add logger N/A logger N/A start_logging N/A N/A out level N/A _stdout info N/A N/A 
    Begin logging.

    :param out: if provided, a file-like object to log to. By default, this is
                stdout.
    :param level: the maximum log-level to emit (a string)
     N/A _log_level _loggers _started_logging N/A N/A level log_levels N/A N/A N/A RuntimeError N/A N/A Invalid log level '{0}'; valid are: {1} format level N/A N/A ,  join log_levels N/A _started_logging N/A N/A N/A _started_logging True N/A _log_level level N/A handler N/A _TxaioFileHandler out N/A N/A N/A N/A N/A logging getLogger addHandler handler N/A N/A logging raiseExceptions True N/A level_to_stdlib N/A critical error warn info debug trace N/A logging CRITICAL N/A logging ERROR N/A logging WARNING N/A logging INFO N/A logging DEBUG N/A logging DEBUG N/A N/A N/A N/A N/A logging getLogger setLevel N/A level_to_stdlib N/A level N/A logger _loggers N/A N/A N/A N/A logger _set_log_level level N/A failure_message N/A N/A fail N/A N/A N/A 
    :param fail: must be an IFailedFuture
    returns a unicode error-message
     N/A N/A N/A N/A N/A {0}: {1} format N/A N/A N/A fail _value __class__ __name__ N/A str N/A fail _value N/A N/A N/A Exception N/A N/A N/A N/A Failed to produce failure message for "{0}" format fail N/A failure_traceback N/A N/A fail N/A N/A N/A 
    :param fail: must be an IFailedFuture
    returns a traceback instance
     N/A N/A fail _traceback N/A failure_format_traceback N/A N/A fail N/A N/A N/A 
    :param fail: must be an IFailedFuture
    returns a string
     N/A N/A N/A f N/A N/A six StringIO N/A N/A N/A traceback print_exception N/A fail _type N/A fail value N/A fail _traceback file f N/A N/A N/A f getvalue N/A N/A N/A Exception N/A N/A N/A N/A Failed to format failure traceback for '{0}' format fail N/A N/A _unspecified N/A object create_future N/A N/A result error N/A _unspecified _unspecified N/A N/A N/A N/A result _unspecified N/A error _unspecified N/A N/A N/A ValueError Cannot have both result and error. N/A f N/A Future loop N/A config loop N/A N/A result _unspecified N/A N/A N/A resolve f result N/A N/A N/A error _unspecified N/A N/A N/A reject f error N/A f N/A create_future_success N/A N/A result N/A N/A N/A N/A create_future result result N/A create_future_error N/A N/A error N/A None N/A N/A f N/A create_future N/A N/A reject f error N/A f N/A as_future N/A N/A fun N/A args kwargs N/A N/A N/A N/A res N/A fun args kwargs N/A N/A N/A Exception N/A N/A N/A create_future_error N/A create_failure N/A N/A N/A isinstance res Future N/A N/A res N/A N/A N/A iscoroutine res N/A N/A N/A N/A asyncio Task res loop N/A config loop N/A N/A N/A create_future_success res N/A is_future N/A N/A obj N/A N/A N/A N/A N/A iscoroutine obj N/A isinstance obj Future N/A call_later N/A N/A delay fun N/A args kwargs N/A N/A real_call N/A N/A functools partial fun args kwargs N/A N/A N/A N/A config loop call_later delay real_call N/A make_batched_timer N/A N/A bucket_seconds chunk_size N/A 100 N/A N/A 
    Creates and returns an object implementing
    :class:`txaio.IBatchedTimer`.

    :param bucket_seconds: the number of seconds in each bucket. That
        is, a value of 5 means that any timeout within a 5 second
        window will be in the same bucket, and get notified at the
        same time. This is only accurate to "milliseconds".

    :param chunk_size: when "doing" the callbacks in a particular
        bucket, this controls how many we do at once before yielding to
        the reactor.
     N/A get_seconds N/A N/A config loop time N/A N/A _BatchedTimer N/A bucket_seconds 1000.0 chunk_size seconds_provider get_seconds delayed_call_creator call_later N/A is_called N/A N/A future N/A N/A N/A N/A N/A future done N/A resolve N/A N/A future result N/A None N/A N/A N/A N/A future set_result result N/A reject N/A N/A future error N/A None N/A N/A N/A error None N/A N/A error N/A create_failure N/A N/A N/A isinstance error Exception N/A N/A error N/A FailedFuture N/A type error error None N/A N/A N/A N/A isinstance error IFailedFuture N/A N/A N/A RuntimeError reject requires an IFailedFuture or Exception N/A N/A N/A future set_exception N/A error value N/A create_failure N/A N/A exception N/A None N/A N/A 
    This returns an object implementing IFailedFuture.

    If exception is None (the default) we MUST be called within an
    "except" block (such that sys.exc_info() returns useful
    information).
     N/A exception N/A N/A N/A FailedFuture N/A type exception exception None N/A N/A FailedFuture N/A N/A sys exc_info N/A add_callbacks N/A N/A future callback errback N/A N/A N/A 
    callback or errback may be None, but at least one must be
    non-None.

    XXX beware the "f._result" hack to get "chainable-callback" type
    behavior.
     done N/A N/A f N/A N/A N/A N/A N/A res N/A N/A f result N/A callback N/A N/A x N/A callback res N/A N/A x None N/A N/A N/A f _result x N/A N/A N/A Exception N/A N/A errback N/A N/A N/A errback N/A create_failure N/A N/A N/A N/A future add_done_callback done N/A gather N/A N/A futures consume_exceptions N/A True N/A N/A 
    This returns a Future that waits for all the Futures in the list
    ``futures``

    :param futures: a list of Futures (or coroutines?)

    :param consume_exceptions: if True, any errors are eaten and
    returned in the result list.
     N/A N/A N/A asyncio gather return_exceptions consume_exceptions futures N/A set_global_log_level N/A N/A level N/A N/A N/A 
    Set the global log level on all loggers instantiated by txaio.
     N/A logger _loggers N/A N/A N/A N/A logger _set_log_level level N/A _log_level N/A _log_level level N/A get_global_log_level N/A N/A N/A N/A N/A _log_level N/A