GeezerVisonThe World Wide Web, restored to 800 pixels of glory. |
| Home|About|Gaming cabinet|Archives|How it works|Starter sites |
GeezerVison is showing github.com — libraries/rxjava/SingleObserverActivity.java at master · android-code/libraries Expand file tree/ Copy pathSingleObserverActivity.javaMore file actions 47 lines (39 loc) · 1.41 KB / Copy pathSingleObserverActivity.javaFile metadata and controls47 lines (39 loc) · 1.41 KB 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 public class SingleObserverActivity extends AppCompatActivity { private Disposable disposable; @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_single_observer); Observable<String> observable = createObservableWithDispose(); Observer<String> observer = createObserver(); observable .observeOn(Schedulers.io()) .subscribeOn(AndroidSchedulers.mainThread()) .subscribe(observer); } @Override protected void onDestroy() { super.onDestroy(); disposable.dispose(); //don't send event anymore } private Observer<String> createObserverWithDispose() { Observer<String> observer = new Observer<String>() { @Override public void onSubscribe(Disposable d) { //assign subscription to dispoable disposable = d; } @Override public void onNext(String s) { } @Override public void onError(Throwable e) { } @Override public void onComplete() { } }; return observer; } private Observable<String> createObservableJust() { Observable<String> observable = Observable.just("Catan", "Splendor", "7 Wonders", "Codenames", "Taboo"); return observable; } } |
| You are visitor 01402520 — GeezerVison does not store the pages you look up. Best viewed with Netscape Navigator 4.7 or Internet Explorer 6 at 800×600. No cookies required. |