Skip to content

Commit 3a8531a

Browse files
jiang111jiang111
committed
add some operators
1 parent 5166814 commit 3a8531a

File tree

6 files changed

+261
-47
lines changed

6 files changed

+261
-47
lines changed

‎app/build.gradle

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -34,6 +34,7 @@ dependencies {
3434
compile files('libs/commons-codec-1.6.jar')
3535
compile 'io.reactivex:rxjava:1.1.1'
3636
compile 'io.reactivex:rxandroid:1.1.0'
37+
compile 'de.greenrobot:eventbus:2.4.+'
3738

3839

3940
}

‎app/src/main/java/com/jiang/android/rxjavaapp/InitDataService.java

Lines changed: 109 additions & 34 deletions
Large diffs are not rendered by default.

‎app/src/main/java/com/jiang/android/rxjavaapp/actiity/MainActivity.java

Lines changed: 17 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -29,6 +29,7 @@
2929
import java.util.ArrayList;
3030
import java.util.List;
3131

32+
import de.greenrobot.event.EventBus;
3233
import rx.Observable;
3334
import rx.Subscriber;
3435
import rx.android.schedulers.AndroidSchedulers;
@@ -52,8 +53,18 @@ public class MainActivity extends BaseActivity implements View.OnClickListener {
5253
private NavigationView navigationView;
5354
private ActionBarDrawerToggle toggle;
5455

56+
public void onEventMainThread(int center) {
57+
if (center == 1) {
58+
initToolBar();
59+
initNavigationView();
60+
initNavRecycerView();
61+
mContentRecyclerView = (RecyclerView) findViewById(R.id.id_content);
62+
}
63+
}
64+
5565
@Override
5666
protected void initViewsAndEvents() {
67+
EventBus.getDefault().register(this);
5768
initToolBar();
5869
initNavigationView();
5970
initNavRecycerView();
@@ -243,6 +254,12 @@ public void onBackPressed() {
243254
}
244255
}
245256

257+
@Override
258+
protected void onDestroy() {
259+
super.onDestroy();
260+
EventBus.getDefault().unregister(this);
261+
}
262+
246263
@Override
247264
public boolean onCreateOptionsMenu(Menu menu) {
248265
// Inflate the menu; this adds items to the action bar if it is present.

‎app/src/main/java/com/jiang/android/rxjavaapp/actiity/splashActivity.java

Lines changed: 10 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -30,6 +30,12 @@ public class splashActivity extends Activity {
3030
protected void onCreate(Bundle savedInstanceState) {
3131
super.onCreate(savedInstanceState);
3232
setContentView(getContentViewLayoutID());
33+
boolean isFirst = SharePrefUtil.getBoolean(this, SPKey.FIRST_ENTER, true);
34+
if (isFirst) {
35+
Intent intent = new Intent(this, InitDataService.class);
36+
startService(intent);
37+
this.finish();
38+
}
3339
mSplashIndex = (ImageView) findViewById(R.id.splash_index);
3440
initViewsAndEvents();
3541
}
@@ -69,13 +75,10 @@ protected void onResume() {
6975
}
7076

7177
private void toGuideOrMain() {
72-
boolean isFirst = SharePrefUtil.getBoolean(this, SPKey.FIRST_ENTER, true);
73-
if (isFirst) {
74-
Intent intent = new Intent(this, InitDataService.class);
75-
startService(intent);
76-
} else {
77-
startActivity(new Intent(this, MainActivity.class));
78-
}
78+
79+
startActivity(new Intent(this, MainActivity.class));
80+
this.finish();
81+
7982
}
8083

8184
protected int getContentViewLayoutID() {

‎app/src/main/java/com/jiang/android/rxjavaapp/common/CommonString.java

Lines changed: 59 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -33,11 +33,7 @@
3333
*/
3434
public class CommonString {
3535
public static final String SPLASH_INDEX_URL = "http://s7.51cto.com/wyfs02/M01/71/AC/wKiom1XWiPSQ-3r1AABXHna6t3c411.jpg";
36-
37-
3836
public static final String GITHUB_URL = "https://github.com/jiang111/RxJavaApp";
39-
40-
4137
public static final String OBSERVABLES = "https://github.com/mcxiaoke/RxDocs/raw/master/images/legend.png";
4238
public static final String SUBJECT = "https://github.com/mcxiaoke/RxDocs/raw/master/images/S.AsyncSubject.png";
4339
public static final String JUST = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/just.png";
@@ -46,12 +42,10 @@ public class CommonString {
4642
public static final String REPEAT_WHEN = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/repeatWhen.f.png";
4743
public static final String CREATE = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/create.c.png";
4844
public static final String DEFER = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/defer.c.png";
49-
5045
public static final String RANGE = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/range.png";
5146
public static final String INTERVAL = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/interval.c.png";
5247
public static final String TIMER = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/timer.p.png";
5348
public static final String EMPTY = SPLASH_INDEX_URL;
54-
5549
// transd form
5650
public static final String MAP = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/map.png";
5751
public static final String FLATMAP = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/flatMap.png";
@@ -62,6 +56,65 @@ public class CommonString {
6256
public static final String BUFFER = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/buffer.png";
6357
public static final String WINDOW = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/window.C.png";
6458
public static final String CAST = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/cast.png";
59+
//filter
60+
public static final String FILTER = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/filter.c.png";
61+
public static final String TAKE_LAST = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/takeLast.c.png";
62+
public static final String LAST = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/last.c.png";
63+
public static final String LAST_OR_DEFAULT = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/lastOrDefault.p.png";
64+
public static final String TAKE_LAST_BUFFER = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/takeLastBuffer.png";
65+
public static final String SKIP = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/skip.png";
66+
public static final String SKIP_LAST = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/skipLast.c.png";
67+
public static final String TAKE = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/take.c.png";
68+
public static final String FIRST = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/first.c.png";
69+
public static final String FIRST_DEFAULT = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/firstOrDefault.png";
70+
public static final String ELEMENT_AT = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/elementAt.c.png";
71+
public static final String ELEMENT_DEFAULT = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/elementAtOrDefault.png";
72+
public static final String SAMPLE = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/sample.png";
73+
public static final String THROLFIRST = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/throttleFirst.png";
74+
public static final String DEBOUND = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/debounce.png";
75+
public static final String TIMEOUT = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/timeout.c.png";
76+
public static final String DISTINCT = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/distinct.png";
77+
public static final String UNTILCHANGED = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/distinctUntilChanged.png";
78+
public static final String OF_TYPE = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/filter.png";
79+
public static final String IGNORE_ELEMENT = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/ignoreElements.c.png";
80+
81+
82+
//combin
83+
public static final String STARTWITH = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/startWith.png";
84+
public static final String MERGE = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/merge.c.png";
85+
public static final String MERGEDELAY = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/mergeDelayError.C.png";
86+
public static final String ZIP = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/zip.c.png";
87+
public static final String AND = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/and_then_when.C.png";
88+
public static final String COMBINLASTED = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/combineLatest.c.png";
89+
public static final String JOIN = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/join.c.png";
90+
public static final String SWITHONNEXT = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/switch.c.png";
91+
92+
93+
//error
94+
public static final String RETRY = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/retry.C.png";
95+
public static final String RETRYWHEN = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/retryWhen.f.png";
96+
97+
98+
//utility
99+
public static final String Materialize = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/materialize.c.png";
100+
public static final String Dematerialize = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/dematerialize.c.png";
101+
public static final String Timestamp = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/timestamp.c.png";
102+
public static final String Serialize = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/serialize.c.png";
103+
public static final String ObserveOn = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/observeOn.c.png";
104+
public static final String SubscribeOn = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/subscribeOn.c.png";
105+
public static final String doOnEach = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/doOnEach.png";
106+
public static final String doOnSubscribe = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/doOnSubscribe.png";
107+
public static final String doOnUnsubscribe = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/doOnUnsubscribe.png";
108+
public static final String doOnCompleted = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/doOnCompleted.png";
109+
public static final String doOnError = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/doOnError.png";
110+
public static final String doOnTerminate = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/doOnTerminate.png";
65111

112+
public static final String finallyDo = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/finallyDo.png";
113+
public static final String Delay = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/delay.c.png";
114+
public static final String delaySubscription = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/delaySubscription.o.png";
115+
public static final String TimeInterval = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/timeInterval.c.png";
116+
public static final String Using = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/using.c.png";
117+
public static final String First = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/first.c.png";
118+
public static final String To = "https://github.com/mcxiaoke/RxDocs/raw/master/images/operators/to.c.png";
66119

67120
}

‎app/src/main/java/com/jiang/android/rxjavaapp/common/OperatorsUrl.java

Lines changed: 65 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -60,4 +60,69 @@ public class OperatorsUrl {
6060
public static final String WINDOW = "https://github.com/mcxiaoke/RxDocs/blob/master/operators/Window.md";
6161
public static final String CAST = "https://github.com/mcxiaoke/RxDocs/blob/master/operators/Map.md";
6262

63+
64+
//filter
65+
66+
67+
//filter
68+
public static final String FILTER = "https://github.com/mcxiaoke/RxDocs/blob/master/operators/Filter.md";
69+
public static final String TAKE_LAST = "https://github.com/mcxiaoke/RxDocs/blob/master/operators/TakeLast.md";
70+
public static final String LAST = "https://github.com/mcxiaoke/RxDocs/blob/master/operators/Last.md";
71+
public static final String LAST_OR_DEFAULT = "https://github.com/mcxiaoke/RxDocs/blob/master/operators/Last.md";
72+
public static final String TAKE_LAST_BUFFER = "https://github.com/mcxiaoke/RxDocs/blob/master/operators/TakeLast.md";
73+
public static final String SKIP = "https://github.com/mcxiaoke/RxDocs/blob/master/operators/Skip.md";
74+
public static final String SKIP_LAST = "https://github.com/mcxiaoke/RxDocs/blob/master/operators/SkipLast.md";
75+
public static final String TAKE = "https://github.com/mcxiaoke/RxDocs/blob/master/operators/Take.md";
76+
public static final String FIRST = "https://github.com/mcxiaoke/RxDocs/blob/master/operators/First.md";
77+
public static final String FIRST_DEFAULT = "https://github.com/mcxiaoke/RxDocs/blob/master/operators/First.md";
78+
public static final String ELEMENT_AT = "https://github.com/mcxiaoke/RxDocs/blob/master/operators/ElementAt.md";
79+
public static final String ELEMENT_DEFAULT = "https://github.com/mcxiaoke/RxDocs/blob/master/operators/ElementAt.md";
80+
public static final String SAMPLE = "https://github.com/mcxiaoke/RxDocs/blob/master/operators/Sample.md";
81+
public static final String THROLFIRST = "https://github.com/mcxiaoke/RxDocs/blob/master/operators/Sample.md";
82+
public static final String DEBOUND = "https://github.com/mcxiaoke/RxDocs/blob/master/operators/Debounce.md";
83+
public static final String TIMEOUT = "https://github.com/mcxiaoke/RxDocs/blob/master/operators/Timeout.md";
84+
public static final String DISTINCT = "https://github.com/mcxiaoke/RxDocs/blob/master/operators/Distinct.md";
85+
public static final String UNTILCHANGED = "https://github.com/mcxiaoke/RxDocs/blob/master/operators/Distinct.md";
86+
public static final String OF_TYPE = "https://github.com/mcxiaoke/RxDocs/blob/master/operators/Filter.md";
87+
public static final String IGNORE_ELEMENT = "https://github.com/mcxiaoke/RxDocs/blob/master/operators/IgnoreElements.md";
88+
89+
90+
//combin
91+
public static final String STARTWITH = "https://github.com/mcxiaoke/RxDocs/blob/master/operators/Merge.md";
92+
public static final String MERGE = "https://github.com/mcxiaoke/RxDocs/blob/master/operators/Merge.md";
93+
public static final String MERGEDELAY = "https://github.com/mcxiaoke/RxDocs/blob/master/operators/Merge.md";
94+
public static final String ZIP = "https://github.com/mcxiaoke/RxDocs/blob/master/operators/Zip.md";
95+
public static final String AND = "https://github.com/mcxiaoke/RxDocs/blob/master/operators/And.md";
96+
public static final String COMBINLASTED = "https://github.com/mcxiaoke/RxDocs/blob/master/operators/CombineLatest.md";
97+
public static final String JOIN = "https://github.com/mcxiaoke/RxDocs/blob/master/operators/Join.md";
98+
public static final String SWITHONNEXT = "https://github.com/mcxiaoke/RxDocs/blob/master/operators/Switch.md";
99+
100+
//error
101+
public static final String ERROR = "https://github.com/mcxiaoke/RxDocs/blob/master/operators/Catch.md";
102+
public static final String RETRY = "https://github.com/mcxiaoke/RxDocs/blob/master/operators/Retry.md#retry";
103+
104+
105+
//utity
106+
//utility
107+
public static final String Materialize = "https://github.com/mcxiaoke/RxDocs/blob/master/operators/Materialize.md";
108+
public static final String Dematerialize = "https://github.com/mcxiaoke/RxDocs/blob/master/operators/Materialize.md";
109+
public static final String Timestamp = "https://github.com/mcxiaoke/RxDocs/blob/master/operators/Timestamp.md";
110+
public static final String Serialize = "https://github.com/mcxiaoke/RxDocs/blob/master/operators/Serialize.md";
111+
public static final String ObserveOn = "https://github.com/mcxiaoke/RxDocs/blob/master/operators/ObserveOn.md";
112+
public static final String SubscribeOn = "https://github.com/mcxiaoke/RxDocs/blob/master/operators/SubscribeOn.md";
113+
public static final String doOnEach = "https://github.com/mcxiaoke/RxDocs/blob/master/operators/Do.md";
114+
public static final String doOnSubscribe = "https://github.com/mcxiaoke/RxDocs/blob/master/operators/Do.md";
115+
public static final String doOnUnsubscribe = "https://github.com/mcxiaoke/RxDocs/blob/master/operators/Do.md";
116+
public static final String doOnCompleted = "https://github.com/mcxiaoke/RxDocs/blob/master/operators/Do.md";
117+
public static final String doOnError = "https://github.com/mcxiaoke/RxDocs/blob/master/operators/Do.md";
118+
public static final String doOnTerminate = "https://github.com/mcxiaoke/RxDocs/blob/master/operators/Do.md";
119+
120+
public static final String finallyDo = "https://github.com/mcxiaoke/RxDocs/blob/master/operators/Do.md";
121+
public static final String Delay = "https://github.com/mcxiaoke/RxDocs/blob/master/operators/Delay.md";
122+
public static final String delaySubscription = "https://github.com/mcxiaoke/RxDocs/blob/master/operators/Delay.md";
123+
public static final String TimeInterval = "https://github.com/mcxiaoke/RxDocs/blob/master/operators/TimeInterval.md";
124+
public static final String Using = "https://github.com/mcxiaoke/RxDocs/blob/master/operators/Using.md";
125+
public static final String First = "https://github.com/mcxiaoke/RxDocs/blob/master/operators/First.md";
126+
public static final String To = "https://github.com/mcxiaoke/RxDocs/blob/master/operators/To.md";
127+
63128
}

0 commit comments

Comments
 (0)