| /external/Reactive-Extensions/RxCpp/Rx/v2/test/subscriptions/ |
| D | subscription.cpp | 204 s0.unsubscribe(); in __anonfe564e910a02()
205 s1.unsubscribe(); in __anonfe564e910a02()
206 s2.unsubscribe(); in __anonfe564e910a02()
310 s0.unsubscribe(); in __anonfe564e911602()
311 s1.unsubscribe(); in __anonfe564e911602()
312 s2.unsubscribe(); in __anonfe564e911602()
381 s.unsubscribe();
385 s.unsubscribe();
386 s.unsubscribe();
390 s.unsubscribe();
[all …]
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/ |
| D | rx-subscription.hpp | 62 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 …]
|
| D | rx-notification.hpp | 29 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/test/subjects/ |
| D | subject.cpp | 49 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 __anon0164c1a70d02()
408 cs.unsubscribe(); in __anon0164c1a71402()
495 o.unsubscribe(); record(1000);}); in __anon0164c1a71e02()
505 results1.unsubscribe(); record(600);}); in __anon0164c1a72202()
507 results2.unsubscribe(); record(700);}); in __anon0164c1a72302()
509 results1.unsubscribe(); record(800);}); in __anon0164c1a72402()
511 results3.unsubscribe(); record(950);}); in __anon0164c1a72502()
[all …]
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/operators/ |
| D | rx-subscribe_on.hpp | 107 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()
|
| D | rx-delay.hpp | 101 localState->cs.unsubscribe(); in delay_observer()
102 localState->dest.unsubscribe(); in delay_observer()
103 localState->worker.unsubscribe(); in delay_observer()
|
| D | rx-sample_time.hpp | 100 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()
|
| D | rx-buffer_time_count.hpp | 113 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()
|
| D | rx-debounce.hpp | 105 localState->cs.unsubscribe(); in debounce_observer()
106 localState->dest.unsubscribe(); in debounce_observer()
107 localState->worker.unsubscribe(); in debounce_observer()
|
| D | rx-window_time_count.hpp | 115 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()
|
| D | rx-timeout.hpp | 112 localState->cs.unsubscribe(); in timeout_observer()
113 localState->dest.unsubscribe(); in timeout_observer()
114 localState->worker.unsubscribe(); in timeout_observer()
|
| D | rx-window_time.hpp | 120 localState->cs.unsubscribe(); in window_with_time_observer()
121 localState->dest.unsubscribe(); in window_with_time_observer()
122 localState->worker.unsubscribe(); in window_with_time_observer()
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/test/operators/ |
| D | publish.cpp | 183 res.unsubscribe(); in __anonf0c0cdea1402()
195 connection.unsubscribe(); in __anonf0c0cdea1602()
208 connection.unsubscribe(); in __anonf0c0cdea1802()
221 connection.unsubscribe(); in __anonf0c0cdea1a02()
297 res.unsubscribe(); in __anonf0c0cdea1d02()
309 connection.unsubscribe(); in __anonf0c0cdea1f02()
322 connection.unsubscribe(); in __anonf0c0cdea2102()
396 res.unsubscribe(); in __anonf0c0cdea2402()
408 connection.unsubscribe(); in __anonf0c0cdea2602()
421 connection.unsubscribe(); in __anonf0c0cdea2802()
[all …]
|
| D | replay.cpp | 45 res.unsubscribe(); in __anon724c1fe00302()
57 connection.unsubscribe(); in __anon724c1fe00502()
70 connection.unsubscribe(); in __anon724c1fe00702()
83 connection.unsubscribe(); in __anon724c1fe00902()
158 res.unsubscribe(); in __anon724c1fe00c02()
170 connection.unsubscribe(); in __anon724c1fe00e02()
183 connection.unsubscribe(); in __anon724c1fe01002()
257 connection.unsubscribe(); in __anon724c1fe01302()
387 connection.unsubscribe(); in __anon724c1fe01902()
506 connection.unsubscribe(); in __anon724c1fe01f02()
[all …]
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/test/sources/ |
| D | interval.cpp | 18 if (c == 5) {scbl.unsubscribe();} in __anon4b8fbe9d0102()
61 if (c == 5) {scbl.unsubscribe();} in __anon4b8fbe9d0402()
85 if (counter == 5) {cs.unsubscribe();} in __anon4b8fbe9d0502()
|
| /external/grpc-grpc/src/python/grpcio/grpc/beta/ |
| D | utilities.py | 62 self._channel.unsubscribe(self._update)
77 self._channel.unsubscribe(self._update)
129 self._channel.unsubscribe(self._update)
|
| D | implementations.py | 92 def unsubscribe(self, callback): member in Channel
99 self._channel.unsubscribe(callback)
|
| /external/grpc-grpc/src/python/grpcio/grpc/ |
| D | _utilities.py | 93 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.py | 72 channel.unsubscribe(callback.update)
74 channel.unsubscribe(callback.update)
140 channel.unsubscribe(callback.update)
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/examples/doxygen/ |
| D | create.cpp | 30 subscription.unsubscribe(); in __anon37f8ac850402()
55 subscription.unsubscribe(); in __anon37f8ac850702()
|
| D | subscribe.cpp | 69 subscription.unsubscribe(); in __anon72867ad30a02()
99 subscription.unsubscribe();
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/subjects/ |
| D | rx-subject.hpp | 169 o.unsubscribe(); in add()
210 s.unsubscribe(); in on_error()
228 s.unsubscribe(); in on_completed()
|
| /external/python/cpython3/Lib/test/test_email/data/ |
| D | msg_16.txt | 30 <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/
|
| /external/python/cpython2/Lib/email/test/data/ |
| D | msg_16.txt | 30 <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/
|
| /external/grpc-grpc/src/python/grpcio_tests/tests/fork/ |
| D | methods.py | 250 child_channel.unsubscribe(child_connectivity_callback)
265 channel.unsubscribe(parent_connectivity_callback)
271 channel.unsubscribe(parent_connectivity_callback)
|