Class Worker

source code

Base class Worker.

Instance Methods

[hide private]

__init__(self, handler)
Initializer.

source code

_set_task(self, task)
Bind worker to task.

source code

_task_bound_check(self)

source code

_engine_clients(self)
Return a list of underlying engine clients.

source code

_invoke(self, ev_type)
Invoke user EventHandler method if needed.

source code

last_read(self)
Get last read message from event handler.

source code

last_error(self)
Get last error message from event handler.

source code

did_timeout(self)
Return True if this worker aborted due to timeout.

source code

flush_buffers(self)
Flush any messages associated to this worker.

source code

flush_errors(self)
Flush any error messages associated to this worker.

source code

Inherited from object: __delattr__, __format__, __getattribute__, __hash__, __new__, __reduce__, __reduce_ex__, __repr__, __setattr__, __sizeof__, __str__, __subclasshook__

Properties

[hide private]

Inherited from object: __class__

Method Details

[hide private]

init(self, handler)
(Constructor)

source code

Initializer. Should be called from derived classes.

Overrides: object.__init__

_set_task(self, task)

source code

Bind worker to task. Called by task.schedule()

Class Worker

__init__(self, handler) (Constructor)

_set_task(self, task)

init(self, handler)
(Constructor)