یک مثال ساده از آموزش RXJava در اندروید و برنامه نویسی reactive در اندروید :

۱ . در گوگل سرچ کنید :

rxandroid github

۲ . لینک زیر را باز کنید :

ReactiveX/RxAndroid: RxJava bindings for Android – GitHub

در اینجا میتوانید توضیحات مفصل RXJava و برنامه نویسی reactive در اندروید را مشاهده کنید .

۳ . یک پروژه جدید ایجاد کنید و کتابخانه های زیر را به گردل مربوط به پروژه اضاف کنید :

توجه : ورژن این ۲ کتابخانه بستگی به زمان استفاده شما دارد .

implementation 'io.reactivex.rxjava2:rxandroid:2.1.1'
implementation 'io.reactivex.rxjava2:rxjava:2.2.9'

۴ . طراحی لی اوت (activity_main.xml) :

فایل لی اوت را به شکل زیر طراحی کنید .

<?xml version="1.0" encoding="utf-8"?>
<RelativeLayout
    xmlns:android="http://schemas.android.com/apk/res/android"
    xmlns:tools="http://schemas.android.com/tools"
    android:layout_width="match_parent"
    android:layout_height="match_parent"
    tools:context=".MainActivity">

    <TextView
        android:id="@+id/txt"
        android:text="Click Button To Subscribe"
        android:textSize="24sp"
        android:textStyle="bold"
        android:layout_marginTop="80dp"
        android:layout_marginLeft="40dp"
        android:layout_marginRight="40dp"
        android:layout_width="match_parent"
        android:layout_height="wrap_content" />

    <Button
        android:id="@+id/subscribe"
        android:text="subscribe"
        android:onClick="subscribeNow"
        android:layout_marginTop="160dp"
        android:layout_marginLeft="40dp"
        android:layout_marginRight="40dp"
        android:layout_width="match_parent"
        android:layout_height="wrap_content" />

</RelativeLayout>

۵ . کدهای مربوط به (MainActivity.java) :

package elecomco.com.rxjavaapp;

import android.support.v7.app.AppCompatActivity;
import android.os.Bundle;
import android.view.View;
import android.widget.TextView;

import io.reactivex.Observable;
import io.reactivex.Observer;
import io.reactivex.disposables.Disposable;

public class MainActivity extends AppCompatActivity {


    private TextView txt;

    private Observable<String> mObservable;
    private Observer<String> mObserver;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

        txt=findViewById(R.id.txt);

        mObservable=Observable.just("Hello from RXandroid");
        mObserver=new Observer<String>() {
            @Override
            public void onSubscribe(Disposable d) {

            }

            @Override
            public void onNext(String s) {
                txt.setText(s);
            }

            @Override
            public void onError(Throwable e) {

            }

            @Override
            public void onComplete() {

            }
        };


    }

    public void subscribeNow(View view){
        mObservable.subscribe(mObserver);
    }

}

۶ . اجرای برنامه :

توضیحات :

تعریف های متغیرهای زیر برای Observable و Observer کردن :

private Observable mObservable;

private Observer mObserver;

تعریف تابع subscribeNow برای سابسکرایب کردن :

public void subscribeNow(View view){
mObservable.subscribe(mObserver);
}

توسط تابع just رشته Hello from RXandroid را هنگام سابسکرایب کردن در TextView مربوطه نمایش میدهیم .

برای اینکار در متد onNext متن مربوطه را تنظیم میکنیم .

در آخر با کلیک دکمه متن مربوطه با سابسکرایب کردن نمایش داده میشود .

آموزش کامل rxjava در اندروید و برنامه نویسی reactive به همراه معماری MVP و کار با آنها در کنار هم ، در دوره یادگیری اندروید استودیو  به صورت کامل با انجام یک پروژه حرفه ای ، آموزش داده شده است. برای خرید این دوره می توانید روی آن کلیک کنید و به یک برنامه نویس اندروید حرفه ای تبدیل شوید.

دوره های آموزش برنامه نویسی اندروید الکامکو

در صورتیکه سوالی در این زمینه دارید می توانید با ما در میان بگذارید.