$search
Public Member Functions | |
def | __init__ |
def | get |
def | listen |
def | set_discard |
def | stop_listen |
Public Attributes | |
discard | |
put | |
Private Member Functions | |
def | _put |
def | _trigger |
Private Attributes | |
_invoke_listener | |
_queue |
Event stream class to be used with select and switch.
Definition at line 51 of file async_helpers.py.
def multi_interface_roam::async_helpers::EventStream::__init__ | ( | self, | ||
event = None | ||||
) |
Reimplemented in multi_interface_roam::async_helpers::EventStreamFromDeferred, and multi_interface_roam::async_helpers::Timeout.
Definition at line 53 of file async_helpers.py.
def multi_interface_roam::async_helpers::EventStream::_put | ( | args, | ||
kwargs | ||||
) | [private] |
Puts an element into the queue, and notifies an eventual listener. Use pop rather than _pop or you will create cycles and prevent reference counts from going to zero.
Definition at line 61 of file async_helpers.py.
def multi_interface_roam::async_helpers::EventStream::_trigger | ( | self | ) | [private] |
Used internally to to trigger the callback.
Definition at line 76 of file async_helpers.py.
def multi_interface_roam::async_helpers::EventStream::get | ( | self | ) |
Pops the next element off the queue.
Definition at line 72 of file async_helpers.py.
def multi_interface_roam::async_helpers::EventStream::listen | ( | self | ) |
Returns a Deferred that will be called the next time an event arrives, possibly immediately.
Definition at line 81 of file async_helpers.py.
def multi_interface_roam::async_helpers::EventStream::set_discard | ( | self, | ||
discard | ||||
) |
Tells the event stream whether it should discard all queued and incoming events.
Definition at line 96 of file async_helpers.py.
def multi_interface_roam::async_helpers::EventStream::stop_listen | ( | self | ) |
Discards the Deferred set by listen.
Definition at line 91 of file async_helpers.py.
Definition at line 55 of file async_helpers.py.
Definition at line 54 of file async_helpers.py.
Definition at line 57 of file async_helpers.py.
Definition at line 56 of file async_helpers.py.