txaio.aio

Attributes

add_callbacks
as_future
call_later
cancel
config
create_failure
create_future
create_future_error
create_future_success
failure_format_traceback
failure_message
failure_traceback
gather
is_called
is_future
make_batched_timer
perf_counter_ns
reject
resolve
sleep
sleep
time_ns
using_asyncio
using_twisted

Classes

AsyncGeneratorType
FailedFuture	This provides an object with any features from Twisted's Failure

Functions

add_log_categories(categories)
get_global_log_level()
make_logger()
set_global_log_level(level)	Set the global log level on all loggers instantiated by txaio.
start_logging([out, level])	Begin logging.
with_config([loop])

Module Contents

class AsyncGeneratorType

class FailedFuture(type_, value, traceback)

Bases: txaio.interfaces.IFailedFuture

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.

property value

An actual Exception instance. Same as the second item returned from sys.exc_info()

add_callbacks

add_log_categories(categories)

as_future

call_later

cancel

config

create_failure

create_future

create_future_error

create_future_success

failure_format_traceback

failure_message

failure_traceback

gather

get_global_log_level()

is_called

is_future

make_batched_timer

make_logger()

perf_counter_ns

reject

resolve

set_global_log_level(level)

Set the global log level on all loggers instantiated by txaio.

sleep

sleep

start_logging(out=_stdout, level='info')

Begin logging.

Parameters:

• out – if provided, a file-like object to log to. By default, this is stdout.

• level – the maximum log-level to emit (a string)

time_ns

using_asyncio = True

using_twisted = False

with_config(loop=None)

Returns:

an instance of the txaio API with the given configuration. This won’t affect anything using the ‘gloabl’ config nor other instances created using this function.

If you need to customize txaio configuration separately (e.g. to use multiple event-loops in asyncio), you can take code like this:

import txaio

class FunTimes(object):

def something_async(self):

return txaio.call_later(1, lambda: ‘some result’)

and instead do this:

import txaio

class FunTimes(object):

txaio = txaio

def something_async(self):

# this will run in the local/new event loop created in the constructor return self.txaio.call_later(1, lambda: ‘some result’)

fun0 = FunTimes() fun1 = FunTimes() fun1.txaio = txaio.with_config(loop=asyncio.new_event_loop())

So fun1 will run its futures on the newly-created event loop, while fun0 will work just as it did before this with_config method was introduced (after 2.6.2).