koji
積分 1
關於 click 觸發 IO 不知道會怎寫 :D? 以下示意省略 bind。
ViewObservable.clicks(findViewById(R.id.like_button))
.subscribe(likes -> {
downloadObs().subcribe(/*update ui*/)
});
或是
ViewObservable.clicks(findViewById(R.id.like_button))
.flatmap( ignore -> downloadObs)
.subscribe(/*update ui*/);
但第二種如果下載有丟出例外的話會讓 click 的 source 也停掉不再發事件,不知道有沒建議寫法。
koji
積分 1
雖然就叫 rpc,但好奇 Bidirectional streaming RPC1 可以怎麼 read, write 玩法...
rpc RouteChat(stream RouteNote) returns (stream RouteNote) {}