آموزش اپراتور یا عملگر Just در RxJava

 Observable.just(1, 2, 3, 4, 5, 6, 7, 8, 9, 10)
                 .subscribeOn(Schedulers.io())
                 .observeOn(AndroidSchedulers.mainThread())
                 .subscribe(new Observer() {
                     @Override
                     public void onSubscribe(Disposable d) {
       }

                @Override
                public void onNext(Integer integer) {
                    Log.d(TAG, "onNext: " + integer);
                }

                @Override
                public void onError(Throwable e) {

                }

                @Override
                public void onComplete() {

                }
            });

 Integer[] numbers = {1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12};
Observable.just(numbers)
                 .subscribeOn(Schedulers.io())
                 .observeOn(AndroidSchedulers.mainThread())
                 .subscribe(new Observer() {
                     @Override
                     public void onSubscribe(Disposable d) {
                }

                @Override
                public void onNext(Integer[] integers) {
                    Log.d(TAG, "onNext: " + integers.length);

                    // you might have to loop through the array
                }

                @Override
                public void onError(Throwable e) {

                }

                @Override
                public void onComplete() {

                }
            });