| /external/Reactive-Extensions/RxCpp/Rx/v2/examples/doxygen/ |
| create.cpp | 24 auto subscription = rxcpp::composite_subscription(); variable
26 subscription,
30 subscription.unsubscribe();
49 auto subscription = rxcpp::composite_subscription(); variable
51 subscription,
55 subscription.unsubscribe();
|
| subscribe.cpp | 60 SCENARIO("subscribe by subscription, on_next, and on_completed"){
61 printf("//! [subscribe by subscription, on_next, and on_completed]\n");
62 auto subscription = rxcpp::composite_subscription(); variable
65 subscription,
66 [&subscription](int v){
69 subscription.unsubscribe();
72 printf("//! [subscribe by subscription, on_next, and on_completed]\n");
96 auto subscription = values.subscribe( variable
99 subscription.unsubscribe();
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/examples/stop/ |
| main.cpp | 29 auto subscription = published_observable.connect(); local
31 subscription.unsubscribe();
|
| /developers/samples/android/tv/ChannelsPrograms/Application/src/main/java/com/example/android/tv/channelsprograms/ |
| AppLinkActivity.java | 27 import com.example.android.tv.channelsprograms.model.Subscription;
71 Subscription subscription = local
73 if (subscription == null) {
74 Log.e(TAG, "Invalid subscription " + action.getSubscriptionName());
76 // TODO: Open an activity that has the movies for the subscription.
|
| MainActivity.java | 28 import com.example.android.tv.channelsprograms.model.Subscription;
56 final Subscription tvShowSubscription =
60 final Subscription videoSubscription =
64 final Subscription catVideosSubscription =
71 private void setupButtonState(Button button, final Subscription subscription) {
72 boolean channelExists = subscription.getChannelId() > 0L;
75 view -> new AddChannelTask(getApplicationContext()).execute(subscription));
78 private class AddChannelTask extends AsyncTask<Subscription, Void, Long> {
87 protected Long doInBackground(Subscription... varArgs)
92 Subscription subscription = subscriptions.get(0); local
[all...] |
| SyncProgramsJobService.java | 33 import com.example.android.tv.channelsprograms.model.Subscription;
230 Subscription subscription = local
232 if (subscription != null) {
|
| /developers/samples/android/tv/ChannelsPrograms/Application/src/main/java/com/example/android/tv/channelsprograms/model/ |
| MockDatabase.java | 37 * Returns a subscription to mock content representing tv shows.
40 * @return a subscription with tv show data.
42 public static Subscription getTvShowSubscription(Context context) {
52 * Returns a subscription to mock content representing your videos.
55 * @return a subscription with your video data.
57 public static Subscription getVideoSubscription(Context context) {
67 * Returns a subscription to mock content representing cat videos.
70 * @return a subscription with cat videos.
72 public static Subscription getCatVideosSubscription(Context context) {
81 private static Subscription findOrCreateSubscription
89 Subscription subscription = findSubscriptionByTitle(context, title); local
[all...] |
| /cts/tests/tests/telephony/current/src/android/telephony/euicc/cts/ |
| EuiccManagerTest.java | 117 DownloadableSubscription subscription = createDownloadableSubscription(); local
120 subscription, false /* switchAfterDownload */, callbackIntent);
|
| EuiccServiceTest.java | 168 DownloadableSubscription subscription = local
175 subscription,
244 DownloadableSubscription subscription = local
251 subscription,
|
| /external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/ |
| rx-notification.hpp | 14 class subscription class in namespace:rxcpp::notifications
20 explicit inline subscription(long s) function in class:rxcpp::notifications::subscription
23 inline subscription(long s, long u) function in class:rxcpp::notifications::subscription
34 inline bool operator == (subscription lhs, subscription rhs) {
38 inline std::ostream& operator<< (std::ostream& out, const subscription& s) {
271 inline std::ostream& operator<< (std::ostream& out, const std::vector<rxcpp::notifications::subscription>& vs) {
|
| rx-subscription.hpp | 67 class subscription : public subscription_base class in namespace:rxcpp
109 friend bool operator<(const subscription&, const subscription&);
110 friend bool operator==(const subscription&, const subscription&);
113 subscription(weak_state_type w) function in class:rxcpp::subscription
121 explicit subscription(std::shared_ptr<base_subscription_state> s) function in class:rxcpp::subscription
130 subscription() function in class:rxcpp::subscription
138 explicit subscription(U u, typename std::enable_if<!is_subscription<U>::value, void**>::type = nullptr) function in class:rxcpp::subscription
146 explicit subscription(U u, typename std::enable_if<!std::is_same<subscription, U>::value && is_subscription<U>::value, v (…) function in class:rxcpp::subscription
154 subscription(const subscription& o) function in class:rxcpp::subscription
161 subscription(subscription&& o) function in class:rxcpp::subscription
[all...] |
| /external/libchrome/base/ |
| callback_list_unittest.cc | 41 std::unique_ptr<CallbackList<void(void)>::Subscription> sub) {
49 std::unique_ptr<CallbackList<void(void)>::Subscription> removal_subscription_;
77 std::unique_ptr<CallbackList<void(void)>::Subscription> subscription_;
121 std::unique_ptr<CallbackList<void(int)>::Subscription> subscription1 =
128 std::unique_ptr<CallbackList<void(int, int)>::Subscription> subscription2 =
135 std::unique_ptr<CallbackList<void(int, int, int)>::Subscription>
142 std::unique_ptr<CallbackList<void(int, int, int, int)>::Subscription>
149 std::unique_ptr<CallbackList<void(int, int, int, int, int)>::Subscription>
157 CallbackList<void(int, int, int, int, int, int)>::Subscription>
170 std::unique_ptr<CallbackList<void(void)>::Subscription> a_subscription
312 std::unique_ptr<CallbackList<void(void)>::Subscription> subscription = local
[all...] |
| /external/wpa_supplicant_8/src/wps/ |
| wps_upnp_i.h | 79 struct subscription { struct
82 time_t timeout_time; /* when to age out the subscription */
85 * This uuid identifies the subscription and is randomly generated by
86 * us and given to the subscriber when the subscription is accepted;
152 struct subscription * subscription_start(struct upnp_wps_device_sm *sm,
154 struct subscription * subscription_renew(struct upnp_wps_device_sm *sm,
156 void subscription_destroy(struct subscription *s);
157 struct subscription * subscription_find(struct upnp_wps_device_sm *sm,
180 int event_add(struct subscription *s, const struct wpabuf *data, int probereq);
181 void event_delete_all(struct subscription *s)
[all...] |
