feat: wiring up example for polling · DaveLapar/Android-RxJava@66ceea9 · GitHub
Skip to content

Commit 66ceea9

Browse files
author
Kaushik Gopal
committed
feat: wiring up example for polling
1 parent 4e6be41 commit 66ceea9

5 files changed

Lines changed: 163 additions & 1 deletion

File tree

‎app/src/main/java/com/morihacky/android/rxjava/MainFragment.java‎

Lines changed: 9 additions & 0 deletions

‎app/src/main/java/com/morihacky/android/rxjava/PollingFragment.java‎

Lines changed: 111 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,111 @@
1+
package com.morihacky.android.rxjava;
2+
3+
import android.content.Context;
4+
import android.os.Bundle;
5+
import android.os.Handler;
6+
import android.os.Looper;
7+
import android.support.annotation.Nullable;
8+
import android.support.v4.app.Fragment;
9+
import android.view.LayoutInflater;
10+
import android.view.View;
11+
import android.view.ViewGroup;
12+
import android.widget.ArrayAdapter;
13+
import android.widget.Button;
14+
import android.widget.ListView;
15+
import butterknife.ButterKnife;
16+
import butterknife.InjectView;
17+
import butterknife.OnClick;
18+
import com.morihacky.android.rxjava.app.R;
19+
import java.util.ArrayList;
20+
import java.util.List;
21+
import rx.subscriptions.CompositeSubscription;
22+
import timber.log.Timber;
23+
24+
public class PollingFragment
25+
extends Fragment {
26+
27+
@InjectView(R.id.list_threading_log) ListView _logsList;
28+
@InjectView(R.id.btn_start_simple_polling) Button _btnSimplePolling;
29+
30+
private LogAdapter _adapter;
31+
private List<String> _logs;
32+
private CompositeSubscription _subscriptions;
33+
34+
@Override
35+
public void onDestroy() {
36+
super.onDestroy();
37+
_subscriptions.unsubscribe();
38+
}
39+
40+
@Override
41+
public void onActivityCreated(@Nullable Bundle savedInstanceState) {
42+
super.onActivityCreated(savedInstanceState);
43+
_setupLogger();
44+
}
45+
46+
@Override
47+
public View onCreateView(LayoutInflater inflater,
48+
@Nullable ViewGroup container,
49+
@Nullable Bundle savedInstanceState) {
50+
View layout = inflater.inflate(R.layout.fragment_polling, container, false);
51+
ButterKnife.inject(this, layout);
52+
return layout;
53+
}
54+
55+
@OnClick(R.id.btn_start_simple_polling)
56+
public void onStartSimplePollingClicked() {
57+
58+
}
59+
60+
61+
// -----------------------------------------------------------------------------------
62+
// Method that help wiring up the example (irrelevant to RxJava)
63+
64+
private void _doSomeLongOperation_thatBlocksCurrentThread() {
65+
_log("performing long operation");
66+
67+
try {
68+
Thread.sleep(3000);
69+
} catch (InterruptedException e) {
70+
Timber.d("Operation was interrupted");
71+
}
72+
}
73+
74+
private void _log(String logMsg) {
75+
if (_isCurrentlyOnMainThread()) {
76+
_logs.add(0, logMsg + " (main thread) ");
77+
_adapter.clear();
78+
_adapter.addAll(_logs);
79+
} else {
80+
_logs.add(0, logMsg + " (NOT main thread) ");
81+
82+
// You can only do below stuff on main thread.
83+
new Handler(Looper.getMainLooper()).post(new Runnable() {
84+
85+
@Override
86+
public void run() {
87+
_adapter.clear();
88+
_adapter.addAll(_logs);
89+
}
90+
});
91+
}
92+
}
93+
94+
private void _setupLogger() {
95+
_logs = new ArrayList<String>();
96+
_adapter = new LogAdapter(getActivity(), new ArrayList<String>());
97+
_logsList.setAdapter(_adapter);
98+
}
99+
100+
private boolean _isCurrentlyOnMainThread() {
101+
return Looper.myLooper() == Looper.getMainLooper();
102+
}
103+
104+
private class LogAdapter
105+
extends ArrayAdapter<String> {
106+
107+
public LogAdapter(Context context, List<String> logs) {
108+
super(context, R.layout.item_log, R.id.item_log, logs);
109+
}
110+
}
111+
}

‎app/src/main/res/layout/fragment_main.xml‎

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -44,5 +44,11 @@
4444
android:layout_height="wrap_content"
4545
android:layout_width="match_parent"
4646
android:text="@string/btn_demo_double_binding_textview"/>
47+
48+
<Button
49+
android:id="@+id/btn_demo_polling"
50+
android:layout_height="wrap_content"
51+
android:layout_width="match_parent"
52+
android:text="@string/btn_demo_polling"/>
4753
</LinearLayout>
4854
</ScrollView>

‎app/src/main/res/layout/fragment_polling.xml‎

Lines changed: 34 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,34 @@
1+
<?xml version="1.0" encoding="utf-8"?>
2+
3+
<LinearLayout
4+
android:orientation="vertical"
5+
android:layout_height="match_parent"
6+
android:layout_width="match_parent"
7+
xmlns:android="http://schemas.android.com/apk/res/android">
8+
9+
<TextView
10+
android:layout_height="wrap_content"
11+
android:layout_width="match_parent"
12+
android:padding="10dp"
13+
android:gravity="center"
14+
android:text="@string/msg_demo_polling"/>
15+
16+
17+
<LinearLayout
18+
android:layout_height="wrap_content"
19+
android:layout_width="match_parent">
20+
21+
<Button
22+
android:id="@+id/btn_start_simple_polling"
23+
android:layout_height="wrap_content"
24+
android:layout_width="wrap_content"
25+
android:layout_marginLeft="20dp"
26+
android:textSize="16sp"
27+
android:text="Start simple polling"/>
28+
</LinearLayout>
29+
30+
<ListView
31+
android:id="@+id/list_threading_log"
32+
android:layout_height="match_parent"
33+
android:layout_width="match_parent"/>
34+
</LinearLayout>

‎app/src/main/res/values/strings.xml‎

Lines changed: 3 additions & 1 deletion

0 commit comments

Comments
 (0)