Home
last modified time | relevance | path

Searched refs:unsubscribe (Results 1 – 25 of 71) sorted by relevance

123

/external/Reactive-Extensions/RxCpp/Rx/v2/test/subscriptions/
Dsubscription.cpp204 s0.unsubscribe(); in __anon442cb92f0a02()
205 s1.unsubscribe(); in __anon442cb92f0a02()
206 s2.unsubscribe(); in __anon442cb92f0a02()
310 s0.unsubscribe(); in __anon442cb92f1602()
311 s1.unsubscribe(); in __anon442cb92f1602()
312 s2.unsubscribe(); in __anon442cb92f1602()
381 s.unsubscribe();
385 s.unsubscribe();
386 s.unsubscribe();
390 s.unsubscribe();
[all …]
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/
Drx-subscription.hpp62 void unsubscribe() const { in unsubscribe() function in rxcpp::static_subscription
79 virtual void unsubscribe() { in unsubscribe() function in rxcpp::subscription::base_subscription_state
96 virtual void unsubscribe() { in unsubscribe() function
99 inner.unsubscribe(); in unsubscribe()
178 void unsubscribe() const { in unsubscribe() function in rxcpp::subscription
183 state->unsubscribe(); in unsubscribe()
286 s.unsubscribe(); in add()
293 s.unsubscribe(); in add()
348 s.unsubscribe(); }); in clear()
366 inline void unsubscribe() { in unsubscribe() function
[all …]
Drx-notification.hpp29 inline long unsubscribe() const { in unsubscribe() function in rxcpp::notifications::subscription
35 return lhs.subscribe() == rhs.subscribe() && lhs.unsubscribe() == rhs.unsubscribe(); in operator ==()
39 out << s.subscribe() << "-" << s.unsubscribe(); in operator <<()
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/
Drx-subscribe_on.hpp107 sl.unsubscribe(); in on_subscribe()
108 ol.unsubscribe(); in on_subscribe()
109 coordinator_lifetime.unsubscribe(); in on_subscribe()
123 sl.unsubscribe(); in on_subscribe()
124 ol.unsubscribe(); in on_subscribe()
125 coordinator_lifetime.unsubscribe(); in on_subscribe()
Drx-sample_time.hpp100 localState->cs.unsubscribe(); in sample_with_time_observer()
101 localState->dest.unsubscribe(); in sample_with_time_observer()
102 localState->worker.unsubscribe(); in sample_with_time_observer()
Drx-delay.hpp101 localState->cs.unsubscribe(); in delay_observer()
102 localState->dest.unsubscribe(); in delay_observer()
103 localState->worker.unsubscribe(); in delay_observer()
Drx-buffer_time_count.hpp113 localState->cs.unsubscribe(); in buffer_with_time_or_count_observer()
114 localState->dest.unsubscribe(); in buffer_with_time_or_count_observer()
115 localState->worker.unsubscribe(); in buffer_with_time_or_count_observer()
Drx-timeout.hpp112 localState->cs.unsubscribe(); in timeout_observer()
113 localState->dest.unsubscribe(); in timeout_observer()
114 localState->worker.unsubscribe(); in timeout_observer()
Drx-window_time_count.hpp115 localState->cs.unsubscribe(); in window_with_time_or_count_observer()
116 localState->dest.unsubscribe(); in window_with_time_or_count_observer()
117 localState->worker.unsubscribe(); in window_with_time_or_count_observer()
Drx-debounce.hpp105 localState->cs.unsubscribe(); in debounce_observer()
106 localState->dest.unsubscribe(); in debounce_observer()
107 localState->worker.unsubscribe(); in debounce_observer()
Drx-buffer_time.hpp128 localState->cs.unsubscribe(); in buffer_with_time_observer()
129 localState->dest.unsubscribe(); in buffer_with_time_observer()
130 localState->worker.unsubscribe(); in buffer_with_time_observer()
/external/Reactive-Extensions/RxCpp/Rx/v2/test/subjects/
Dsubject.cpp49 void unsubscribe() {issubscribed = false;} in unsubscribe() function in syncwithvoid::sync_subscriber
112 void unsubscribe() {issubscribed = false;} in unsubscribe() function in asyncwithready::async_subscriber
187 void unsubscribe() {issubscribed = false;} in unsubscribe() function in asyncwithfuture::async_subscriber
338 cs.unsubscribe(); in __anon2b91aec50d02()
408 cs.unsubscribe(); in __anon2b91aec51402()
495 o.unsubscribe(); record(1000);}); in __anon2b91aec51e02()
505 results1.unsubscribe(); record(600);}); in __anon2b91aec52202()
507 results2.unsubscribe(); record(700);}); in __anon2b91aec52302()
509 results1.unsubscribe(); record(800);}); in __anon2b91aec52402()
511 results3.unsubscribe(); record(950);}); in __anon2b91aec52502()
[all …]
/external/Reactive-Extensions/RxCpp/Rx/v2/test/operators/
Dpublish.cpp183 res.unsubscribe(); in __anon608b5ec81402()
195 connection.unsubscribe(); in __anon608b5ec81602()
208 connection.unsubscribe(); in __anon608b5ec81802()
221 connection.unsubscribe(); in __anon608b5ec81a02()
297 res.unsubscribe(); in __anon608b5ec81d02()
309 connection.unsubscribe(); in __anon608b5ec81f02()
322 connection.unsubscribe(); in __anon608b5ec82102()
396 res.unsubscribe(); in __anon608b5ec82402()
408 connection.unsubscribe(); in __anon608b5ec82602()
421 connection.unsubscribe(); in __anon608b5ec82802()
[all …]
Dreplay.cpp45 res.unsubscribe(); in __anon9c790cfe0302()
57 connection.unsubscribe(); in __anon9c790cfe0502()
70 connection.unsubscribe(); in __anon9c790cfe0702()
83 connection.unsubscribe(); in __anon9c790cfe0902()
158 res.unsubscribe(); in __anon9c790cfe0c02()
170 connection.unsubscribe(); in __anon9c790cfe0e02()
183 connection.unsubscribe(); in __anon9c790cfe1002()
257 connection.unsubscribe(); in __anon9c790cfe1302()
387 connection.unsubscribe(); in __anon9c790cfe1902()
506 connection.unsubscribe(); in __anon9c790cfe1f02()
[all …]
/external/Reactive-Extensions/RxCpp/Rx/v2/test/sources/
Dinterval.cpp18 if (c == 5) {scbl.unsubscribe();} in __anon75bcabbb0102()
61 if (c == 5) {scbl.unsubscribe();} in __anon75bcabbb0402()
85 if (counter == 5) {cs.unsubscribe();} in __anon75bcabbb0502()
/external/grpc-grpc/src/python/grpcio/grpc/beta/
Dutilities.py62 self._channel.unsubscribe(self._update)
77 self._channel.unsubscribe(self._update)
129 self._channel.unsubscribe(self._update)
Dimplementations.py92 def unsubscribe(self, callback): member in Channel
99 self._channel.unsubscribe(callback)
/external/grpc-grpc/src/python/grpcio/grpc/
D_utilities.py93 self._channel.unsubscribe(self._update)
108 self._channel.unsubscribe(self._update)
160 self._channel.unsubscribe(self._update)
/external/grpc-grpc/src/python/grpcio_tests/tests/unit/
D_channel_connectivity_test.py72 channel.unsubscribe(callback.update)
74 channel.unsubscribe(callback.update)
140 channel.unsubscribe(callback.update)
/external/Reactive-Extensions/RxCpp/Rx/v2/examples/doxygen/
Dcreate.cpp30 subscription.unsubscribe(); in __anona11559230402()
55 subscription.unsubscribe(); in __anona11559230702()
Dsubscribe.cpp69 subscription.unsubscribe(); in __anonf4ca4ab10a02()
99 subscription.unsubscribe();
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/subjects/
Drx-subject.hpp169 o.unsubscribe(); in add()
210 s.unsubscribe(); in on_error()
228 s.unsubscribe(); in on_completed()
/external/Reactive-Extensions/RxCpp/Rx/v2/examples/stop/
Dmain.cpp31 subscription.unsubscribe(); in main()
/external/grpc-grpc/src/python/grpcio_tests/tests/fork/
Dmethods.py250 child_channel.unsubscribe(child_connectivity_callback)
265 channel.unsubscribe(parent_connectivity_callback)
271 channel.unsubscribe(parent_connectivity_callback)
/external/python/cpython2/Lib/email/test/data/
Dmsg_16.txt30 <mailto:scr-request@socal-raves.org?subject=unsubscribe>
111 <mailto:scr-request@socal-raves.org?subject=unsubscribe>
118 For event info, list questions, or to unsubscribe, see http://www.socal-raves.org/

123