字符串值是如何传递给 updateText() 方法的?
How is the String value passed to the updateText() method?
第一次修改 RxJava
,我创建了一个 Rx 链来监听 String 对象的状态变化:
observable=Observable
.defer(new Callable<ObservableSource<String>>() {
@Override
public ObservableSource<String> call() throws Exception {
return(Observable.just(query()));
}
})
.subscribeOn(Schedulers.io())
.map(this::prettify)
.observeOn(AndroidSchedulers.mainThread())
.cache();
这里美化是:
private String prettify(String raw) {
Gson gson=new GsonBuilder().setPrettyPrinting().create();
JsonElement json=new JsonParser().parse(raw);
return(gson.toJson(json));
}
现在,我创建了 observable
的订阅者:
sub=observable.subscribe(
this::updateText,
error -> Toast
.makeText(getActivity(), error.getMessage(), Toast.LENGTH_LONG)
.show()
);
但我无法理解的是值是如何传递给 updateText
方法的:
private void updateText(String text) {
((TextView)getView().findViewById(R.id.result)).setText(text);
}
updateText
方法很简单,但我的问题是它如何获取字符串值?对此的任何帮助将不胜感激。
这只是 lambda 表达式
sub=observable.subscribe(
this::updateText,
error -> Toast
.makeText(getActivity(), error.getMessage(), Toast.LENGTH_LONG)
.show()
);
在 this::updateText
中调用了您的方法 updateText(String text)
实物加长版的样子
.subscribe( result -> updateText(result), ....
第一次修改 RxJava
,我创建了一个 Rx 链来监听 String 对象的状态变化:
observable=Observable
.defer(new Callable<ObservableSource<String>>() {
@Override
public ObservableSource<String> call() throws Exception {
return(Observable.just(query()));
}
})
.subscribeOn(Schedulers.io())
.map(this::prettify)
.observeOn(AndroidSchedulers.mainThread())
.cache();
这里美化是:
private String prettify(String raw) {
Gson gson=new GsonBuilder().setPrettyPrinting().create();
JsonElement json=new JsonParser().parse(raw);
return(gson.toJson(json));
}
现在,我创建了 observable
的订阅者:
sub=observable.subscribe(
this::updateText,
error -> Toast
.makeText(getActivity(), error.getMessage(), Toast.LENGTH_LONG)
.show()
);
但我无法理解的是值是如何传递给 updateText
方法的:
private void updateText(String text) {
((TextView)getView().findViewById(R.id.result)).setText(text);
}
updateText
方法很简单,但我的问题是它如何获取字符串值?对此的任何帮助将不胜感激。
这只是 lambda 表达式
sub=observable.subscribe(
this::updateText,
error -> Toast
.makeText(getActivity(), error.getMessage(), Toast.LENGTH_LONG)
.show()
);
在 this::updateText
中调用了您的方法 updateText(String text)
实物加长版的样子
.subscribe( result -> updateText(result), ....