Home
last modified time | relevance | path

Searched refs:PubSubClient (Results 1 – 10 of 10) sorted by relevance

/external/webrtc/webrtc/libjingle/xmpp/
Dpubsubclient.cc22 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 …]
Dpubsubclient.h36 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*,
Dpubsubclient_unittest.cc32 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;
Dpubsubstateclient.h91 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_;
Dhangoutpubsubclient.h123 void OnPresenterRequestError(PubSubClient* client,
125 void OnMediaRequestError(PubSubClient* client,
166 rtc::scoped_ptr<PubSubClient> media_client_;
167 rtc::scoped_ptr<PubSubClient> presenter_client_;
Dhangoutpubsubclient.cc50 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/
Dpubsub_utils_unittest.py82 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(
Dpubsub_utils.py33 class PubSubClient(object): class
Dcloud_console_client_unittest.py23 pubsub_utils.PubSubClient)
Dcloud_console_client.py124 return pubsub_utils.PubSubClient(credential)