__init__(self, topics={}) | flexbe_core.proxy.proxy_subscriber_cached.ProxySubscriberCached | |
_callback(self, msg, topic) | flexbe_core.proxy.proxy_subscriber_cached.ProxySubscriberCached | private |
_persistant_topics | flexbe_core.proxy.proxy_subscriber_cached.ProxySubscriberCached | privatestatic |
_topics | flexbe_core.proxy.proxy_subscriber_cached.ProxySubscriberCached | privatestatic |
disable_buffer(self, topic) | flexbe_core.proxy.proxy_subscriber_cached.ProxySubscriberCached | |
enable_buffer(self, topic) | flexbe_core.proxy.proxy_subscriber_cached.ProxySubscriberCached | |
get_from_buffer(self, topic) | flexbe_core.proxy.proxy_subscriber_cached.ProxySubscriberCached | |
get_last_msg(self, topic) | flexbe_core.proxy.proxy_subscriber_cached.ProxySubscriberCached | |
has_buffered(self, topic) | flexbe_core.proxy.proxy_subscriber_cached.ProxySubscriberCached | |
has_msg(self, topic) | flexbe_core.proxy.proxy_subscriber_cached.ProxySubscriberCached | |
has_topic(self, topic) | flexbe_core.proxy.proxy_subscriber_cached.ProxySubscriberCached | |
is_available(self, topic) | flexbe_core.proxy.proxy_subscriber_cached.ProxySubscriberCached | |
make_persistant(self, topic) | flexbe_core.proxy.proxy_subscriber_cached.ProxySubscriberCached | |
remove_last_msg(self, topic, clear_buffer=False) | flexbe_core.proxy.proxy_subscriber_cached.ProxySubscriberCached | |
set_callback(self, topic, callback) | flexbe_core.proxy.proxy_subscriber_cached.ProxySubscriberCached | |
shutdown(self) | flexbe_core.proxy.proxy_subscriber_cached.ProxySubscriberCached | |
subscribe(self, topic, msg_type, callback=None, buffered=False) | flexbe_core.proxy.proxy_subscriber_cached.ProxySubscriberCached | |
unsubscribe_topic(self, topic) | flexbe_core.proxy.proxy_subscriber_cached.ProxySubscriberCached | |