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/MultipleObserversActivity.java at master · android-code/libraries Expand file tree/ Copy pathMultipleObserversActivity.javaMore file actions 53 lines (45 loc) · 1.87 KB / Copy pathMultipleObserversActivity.javaFile metadata and controls53 lines (45 loc) · 1.87 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 48 49 50 51 52 53 public class MultipleObserversActivity extends AppCompatActivity { private CompositeDisposable compositeDisposable = new CompositeDisposable(); @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_multiple_observers); Observable<String> observable = createObservable(); DisposableObserver<String> observerGames = createDisposableObserver(); DisposableObserver<String> observerFilteredGames = createDisposableObserver(); compositeDisposable.add(observable .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .subscribeWith(observerGames)); compositeDisposable.add(observable .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .filter(new Predicate<String>() { @Override public boolean test(String s) throws Exception { return s.toLowerCase().startsWith("c"); } }) .subscribeWith(observerFilteredGames)); } @Override protected void onDestroy() { super.onDestroy(); compositeDisposable.clear(); //clear all disposable } private Observable<String> createObservableJust() { Observable<String> observable = Observable.just("Catan", "Splendor", "7 Wonders", "Codenames", "Taboo"); return observable; } private DisposableObserver<String> createDisposableObserver() { DisposableObserver<String> observer = new DisposableObserver<String>() { @Override public void onNext(String s) { } @Override public void onError(Throwable e) { } @Override public void onComplete() { } }; return observer; } } |
| You are visitor 01402503 — 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. |