/external/Reactive-Extensions/RxCpp/Rx/v2/test/subscriptions/ |
D | subscription.cpp | 204 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/ |
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/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-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-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-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-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_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-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-buffer_time.hpp | 128 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/ |
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 __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/ |
D | publish.cpp | 183 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 …]
|
D | replay.cpp | 45 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/ |
D | interval.cpp | 18 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/ |
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 __anona11559230402() 55 subscription.unsubscribe(); in __anona11559230702()
|
D | subscribe.cpp | 69 subscription.unsubscribe(); in __anonf4ca4ab10a02() 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/Reactive-Extensions/RxCpp/Rx/v2/examples/stop/ |
D | main.cpp | 31 subscription.unsubscribe(); in main()
|
/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)
|
/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/
|