Package afx :: Module pubsub

[frames] | no frames]

Module pubsub

source code

Classes

[hide private]

publisher
Publish-subscribe mechanism.

condvar
Condition variable.

bool
A bool on which threads can wait for notifications about changes in state.

wfq
I'm a simple prioritized fair queue.

fq
I'm a simple round-robin fair queue.

cell
Holds a single value, and replaces it on each put.

socket_unpickler
Pickle objects directly to a socket stream.

socket_line_reader
A line-reading interface to socket streams.

Functions

[hide private]

deplete_iter(ch)
Generator that yields elements in the channel until it is empty.

source code

deplete(ch)
Return a list of all the remaining elements in the channel until it is empty.

source code

size(ch)
Get the size of a channel.

source code

remaining(ch)
Get the remaining capacity of the channel.

source code

get_all(ch)
I will return all items from this channel, blocking until I have at least one item to return.

source code

is_disp(proc)

source code

is_task(proc)

source code

tag(task, attach)

source code

read_pickle(read, init='', length_thresh=100000)

source code

get_traceback()

source code

get_tb_string()

source code

Variables

[hide private]

stop = 'stop'

Function Details

[hide private]

get_all(ch)

source code

I will return all items from this channel, blocking until I have at least one item to return.

Decorators:

@af.task

tag(task, attach)

source code

Decorators:

@af.task

read_pickle(read, init='', length_thresh=100000)

source code

Decorators:

@af.task

get_traceback()

source code

Decorators:

@af.task

get_tb_string()

source code

Decorators:

@af.task