Question

下面java改写成kotlin

public static ObservableTransformer schedulersTransformer = new ObservableTransformer() {
@Override
public ObservableSource apply(Observable upstream) {
return ((Observable) upstream).subscribeOn(Schedulers.io())
.unsubscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread());
}
};

Answer 1

修改后：

val schedulersTransformer = object:ObservableTransformer() {
  fun apply(upstream:Observable):ObservableSource {
    return (upstream as Observable).subscribeOn(Schedulers.io())
    .unsubscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
  }
}

追问

报错啊