Reactive Extensions Persuasion part_1

ObservableBufferExample.java

Observable.range(0, 50)
          .buffer(10)
          .subscribe(integers -> {
              Log.d("tag", "list size recevied after buffering: "+integers.size());
          });

ObservableDebounceTimeExample.java

Observable.create(searchEvents)
                .throttle(10, TimeUnit.SECONDS)
                .subscribe(new Consumer<events>() {
                    @Override
                    public void accept(Events events) throws Exception {
                        
                    }
                });

ObservableDistinctExample.java

List<Integer> ints = Arrays.asList(1, 4, 7, 5, 1, 5, 4, 5, 1, 7);
Observable.fromIterable(ints)
                .distinct()
                .filter(integer-> integer % 2 == 0)
                .subscribe();

Observable.create(new ObservableOnSubscribe<String>() {
            @Override
            public void subscribe(ObservableEmitter<String> e) throws Exception {
                for (int i = 0; i > 10; i++) {
                    e.onNext("example No:." + i);
                }
                e.onComplete();
                }
            }).toList()
              .map(new Function<List<String>, String>() {
                @Override
                public String apply(List<String> strings) throws Exception {
                    return strings.toString();
                }
            }).subscribe();

ObservableSchedulerExample.java

Observable.just("Schedulers Test")
                .subscribeOn(Schedulers.computation())
                .subscribeOn(Schedulers.io())
                .subscribeOn(Schedulers.single())
                .subscribeOn(Schedulers.newThread())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Consumer<String>() {
                    @Override
                    public void accept(String s) throws Exception {
                        
                    }
                });