LiveData와 RxJava에는 많은 차이점이 있습니다.

1. LiveData는 아니다 STREAM RxJava 모든 (문자 그대로 모든)은 인에있는 동안 STREAM .
2. LiveData는 관찰 가능한 데이터 홀더 클래스입니다. 일반 관측 가능 데이터와 달리 LiveData는 수명주기를 인식하므로 활동, 조각 또는 서비스와 같은 다른 앱 구성 요소의 수명주기를 존중합니다. 이러한 인식은 LiveData가 활성 수명주기 상태 인 앱 구성 요소 관찰자 만 업데이트하도록합니다.
3. LiveData는 동기식 이므로 RxJava와 마찬가지로 LiveData 만 사용하여 코드 청크 (네트워크 호출, 데이터베이스 조작 등)를 비동기 적으로 실행할 수 없습니다.
4. 이 듀오를 최대한 활용하기 위해 할 수있는 최선의 방법은 비즈니스 로직 (네트워크 호출, 데이터 조작 등 리포지토리 내외에서 발생하는 모든 작업)에 RxJava를 사용하고 프레젠테이션 계층에 LiveData를 사용하는 것입니다. 이를 통해 비즈니스 로직 및 라이프 사이클 인식 작업을위한 변환 및 스트림 기능을 사용할 수 있습니다.
5. LiveData와 RxJava 는 함께 사용될 경우 서로 보완 합니다. 내 말은 RxJava로 모든 것을하고 UI를 업데이트하려고 할 때 Observable을 LiveData로 변경하려면 아래 주어진 코드와 같은 것을하십시오. 따라서 View (UI)는 LiveData가 변경 불가능한 MutableLiveData이거나 MutableLiveData가 변경 가능한 LiveData 인 ViewModel의 LiveData를 관찰합니다.
6. 여기서 질문은 왜 LiveData를 처음부터 사용해야합니까?
   아래 코드에서 볼 수 있듯이 RxJava에서 MutableLiveData (또는 LiveData) 로의 응답을 저장하고 LiveData는 수명주기를 인식하므로 데이터는 수명주기를 인식합니다. 이제 데이터 자체가 UI 업데이트시기와시기를 알고있을 때의 가능성을 상상해보십시오.
7. LiveData에는 기록이 없습니다 (현재 상태 만). 따라서 채팅 응용 프로그램에 LiveData를 사용해서는 안됩니다.
8. RxJava와 함께 LiveData를 사용하는 경우 MediatorLiveData , SwitchMap 등이 필요하지 않습니다 . 스트림 제어 도구이며 RxJava가 여러 번 향상되어 있습니다.
9. 데이터 홀더로 LiveData를 참조하십시오. 또한 LiveData는 수명주기 인식 소비자라고 말할 수 있습니다.

    public class RegistrationViewModel extends ViewModel {
        Disposable disposable;

        private RegistrationRepo registrationRepo;
        private MutableLiveData<RegistrationResponse> modelMutableLiveData =
                new MutableLiveData<>();

        public RegistrationViewModel() {
        }

        public RegistrationViewModel(RegistrationRepo registrationRepo) {
            this.registrationRepo = registrationRepo;
        }

        public void init(RegistrationModel registrationModel) {
            disposable = registrationRepo.loginForUser(registrationModel)
                    .subscribeOn(Schedulers.io())
                    .observeOn(AndroidSchedulers.mainThread())
                    .subscribe(new Consumer<Response<RegistrationResponse>>() {
                        @Override
                        public void accept(Response<RegistrationResponse>
                                                   registrationModelResponse) throws Exception {

                            modelMutableLiveData.setValue(registrationModelResponse.body());
                        }
                    });
        }

        public LiveData<RegistrationResponse> getModelLiveData() {
            return modelMutableLiveData;
        }

       @Override
       protected void onCleared() {
                super.onCleared();
            disposable.dispose();
         }
    }

답변

class ViewModel : ViewModel() { //Point 1

    var liveData: MutableLiveData<Int> = MutableLiveData()

}

class MainActivity : AppCompatActivity() {

    override fun onCreate(savedInstanceState: Bundle?) {
        super.onCreate(savedInstanceState)
        setContentView(R.layout.activity_main)

        val ViewModelProvider= ViewModelProviders.of(this).get(ViewModel::class.java)

        ViewModelProvider.observe(this, Observer {//Points 2 and 3
            //what you want to observe
        })


        }
    }
}

Observable.just(1, 2, 3, 4, 5, 6) // Point 1

   .subscribe(new Subscriber() {    //Points 2 & 3
       @Override
       public void onCompleted() {
           System.out.println("Complete!");
       }

       @Override
       public void onError(Throwable e) {
       }

       @Override
       public void onNext(Double value) {
           System.out.println("onNext: " + value);
       }
    });