UniRx:入門解説

ちょっとずつ書いていく予定です。
Rxについての解説ではなく、あくまでUniRxの解説です。
間違い/Typoを発見したらコメントください＞＜
UniRxに幸あれ！

- データ => ストリームに流れるデータ
- 回収   => データが来たら後続に流さず、キープしちゃうよ
- 流れ   => ストリームが発火してから各関数がどのように動くかを書くよ

##
- 引数        : 
- url         : 
- 一言で言うと :

流れ
1.

##Sample

• 引数 : TimeSpan
• url : http://rxmarbles.com/#sample
• 一言で言うと :データを何時間毎に流すか決める関数

流れ

1. 内部で引数に指定された時間までのタイマーをセットするよ
2. ストリームを監視し、データが来たら回収するよ
3. 引数に指定された時間が来るまでひたすら2をやるよ
4. (引数に指定された時間が経過してから)2で貯めたデータの中で最新のデータを後続に流すよ
5. 1からやり直すよ

サンプル

this.UpdateAsObservable ().Where (_ => Input.GetMouseButtonDown (0))
	.Select (x => 1)
	.Scan ((a, b) => a + b)
	.Sample (TimeSpan.FromSeconds (1))
	.Subscribe (x => Debug.Log ("累計" + x + "click!とはやるな•••ッ!!"));

##SampleFrame

• 引数 : int
• url :
• 一言で言うと :データを何フレーム毎に流すか決める関数

流れ

1. Sampleと同じ

サンプル

this.UpdateAsObservable ().Where (_ => Input.GetMouseButtonDown (0))
	.Select (x => 1)
	.Scan ((a, b) => a + b)
	.SampleFrame (30)
	.Subscribe (x => Debug.Log ("累計" + x + "click!とはやるな•••ッ!!"));