Rx談義 20111208

尾上 雅則 @ugaya40

@okazuki @neuecc あー挙動の違いがひどいからSubjectをPublishに渡すように変更になったんですかね。

尾上 雅則 @ugaya40

ConnectableObservableを見てて理解した気になったけど、果たして本当に理解しているのか謎

尾上 雅則 @ugaya40

ConnectableObservableはConnectした時点で流れてくるソースの値をsubjectにSubscribeする(流す)。ConnectableObservableをSubscribeするとsubject自体がSubscribeされる。これがPublishか。

尾上 雅則 @ugaya40

なるほど。

かずき(Kazuki Ota) | Cloud Solution Architect at MS @okazuki

@ugaya40 @neuecc あー、どうなんでしょうね？そこらへんは、日本のRxの生き字引の、のいえさんが起きる10:50くらいまで待つしか無いですね。

neuecc @neuecc

@ugaya40 @okazuki Rangeだけで検証していると陥りがちですが、イベントとか無限リストも踏まえないとダメです。あと、OnCompletedは必ず来るものではないわけなので、Subjectを検証するにあたり、OnCompletedを実行後と考えるのもよくないです。

neuecc @neuecc

@ugaya40 @okazuki BehaviorSubject(を使ったPublish)は完全に無限リスト向けでしょう、具体的にイメージするなら初期値付きイベント。AsyncSubjectはTPLを分かっているのならTaskCompletionSourceそのものです。

neuecc @neuecc

@ugaya40 @okazuki 同じメソッド名という点ではPublishのオーバーロードはイベントor初期値付きイベントなので、そんな不自然ではないかなあ、と。PublishLastは別のメソッド名ですよね(以前のPruneというイミフな名前よりはずっといいかと！)。

neuecc @neuecc

@ugaya40 @okazuki 「挙動の違いがひどいからSubjectをPublishに渡すように変更になったんですかね。」というのは、文面が何を指して何を言っているのか分からないです。SubjectをPublishに渡す……？変更？。といったところでしょーか。

尾上 雅則 @ugaya40

@neuecc @okazuki 最初はOnCompleted実行後とか考えてなかったんですが、AsyncSubjectがOnCompleted後じゃないと値が流れないのを気づけず、そこを@okazukiさんに指摘を受けたので入れました。

尾上 雅則 @ugaya40

@neuecc @okazuki PublishがSubjectを受けるように変更云々は、@neueccさんの１年前のこの記事です http://t.co/yZRdKFaC

neuecc @neuecc

@ugaya40 あー、すみません、 http://t.co/yKoM4NSR ですね、見落としてました。

尾上 雅則 @ugaya40

@neuecc PublishとPublishLastが違うメソッド名なのはわかりますが、同じPublishってつくのに、Connect後にSubscribeしたものでも値が取れるのが気になったんですー。初期値付きかそうでないかははい。

尾上 雅則 @ugaya40

@neuecc @okazuki BehaviorSubjectとか、IO二つのinterfaceを使った基本実装とか、今夜見てみるつもりです。お時間の無いところありがとうございました＞＜

尾上 雅則 @ugaya40

AsyncSubjectの用途である、非同期を模す＝OnNext()OnCompleted()がセット、つまりOnCompletedまで値を流さなくても問題ない、か。

尾上 雅則 @ugaya40

Rxでクリシミマス

neuecc @neuecc

@ugaya40 柔軟性の確保(野良Subject対応とか)のためにMulticastを追加したらPublishの意義が微妙になったので、ついでに、APIを整理しただけかなー、と。とはいえ、その変更もまた翌月に一瞬で消滅しましたね。

neuecc @neuecc

@ugaya40 引数にラムダを受け取る(外部変数を用意する必要がなくConnect)PublishとMulticast、に分けたわけですが、すぐに再変更かかったのは、結局のとこ一々Subjectをnewするのが激しく面倒くさかった(&匿名型に対応できない)からな感。