クックパッドで流しそうめんやったら「そうめんStreamで学ぶRxJava」が盛り上がってる模様

FUJI Goro @__gfx__

流しそうめん in オフィス。世界よ、これがクックパッドだ！ pic.twitter.com/nvP9x8j0xv

拡大

mhidaka@技術書典12 @mhidaka

本気を感じる

FUJI Goro @__gfx__

流しそうめん美味しいです(^q^) pic.twitter.com/j6AFYrx7ee

拡大

Minero Aoki @mineroaoki

ストリームをリアルタイム処理中 pic.twitter.com/1oV4d5T5mZ

拡大

Minero Aoki @mineroaoki

バッチ処理中 pic.twitter.com/NnUHSoh76Z

拡大

KeithYokoma @KeithYokoma

流しそうめんの無限ストリームや！

KeithYokoma @KeithYokoma

SomenProvider.provide().subscribe(somen -> self.eat(somen));

mhidaka@技術書典12 @mhidaka

そうめんストリーム、スループット高いと処理できなさそうｗｗｗ

けいま (Kouta IMANAKA) @pside

クッ社のソーメンStream、onErrorコールされないの

FUJI Goro @__gfx__

rx.Observable<Soumen> だ！

mhidaka@技術書典12 @mhidaka

このストリーム、バッファ0だぞ！！

KeithYokoma @KeithYokoma

SomenProvider.provide().subscribe(somen -> self.eat(somen));

mhidaka@技術書典12 @mhidaka

このストリーム、マルチスレッド対応してるのかな。。。

FUJI Goro @__gfx__

.@mhidaka 残念ながらシングルスレッドです＞＜

mhidaka@技術書典12 @mhidaka

@__gfx__ 複数Streamあつかえても受け手側の処理能力は上がらなさそうなので設計上、正解かと！！

FUJI Goro @__gfx__

@mhidaka subscriberがめっちゃいるのでそこは大丈夫です。ただ、そうめんを茹でるpubliisherの処理能力に限界があるので、やはりマルチスレッドは無理ぽですな。

🥐黒澤🐺 @kurosawa0626

@mhidaka 処理する側がいないと・・・

mhidaka@技術書典12 @mhidaka

@kurosawa0626 あふれちゃう

🥐黒澤🐺 @kurosawa0626

そうめんを茹でるPublisher、そうめんを食べるSubscriber

FUJI Goro @__gfx__

そうめんで学ぶRxJava

mhidaka@技術書典12 @mhidaka

@__gfx__ 思いの外よさそうwww

Yuki Fujisaki / rai @tnj

そうめん食べたいTL

Yuki Fujisaki / rai @tnj

そうめんobservable、最初にsubscribeした人が拾ったら最後後ろの人にはそうめんが渡らないので実装に問題があるのでは

FUJI Goro @__gfx__

@tnj map(Func1<Soumen, Soumen>) でだんだん Soumen#amount() が減っていくのではないか、という議論が社内チャットで行われています。

Yuki Fujisaki / rai @tnj

@__gfx__ ！ なるほどSoumenはCollection……！