尝试使用 RetrofitClient 并订阅，但在使用 Kotlin 时遇到问题

Question

我正在尝试设置用户注册和登录，并且一直在关注 youtube 上的教程 (https://www.youtube.com/watch?v=4Xq2FUJvE-c)

我也在从 java 过渡到 kotlin，同时学习 android 编程而不是桌面，所以对我来说有很多新东西。无论如何，我想复制代码：

  compositeDisposable.add(iMyService.loginUser(email,password)
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Consumer<String>() {
                     @Override
                     public void accept(String response) throws Exception {
                     Toast.makeText(Mainactivity.this,""+response,
                           Toast.LENGTH_SHORT).show();
                     }
                }));

在 Kotlin 我有：

    compositeDisposable.add(iMyService.loginUser(email,password)
        .subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(Consumer<String>() {

        }))

不确定如何继续并填写其余部分。我对订阅方法不熟悉

Answer 1

在 Kotlin 中会是这样的：

compositeDisposable.add(iMyService.loginUser(email,password)
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
     .subscribe({ response: String ->
           Toast.makeText(context, response, Toast.LENGTH_SHORT).show()
      }, { t: Throwable? ->
      })

你可以参考这个链接：https://www.raywenderlich.com/384-reactive-programming-with-rxandroid-in-kotlin-an-introduction