Searched refs:PubSubClient (Results 1 – 10 of 10) sorted by relevance
/external/webrtc/webrtc/libjingle/xmpp/ |
D | pubsubclient.cc | 22 void PubSubClient::RequestItems() { in RequestItems() 25 request_task->SignalResult.connect(this, &PubSubClient::OnRequestResult); in RequestItems() 26 request_task->SignalError.connect(this, &PubSubClient::OnRequestError); in RequestItems() 30 receive_task->SignalUpdate.connect(this, &PubSubClient::OnReceiveUpdate); in RequestItems() 36 void PubSubClient::PublishItem( in PublishItem() 43 void PubSubClient::PublishItem( in PublishItem() 48 publish_task->SignalError.connect(this, &PubSubClient::OnPublishError); in PublishItem() 49 publish_task->SignalResult.connect(this, &PubSubClient::OnPublishResult); in PublishItem() 56 void PubSubClient::RetractItem( in RetractItem() 60 retract_task->SignalError.connect(this, &PubSubClient::OnRetractError); in RetractItem() [all …]
|
D | pubsubclient.h | 36 class PubSubClient : public sigslot::has_slots<> { 38 PubSubClient(XmppTaskParentInterface* parent, in PubSubClient() function 53 sigslot::signal2<PubSubClient*, 56 sigslot::signal2<PubSubClient*, 59 sigslot::signal4<PubSubClient*, 64 sigslot::signal3<PubSubClient*, 68 sigslot::signal3<PubSubClient*, 72 sigslot::signal2<PubSubClient*,
|
D | pubsubclient_unittest.cc | 32 void OnItems(buzz::PubSubClient*, in OnItems() argument 45 void OnRequestError(buzz::PubSubClient* client, in OnRequestError() 50 void OnPublishResult(buzz::PubSubClient* client, in OnPublishResult() 56 void OnPublishError(buzz::PubSubClient* client, in OnPublishError() 64 void OnRetractResult(buzz::PubSubClient* client, in OnRetractResult() 69 void OnRetractError(buzz::PubSubClient* client, in OnRetractError() 90 client.reset(new buzz::PubSubClient(xmpp_client, pubsubjid, node)); in PubSubClientTest() 109 rtc::scoped_ptr<buzz::PubSubClient> client;
|
D | pubsubstateclient.h | 91 PubSubClient* client, in PubSubStateClient() 160 PubSubClient* client() { return client_; } in client() 164 void OnItems(PubSubClient* pub_sub_client, in OnItems() 223 void OnPublishResult(PubSubClient* pub_sub_client, in OnPublishResult() 229 void OnPublishError(PubSubClient* pub_sub_client, in OnPublishError() 236 void OnRetractResult(PubSubClient* pub_sub_client, in OnRetractResult() 245 void OnRetractError(PubSubClient* pub_sub_client, in OnRetractError() 256 PubSubClient* client_;
|
D | hangoutpubsubclient.h | 123 void OnPresenterRequestError(PubSubClient* client, 125 void OnMediaRequestError(PubSubClient* client, 166 rtc::scoped_ptr<PubSubClient> media_client_; 167 rtc::scoped_ptr<PubSubClient> presenter_client_;
|
D | hangoutpubsubclient.cc | 50 PubSubClient* client, in PresenterStateClient() 110 presenter_client_.reset(new PubSubClient(parent, mucjid, NS_PRESENTER)); in HangoutPubSubClient() 114 media_client_.reset(new PubSubClient(parent, mucjid, NS_GOOGLE_MUC_MEDIA)); in HangoutPubSubClient() 190 PubSubClient* client, const XmlElement* stanza) { in OnPresenterRequestError() 195 PubSubClient* client, const XmlElement* stanza) { in OnMediaRequestError()
|
/external/autotest/site_utils/ |
D | pubsub_utils_unittest.py | 82 pubsub_utils.PubSubClient() 91 pubsub_utils.PubSubClient(_TEST_CLOUD_SERVICE_ACCOUNT_FILE) 104 pubsub_utils.PubSubClient(_TEST_CLOUD_SERVICE_ACCOUNT_FILE) 126 pubsub_client = pubsub_utils.PubSubClient( 157 pubsub_client = pubsub_utils.PubSubClient(
|
D | pubsub_utils.py | 33 class PubSubClient(object): class
|
D | cloud_console_client_unittest.py | 23 pubsub_utils.PubSubClient)
|
D | cloud_console_client.py | 124 return pubsub_utils.PubSubClient(credential)
|