R3 オペレーター/ファクトリーメソッド まとめ

# この記事について

次世代Rxである[R3](https://github.com/Cysharp/R3)に登場するオペレーターおよびファクトリーのまとめ記事です。

R3自体はフレームワークに依存せずにピュアなC#で用いることができるライブラリです。
ですが本記事では **UniRxとの比較を行うためにUnity上でR3を動作させています。** 


## 執筆環境

- Unity 6.0.30f1
- R3/R3.Unity Ver.1.3.0
- UniRx Ver.7.1.0
- UniTask Ver.2.5.10

## サンプルプロジェクト

オペレーターおよびファクトリーの動作説明のために用意したサンプルプロジェクトがあります。

* [R3_Factories_and_Operators_Samples](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples)

また一部のオペレーターの動作確認を行えるDEMOを作成してあります。

* [動作確認用のDEMO](https://torisoup.github.io/R3_Factories_and_Operators_Samples/)


# R3について

## 概要

R3についての解説は以前に執筆しているのでこちらを御覧ください。

- [次世代Rx「R3」解説](https://qiita.com/toRisouP/items/e7be5a5a43058556db8f)

## 概念・用語集

本記事で登場する単語について解説が必要そうなものを取り上げて紹介します。

|用語|意味|補足|
|:--|:--|:--|
|`Observable`|RxやR3における中核となる概念・オブジェクト。イベントメッセージを伝達し途中にオペレーターを介することでメッセージの加工ができる存在。イベントシーケンスやイベントストリームなどと呼ばれることもある。|いわゆる「`Subscribe()`して使うヤツ」のこと|
|`Observer`|`Observable`に登録してメッセージを受信する側のオブジェクトのこと。||
|オペレーター|Operator。`Observable`に連結してメッセージの加工や挙動の変更を行うことができる仕組み。||
|ファクトリー|Factory、ファクトリーメソッド。`Observable`を生成するためのstaticなメソッド群のこと。|
|購読/購読する|`Observable`に`Observer`を登録してメッセージの受信体制を構築すること。その処理の代表格が`Subscribe()`なので「Subscribeする」という言い回しを使うこともある。|なお`ForEachAsync()`や`~Async()`なども`Subscribe()`と同等の処理を行っている。そのため「購読する」「Subscribeする」といった言い回しをした場合はこれらオペレーターも含んでいる。とにかく「`Observable`に`Observer`を登録する処理」を引っくるめてこう呼ぶ。|
|メッセージ|R3の`Observable`で扱われる`OnNext`/`OnErrorResume`/`OnCompleted`のこと。文脈に寄っては`OnNext`単体を指すこともある。|`Observable`を流れてくるイベントメッセージのこと。|
|`OnNext`|`Observable`で扱われる常用のメッセージのこと。``Observable<T>``の`T`の部分。||
|`OnErrorResume`|`Observable`で扱われるエラー通知用のメッセージのこと。`OnErrorResume`は発行されたとしても`Observable`の動作は継続する。|UniRxでは`OnError`の発行をもって`Observable`は解体されていた。|
|`OnCompleted`|`Observable`で扱われる`Observable`の動作完了用のメッセージのこと。内容によって正常終了と異常終了のどちらかを表現できる。|中身が空なら正常終了。例外が入っていた場合は異常終了。|
|完了/完了する|`OnCompleted`のうち正常終了の方のメッセージが発行されて`Observable`が動作を停止すること。|「`Task`が完了する」という場合もだいたい同じ意味。|
|異常終了|`OnCompleted`のうち異常終了の方のメッセージが発行されて`Observable`が動作を停止すること。「`OnCompleted(Exception)`が発行される」もこの意味と同じ。||


# R3のオペレーター一覧

R3のオペレーターを列挙して説明します。

「UniRx」の項目はUniRxに同じ動作をするオペレーターが存在する場合に記載しています。(括弧)で包まれている場合は「似てるけどちょっと違うもの」を挙げています。

また **オペレーター名の列からそのオペレーターを実際に動作させているサンプルコード（テストコード）に飛ぶことができます。**

## 変換系

`OnNext`の内容を変化させるものをここにまとめています。

|R3|UniRx|機能|一言でまとめると|戻り値|
|:----|:----|:----|:----|:----|
|[AsUnitObservable](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/AsUnitObservableTest.cs)|AsUnitObservable|`Observable<Unit>`に変換する。|型の情報を落とす|`Observable<Unit>`|
|[Cast](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/CastTest.cs)|Cast|OnNextの型を指定した型にキャストする。OfTypeに似ているが、こちらはキャストできない場合はOnErrorResumeが発行される。|型変換する|`Observable<TResult>`|
|[Chunk](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/ChunkTest.cs)|Buffer|発行されたOnNextの中身を指定した個数でまとめて1つのOnNextとして発行する。まとめる必要がない場合はThrottleLastでも良い。|まとめる|`Observable<T[]>`
|[Chunk](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/ChunkTest.cs)|Buffer|発行されたOnNextの中身を指定した時間区間でまとめて1つのOnNextとして発行する。時間のカウントはOnNextが発行されたタイミングでスタートする。まとめる必要がない場合はThrottleLastでも良い。|まとめる| `Observable<T[]>`
|[Chunk](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/ChunkTest.cs)|Buffer|発行されたOnNextをまとめて、別のObservableのOnNextタイミングで1つのOnNextとして発行する。|まとめる|`Observable<T[]>`
|[ChunkFrame](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/ChunkFrameTest.cs)|BatchFrame|指定したUnityのフレーム区間内に発行されたOnNextをまとめて1つのOnNextして発行する。|まとめる|`Observable<T[]>`
|[ChunkUntil](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/ChunkUntilTest.cs)|-|発行されたOnNextの中身を条件を満たすまでまとめ1つのOnNextとして発行する。|まとめる| `Observable<T[]>`
|[FrameCount](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/FrameCountTest.cs)|-|OnNextが発行されたときに、それが何フレーム目に発行されたのかとセットにする。何フレーム目であるかはFrameProviderによって定まる。|時間を測る|`Observable<(long, T)>`
|[FrameInterval](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/FrameIntervalTest.cs)|FrameInterval|OnNextが発行されたときに、1つ前のOnNext発行から何フレーム経過しているかとセットにする。フレーム数のカウントはFrameProviderによって定まる。|時間を測る|`Observable<(long, T)>`
|[Index](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/IndexTest.cs)|(Select)|OnNextメッセージにIndexを振る。|採番する|`Observable<(int, T)>`
|[Pairwise](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/PairwiseTest.cs)|Pairwise|現在のOnNextの値と、その１つ前のOnNextの値をペアにする。|直前の値と最新の値を取り出す|`Observable<(T, T)>`
|[Scan](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/ScanTest.cs)|Scan|OnNextが発行されるたびに畳み込み(fold)計算を行いその結果をOnNextとして発行する。AggregateAsyncに似ているが、こちらは型が`Observable<T>`である。|畳み込む|`Observable<T>`|
|[Select](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/SelectTest.cs)|Select|OnNextの値を用いて処理を実行しその結果に内容を差し替える。|変換する|`Observable<T>`|
|[SelectAwait](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/SelectAwaitTest.cs)|-|OnNextの値を用いて非同期処理を実行しその結果待って新しいOnNextとして発行する。指定するAwaitOperationで挙動が変化する。|変換する|`Observable<T>`|
|[SelectMany](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/SelectManyTest.cs)|SelectMany|`Observable<T>`から新たな`Observable<TResult>`を生成し、それを並列に合成する。|変換する、flatMap|`Observable<TResult>`|
|[TimeInterval](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/TimeIntervalTest.cs)|TimeInterval/FrameTimeInterval|直前のOnNextと今のOnNextの時間間隔を計測し、結果をまとめてOnNextとして発行する。|時間を測る|`Observable<(TimeSpan, T)>`|
|[Timestamp](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/TimestampTest.cs)|(Tmestamp)|OnNextにタイムスタンプを付与する。タイムスタンプはTimeProvider.GetTimestapmの値である。|時間を測る|`Observable<(long, T)>`


## フィルタ系

メッセージのフィルタリングを行うものをここにまとめています。

|R3|UniRx|機能|一言でまとめると|戻り値|
|:----|:----|:----|:----|:----|
|[Debounce](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/DebounceTest.cs)|Throttle|メッセージの流量を減らす。OnNextがまとめて発行されたときに、最後に値が発行されてから一定時間経過後に最後のOnNextを1つだけ発行する。|流量を絞る|`Observable<T>`|
|[Debounce](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/DebounceTest.cs)|-|メッセージの流量を減らす。OnNextがまとめて発行されたときに、非同期処理を実行し完了時に最後のOnNextを1つだけ発行する。|流量を絞る|`Observable<T>`|
|[DebounceFrame](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/DebounceFrameTest.cs)|ThrottleFrame|メッセージの流量を減らす。OnNextがまとめて発行されたときに、最後に値が発行されてから一定フレーム経過後に最後のOnNextを1つだけ発行する。|流量を絞る|`Observable<T>`|
|[Distinct](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/DistinctTest.cs)|Distinct|OnNextから重複した値のメッセージを除外する。|重複削除|`Observable<T>`|
|[DistinctBy](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/DistinctByTest.cs)|Distinct|OnNextの値を用いて加工を行い、その結果として重複したメッセージを除外する。|重複削除|`Observable<T>`|
|[DistinctUntilChanged](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/DistinctUntilChangedTest.cs)|DistinctUntilChanged|OnNextから連続で重複した値のメッセージを除外する。|連続した重複を削除|`Observable<T>`|
|[DistinctUntilChangedBy](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/DistinctUntilChangedByTest.cs)|DistinctUntilChanged|OnNextの値を用いて加工を行い、その結果として連続で重複したメッセージを除外する。|連続した重複を削除|`Observable<T>`|
|[IgnoreElements](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/IgnoreElementsTest.cs)|IgnoreElements|OnNextを無視する。|無視する|`Observable<T>`|
|[IgnoreOnErrorResume](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/IgnoreOnErrorResumeTest.cs)|(CatchIgnore)|OnErrorResumeを無視する。|無視する|`Observable<T>`|
|[OfType](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/OfTypeTest.cs)|OfType|OnNextの型を指定した型にキャストする。Castと似ているが、こちらは型変換ができない場合は無視される。|型変換する|`Observable<TResult>`|
|[Skip](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/SkipTest.cs)|Skip|購読開始から指定した個数のOnNextを無視する。|OnNextを無視する|`Observable<T>`|
|[Skip](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/SkipTest.cs)|Skip|購読開始から指定した時間OnNextを無視する。|OnNextを無視する|`Observable<T>`|
|[SkipFrame](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/SkipFrameTest.cs)|-|購読開始から指定したフレーム間のOnNextを無視する。|OnNextを無視する|`Observable<T>`|
|[SkipLast](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/SkipLastTest.cs)|-|Observable完了時に最後から指定した時間のOnNextを無視する。|OnNextを無視する|`Observable<T>`|
|[SkipLastFrame](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/SkipLastFrameTest.cs)|-|Observable完了時に最後から指定したフレーム間のOnNextを無視する。|OnNextを無視する|`Observable<T>`|
|[SkipUntil](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/SkipUntilTest.cs)|-|非同期処理が完了するまでの間はOnNextメッセージを無視し続ける。|OnNextを無視する|`Observable<T>`|
|[SkipUntil](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/SkipUntilTest.cs)|-|CancellationTokenがキャンセルされるまでの間はOnNextメッセージを無視し続ける。|OnNextを無視する|`Observable<T>`|
|[SkipUntil](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/SkipUntilTest.cs)|SkipUntil|他のObservableのOnNextが到達するまでの間はOnNextメッセージを無視し続ける。|OnNextを無視する|`Observable<T>`|
|[SkipWhile](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/SkipWhileTest.cs)|SkipWhile|OnNextメッセージが条件を満たす間はOnNextを無視し続ける。一度条件を満たさなくなったらそれ以降のOnNextはすべて通過させる。|OnNextを無視する|`Observable<T>`|
|[Take](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/TakeTest.cs)|Take|購読開始から指定した個数のOnNextを通過させ、指定数を超えたらOnCompletedを発行する。|最初の方の値を取り出す|`Observable<T>`|
|[Take](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/TakeTest.cs)|Take|購読開始から指定した時間OnNextを通過させ、その時間を超えたらOnCompletedを発行する。|最初の方の値を取り出す|`Observable<T>`|
|[TakeFrame](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/TakeFrameTest.cs)|-|購読開始から指定したフレーム間OnNextを通過させ、そのフレーム数を超えたらOnCompletedを発行する。|最初の方の値を取り出す|`Observable<T>`|
|[TakeLast](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/TakeLastTest.cs)|TakeLast|OnCompletedが発行されたときに最後から指定した個数のOnNextのみを取り出して発行する。|最後の方の値を取り出す|`Observable<T>`|
|[TakeLast](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/TakeLastTest.cs)|TakeLast|OnCompletedが発行されたときに最後から指定した時間以内のOnNextのみを取り出して発行する。|最後の方の値を取り出す|`Observable<T>`|
|[TakeLastFrame](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/TakeLastFrameTest.cs)|-|OnCompletedが発行されたときに最後から指定したフレーム数以内のOnNextのみを取り出して発行する。|最後の方の値を取り出す|`Observable<T>`|
|[ThrottleFirst](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/ThrottleFirstTest.cs)|ThrottleFirst|OnNextが発行されたらまずそれを通過させ、その次以降のOnNextを遮断する。遮断状態は一定時間経過で解除される。|流量を絞る|`Observable<T>`|
|[ThrottleFirst](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/ThrottleFirstTest.cs)|-|OnNextが発行されたらまずそれを通過させ、その次以降のOnNextを遮断する。遮断状態は別のObservableからOnNextが発行されたら解除される。|流量を絞る|`Observable<T>`|
|[ThrottleFirst](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/ThrottleFirstTest.cs)|-|OnNextが発行されたらまずそれを通過させ、非同期処理を実行する。その非同期処理が完了するまでの間OnNextを遮断する。|流量を絞る|`Observable<T>`|
|[ThrottleFirstFrame](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/ThrottleFirstFrameTest.cs)|ThrottleFirstFrame|OnNextが発行されたら次以降のOnNextを遮断する。遮断状態は一定フレーム経過で解除される。|流量を絞る|`Observable<T>`|
|[ThrottleFirstLast](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/ThrottleFirstLastTest.cs)|-|OnNextが発行されたらまずそれを通過させ、一定時間の間OnNextを遮断する。遮断期間中に発行されたOnNextがあった場合は、遮断期間終了時にその最後のものを1つ発行する。|流量を絞る|`Observable<T>`|
|[ThrottleFirstLast](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/ThrottleFirstLastTest.cs)|-|OnNextが発行されたらまずそれを通過させ、、それ以降のOnNextを遮断する。指定した別のObservableからOnNextが発行されると遮断は解除される。遮断中に発行されたOnNextがあった場合は、遮断期間終了時にその最後のものを1つ発行する。|流量を絞る|`Observable<T>`|
|[ThrottleFirstLast](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/ThrottleFirstLastTest.cs)|-|OnNextが発行されたらまずそれを通過させ、、非同期処理を実行しその実行中はそれ以降のOnNextを遮断する。遮断期間中に発行されたOnNextがあった場合は、遮断期間終了時にその最後のものを1つ発行する。|流量を絞る|`Observable<T>`|
|[ThrottleFirstLastFrame](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/ThrottleFirstLastFrameTest.cs)|-|OnNextが発行されたら次以降のOnNextを遮断する。遮断状態は一定フレーム経過で解除される。遮断期間中に発行されたOnNextがあった場合は、遮断期間終了時にその最後のものを1つ発行する。|流量を絞る|`Observable<T>`|
|[ThrottleLast](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/ThrottleLastTest.cs)|Sample|OnNextが発行されたらそれを含め一旦すべてのOnNextを遮断する。遮断状態は一定時間経過で解除され、解除時に一番最後に発行されていたOnNextを１つ発行する。Chunkに似ているがこちらは値をまとめることはない。|流量を絞る|`Observable<T>`|
|[ThrottleLast](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/ThrottleLastTest.cs)|Sample|OnNextが発行されたらそれを含め一旦すべてのOnNextを遮断する。別のObservableを指定しそのObservableからOnNextが発行されると遮断状態は解除される。解除時に一番最後に発行されていたOnNextを１つ発行する。Chunkに似ているがこちらは値をまとめることはない。|流量を絞る|`Observable<T>`|
|[ThrottleLast](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/ThrottleLastTest.cs)|-|OnNextが発行されたらそれを含め一旦すべてのOnNextを遮断し、非同期処理を実行する。その非同期処理が完了すると遮断状態は解除される。解除時に一番最後に発行されていたOnNextを１つ発行する。|流量を絞る|`Observable<T>`|
|[ThrottleLastFrame](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/ThrottleLastFrameTest.cs)|SampleFrame|OnNextが発行されたらそれを含め一旦すべてのOnNextを遮断する。遮断状態は一定フレーム経過で解除され、解除時に一番最後に発行されていたOnNextを１つ発行する。ChunkFrameに似ているがこちらは値をまとめることはない。|流量を絞る|`Observable<T>`|
|[Where](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/WhereTest.cs)|Where|OnNextの値を条件でフィルタリングする。|フィルタリングする|`Observable<T>`|
|[WhereAwait](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/WhereAwaitTest.cs)|-|OnNextの値を条件でフィルタリングする。その際の条件判定に非同期処理を用いることができる。指定するAwaitOperationで挙動が変化する。|フィルタリングする|`Observable<T>`|
|[WhereNotNull](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/WhereNotNullTest.cs)|-|Observable<T?>に対し、値がnullでない場合のみにフィルタリングする。|フィルタリングする|`Observable<T>`|



## 時間や実行コンテキストの制御系

メッセージの発行タイミングや、実行コンテキスト（スレッド）などを変化させるものをここにまとめています。

|R3|UniRx|機能|一言でまとめると|戻り値|
|:----|:----|:----|:----|:----|
|[Delay](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/DelayTest.cs)|Delay|発行されたすべての種別のメッセージを指定時間だけ遅延させる。|遅延させる|`Observable<T>`|
|[DelayFrame](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/DelayFrameTest.cs)|DelayFrame|発行されたすべての種別のメッセージを指定フレームだけ遅延させる。|遅延させる|`Observable<T>`|
|[DelaySubscription](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/DelaySubscriptionTest.cs)|DelaySubscription|Subscribeの実行を指定時間だけ遅延させる。|遅延して購読する|`Observable<T>`|
|[DelaySubscriptionFrame](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/DelaySubscriptionFrameTest.cs)|DelayFrameSubscription|Subscribeの実行を指定フレームだけ遅延させる。|遅延して購読する|`Observable<T>`|
|[ObserveOn](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/ObserveOnTest.cs)|ObserveOn|Observableの実行コンテキストを別のコンテキストに変更する。実行スレッドを変更したり、別のタイミングに移したりできる。|実行コンテキストを変える|`Observable<T>`|
|[ObserveOnCurrentSynchronizationContext](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/ObserveOnCurrentSynchronizationContextTest.cs)|-|Observableの実行コンテキストをSynchronizationContextを用いて変更する。SynchronizationContextはObserveOnCurrentSynchronizationContextを呼び出したタイミングにおけるSynchronizationContext.Currentが用いられる。SynchronizationContext.Currentがnullの場合はスレッドプールで代用される。|実行コンテキストを変える|`Observable<T>`|
|[ObserveOnMainThread](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/ObserveOnMainThreadTest.cs)|ObserveOnMainThread|Unity専用。Observableの実行コンテキストをUnityメインスレッドに変更する。|実行コンテキストを変える|`Observable<T>`|
|[ObserveOnThreadPool](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/ObserveOnThreadPoolTest.cs)|ObserveOn|Observableの実行コンテキストをThreadPoolに変更する。|実行コンテキストを変える|`Observable<T>`|
|[SubscribeOn](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/SubscribeOnTest.cs)|SubscribeOn|「Subscribe()の内部処理」の実行コンテキストを指定できる。「Subscribe()の内部処理」とはObservableにObserverを登録し各Operatorが初期化される一連の処理のことを指す。発行されるメッセージの実行コンテキストを切り替えたいときはObserveOnを使うべき。|購読のコンテキストを変える|`Observable<T>`|
|[SubscribeOnCurrentSynchronizationContext](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/SubscribeOnCurrentSynchronizationContextTest.cs)|-|「Subscribe()の内部処理」を現在の実行コンテキスト上のSynchronizationContextを指定して行う。「Subscribe()の内部処理」とはObservableにObserverを登録し各Operatorが初期化される一連の処理のことを指す。|購読のコンテキストを変える|`Observable<T>`|
|[SubscribeOnMainThread](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/SubscribeOnMainThreadTest.cs)| |「Subscribe()の内部処理」をメインスレッド上で行う。「Subscribe()の内部処理」とはObservableにObserverを登録し各Operatorが初期化される一連の処理のことを指す。|購読のコンテキストを変える|`Observable<T>`|
|[SubscribeOnSynchronize](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/SubscribeOnSynchronizeTest.cs)|-|「Subscribe()の内部処理」の実行に排他ロックをかける。「Subscribe()の内部処理」とはObservableにObserverを登録し各Operatorが初期化される一連の処理のことを指す。|購読のコンテキストを変える|`Observable<T>`|
|[SubscribeOnThreadPool](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/SubscribeOnThreadPoolTest.cs)| |「Subscribe()の内部処理」をスレッドプール上で行う。「Subscribe()の内部処理」とはObservableにObserverを登録し各Operatorが初期化される一連の処理のことを指す。|購読のコンテキストを変える|`Observable<T>`|



## Observableの性質変化系

`Observable`そのものの挙動を変化させるものをここにまとめています。

|R3|UniRx|機能|一言でまとめると|戻り値|
|:----|:----|:----|:----|:----|
|[Append](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/AppendTest.cs)|-|OnCompleted発行時に、Observableの最後に指定された値を挿入する。|最後に足す|`Observable<T>`|
|[DefaultIfEmpty](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/DefaultIfEmptyTest.cs)|DefaultIfEmpty|OnNextが一度も発行されずにObservableが完了したときに、値を１つだけ発行する。|空のときの処理を足す|`Observable<T>`|
|[OnErrorResumeAsFailure](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/OnErrorResumeAsFailureTest.cs)|-|OnErrorResumeをOnCompleted(Exception)に変換する。|異常終了にする|`Observable<T>`|
|[Prepend](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/PrependTest.cs)|StartWith|Observableの購読直後に指定した値を挿入する。|最初に足す|`Observable<T>`|
|[TakeUntil](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/TakeUntilTest.cs)|TakeUntil|指定した別のObservableのOnNextが到達した場合にOnCompletedを発行し本流の購読を打ち切る。|購読を止める条件を追加する|`Observable<T>`|
|[TakeUntil](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/TakeUntilTest.cs)|TakeUntil|OnNextの値が条件を満たしたときにOnCompletedを発行して購読を打ち切る。|購読を止める条件を追加する|`Observable<T>`|
|[TakeUntil](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/TakeUntilTest.cs)|-|CancellationTokenがキャンセルされたときにOnCompletedを発行して購読を打ち切る。|購読を止める条件を追加する|`Observable<T>`|
|[TakeUntil](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/TakeUntilTest.cs)|-|非同期処理の完了を待機し、その完了時にOnCompletedを発行して購読を打ち切る。|購読を止める条件を追加する|`Observable<T>`|
|[TakeWhile](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/TakeWhileTest.cs)|TakeWhile|OnNextが条件を満たし続ける間、OnNextを通過させ続ける。条件を満たさないOnNextが発行されるとOnCompletedを発行し購読を打ち切る。|購読を止める条件を追加する|`Observable<T>`|
|[Timeout](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/TimeoutTest.cs)|(Timeout)|OnNextの発行間隔が指定したTimeSpan以上開いたときにOnCompleted(TimeoutException)を発行してObservableを異常終了させる。|タイムアウト条件を足す|`Observable<T>`|
|[TimeoutFrame](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/TimeoutFrameTest.cs)|(TimeoutFrame)|OnNextの発行間隔が指定したフレーム間隔以上開いたときにOnCompleted(TimeoutException)を発行してObservableを異常終了させる。|タイムアウト条件を足す|`Observable<T>`|
|[Trampoline](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/TrampolineTest.cs)|ObserveOn(Scheduler.CurrentThread)|Observableのメッセージが再帰した際に末尾再帰に変換する。|末尾再帰にする|`Observable<T>`|


## Observableの合成系

複数の`Observable`を用いて1つの`Observable`を構築するものをここにまとめています。

|R3|UniRx|機能|一言でまとめると|戻り値|
|:----|:----|:----|:----|:----|
|[Amb](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/AmbTest.cs)|Amb|2つのObservableを同時に購読し、OnNextが先着した方のObservableのみを採択する。|先着したものを使う|`Observable<T>`|
|[Catch](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/CatchTest.cs)|Catch|購読中のObservableからOnCompleted(Exception)が発行された場合、指定したObservableに購読先を切り替える。|異常終了の対応|`Observable<T>`|
|[CombineLatest](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/CombineLatestTest.cs)|CombineLatest|複数のObservableの入力のうち、それぞれ最新のものをセットにして1つのOnNextとして発行する。|複数のObservableをまとめる|`Observable<TResult>`|
|[Concat](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/ConcatTest.cs)|Concat|OnCompleted発行時に次のObservableに購読先を切り替える（Observableを直列に合成する）。|直列に連結する|`Observable<T>`|
|[Merge](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/MergeTest.cs)|Merge|2つのObservableのメッセージを混ぜて1つのObservableとして扱う（Observableを並列に合成する）。|並列合成|`Observable<T>`
|[Switch](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/SwitchTest.cs)|Switch|Observable<`Observable<T>`>に対してのみ利用可能。新しく発行された`Observable<T>`に対して購読を次々に乗り換えることができる。|購読先を切り替える|`Observable<T>`|
|[WithLatestFrom](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/WithLatestFromTest.cs)|WithLatestFrom|メインとなるObservableにOnNextが入力されたタイミングで別のObservableの最新値と合成して出力する。サブObservable側に一度もOnNextが発行されていない場合は何も出力されない。|２つのObservableを合成する|`Observable<TResult>`|
|[Zip](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/ZipTest.cs)|Zip|複数のObservableの入力をキューにつめて、揃ったものから順次1つのOnNextとして発行する。|複数のObservableをまとめる|`Observable<TResult>`|
|[ZipLatest](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/ZipLatestTest.cs)|ZipLatest|複数のObservableの入力のうち最新のものを1つだけ保持し、揃ったものから順次1つのOnNextとして発行する。CombineLatestとの違いはこちらは一度発行した値は再利用されない。|複数のObservableをまとめる|`Observable<TResult>`|


## Hot変換系

Hot変換目的のものをここにまとめています。Hot変換については過去に記事としてまとめているのでこちらをご参照ください。

* [【Reactive Extensions】 Hot変換はどういう時に必要なのか？](https://qiita.com/toRisouP/items/f6088963037bfda658d3)


|R3|UniRx|機能|一言でまとめると|戻り値|
|:----|:----|:----|:----|:----|
|[Multicast](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/MulticastTest.cs)|Multicast|`Observable<T>`を購読しその結果をすべて別のISubject<T>に流し込む。|他のSubjectに連結する|`ConnectableObservable<T>`|
|[Publish](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/PublishTest.cs)|Publish|Obsevableを購読しその結果をすべて後続に流し直す。Observableをあらかじめ購読しておく（Hot変換）ために用いる。Multicast(new Subject<T>())またMulticast(new BehaviorSubject<T>(initValue))と同義。|Hot変換する|`ConnectableObservable<T>`|
|[RefCount](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/RefCountTest.cs)|RefCount|`ConnectableObservable<T>`のConnect()とそのDispose()を自動化する。購読者が1つ以上いる場合は自動的にConnect()し、購読者が0になったら自動的にDispose()する。Dispose()後もまた新たに購読者がきた場合は再度Connect()する。|Publish()を自動化する|`Observable<T>`|
|[Replay](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/ReplayTest.cs)|Replay|Obsevableを購読しその結果をすべて後続に流し直す。Observableをあらかじめ購読しておく（Hot変換）ために用いる。Multicast(new ReplaySubject<T>())と同義。|Hot変換する|`ConnectableObservable<T>`|
|[ReplayFrame](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/ReplayFrameTest.cs)|-|Obsevableを購読しその結果をすべて後続に流し直す。Observableをあらかじめ購読しておく（Hot変換）ために用いる。Multicast(new ReplayFrameSubject<T>())と同義。|Hot変換する|`ConnectableObservable<T>`|
|[Share](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/ShareTest.cs)|Share|Publish().RefCount()と同義。|Publish().RefCount()と同じ|`Observable<T>`|



## Task変換系

`Observable`を`Task`に変換して扱うことができるものをここにまとめています。

|R3|UniRx|機能|一言でまとめると|戻り値|
|:----|:----|:----|:----|:----|
|[AggregateAsync](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/AggregateAsyncTest.cs)|(Aggregate)|OnCompleted発行時に、過去に発行されたOnNextを畳み込み(fold)計算する。Scanに似ているが、こちらは`Task<T>`である。|畳み込む|`Task<T>`|
|[AggregateByAsync](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/AggregateByAsyncTest.cs)|-|OnCompleted発行時に、過去に発行されたOnNextをkeySelectorでグループ化し、グループ単位で畳み込み(fold)計算する。|畳み込む|`Task<T>`|
|[AllAsync](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/AllAsyncTest.cs)|-|OnCompleted発行時に、過去に発行されたすべてのOnNextが条件を満たしているかを調べる。|すべて合ってるか|`Task<bool>`|
|[AnyAsync](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/AnyAsyncTest.cs)|-|条件を満たしたOnNextが発行されたら即座に完了する`Task<bool>`に変換する。ContainsAsyncとの違いはFunc<T, bool>を引数に取る。|どれか一個でも合ってるか|`Task<bool>`|
|[AverageAsync](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/AverageAsyncTest.cs)|-|OnCompleted発行時に、購読中に発行されたOnNextの平均値を求める。|平均する|``Task<double>``|
|[ContainsAsync](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/ContainsAsyncTest.cs)|-|指定した値を含んだOnNextが発行されたら即座に完了する`Task<bool>`に変換する。AnyAsyncとの違いはこちらは値そのものを引数に取る。|含むか調べる|`Task<bool>`|
|[CountAsync](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/CountAsyncTest.cs)|-|OnCompleted発行時に、購読中に発行された条件を満たす値の個数を返す。|数える|`Task<int>`|
|[ElementAtAsync](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/ElementAtAsyncTest.cs)|-|指定した個数番目(ゼロオリジン)のOnNextの値を返す`Task<T>`に変換する。指定した個数に達せずにObservableが完了したときはArgumentOutOfRangeExceptionとなる。|要素を取り出す|`Task<T>`|
|[ElementAtOrDefaultAsync](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/ElementAtOrDefaultAsyncTest.cs)|-|指定した個数番目(ゼロオリジン)のOnNextの値を返す`Task<T>`に変換する。指定した個数に達せずにObservableが完了したときは既定値となる。|要素を取り出す|`Task<T>`|
|[FirstAsync](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/FirstAsyncTest.cs)|(First)|条件を満たしたOnNextが発行されたら即座に完了する`Task<T>`に変換する。条件を満たすOnNextが発行されずにObservableが完了したときはInvalidOperationExceptionとなる。|最初のメッセージを待つ|`Task<T>`|
|[FirstOrDefaultAsync](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/FirstOrDefaultAsyncTest.cs)|(FirstOrDefault)|条件を満たしたOnNextが発行されたら即座に完了する`Task<T>`に変換する。条件を満たすOnNextが発行されずにObservableが完了したときは既定値となる。|最初のメッセージを待つ|`Task<T>`|
|[IsEmptyAsync](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/IsEmptyAsyncTest.cs)|-|OnNextが一度も発行されずにObservableが完了したかどうかを判定する`Task<bool>`に変換する。|空か調べる|`Task<bool>`|
|[LastAsync](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/LastAsyncTest.cs)|(Last)|一番最後に条件を満たしたOnNextを返す`Task<T>`に変換する。条件を満たすOnNextが発行されずにObservableが完了したときはInvalidOperationExceptionとなる。|最後のメッセージを待つ|`Task<T>`|
|[LastOrDefaultAsync](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/LastOrDefaultAsyncTest.cs)|(LastOrDefault)|一番最後に条件を満たしたOnNextを返す`Task<T>`に変換する。条件を満たすOnNextが発行されずにObservableが完了したときは既定値となる。|最初のメッセージを待つ|`Task<T>`|
|[LongCountAsync](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/LongCountAsyncTest.cs)|-|OnCompleted発行時に、購読中に発行された条件を満たす値の個数を返す。CountAsyncとの違いは型がlongになっている。|数える|`Task<long>`|
|[MaxAsync](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/MaxAsyncTest.cs)|-|`Observable<T>`の完了時に指定した条件下での最大値(TResult型)を返すTaskに変換する。MaxByAsyncとの違いはこちらは「結果となる最大値そのもの」を返す。|最大値を調べる|`Task<TResult>`|
|[MaxByAsync](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/MaxByAsyncTest.cs)|-|`Observable<T>`の完了時に指定した条件下での最大値を含んだT型を返すTaskに変換する。MaxAsyncとの違いはこちらは「最大値を含んだもとのOnNextの値」を返す。|最大値を含むものを調べる|`Task<T>`|
|[MinAsync](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/MinAsyncTest.cs)|-|`Observable<T>`の完了時に指定した条件下での最小値(TResult型)を返すTaskに変換する。MinByAsyncとの違いはこちらは「結果となる最大値そのもの」を返す。|最小値を調べる|`Task<TResult>`|
|[MinByAsync](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/MinByAsyncTest.cs)|-|`Observable<T>`の完了時に指定した条件下での最小値を含んだT型を返すTaskに変換する。MinAsyncとの違いはこちらは「最小値を含んだもとのOnNextの値」を返す。|最小値を含むものを調べる|`Task<T>`|
|[MinMaxAsync](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/MinMaxAsyncTest.cs)|-|`Observable<T>`の完了時に指定した条件下での最小値と最大値(TResult型)を返すTaskに変換する。|最小値と最大値を調べる|`Task<(TResult, TResult)>`|
|[SequenceEqualAsync](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/SequenceEqualAsyncTest.cs)|-|2つのObservableが発行する値が順序含め完全に一致するかを表す`Task<bool>`を返す。一致しないと判断された場合は直ちにfalseで終了するが、完全に一致するかどうかの判定を行う(trueを返す)ためには両者のObservableが完了する必要がある。|一致するか調べる|`Task<bool>`|
|[SingleAsync](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/SingleAsyncTest.cs)|(Single)|購読開始から完了までの間に、条件を満たしたOnNextが1つだけであるかを調べその結果を返す`Task<T>`に変換する。条件を満たすOnNextが発行されなかった、または2つ以上発行された場合はInvalidOperationExceptionとなる。|１個だけか調べる|`Task<T>`|
|[SingleOrDefaultAsync](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/SingleOrDefaultAsyncTest.cs)|(SingleOrDefault)|購読開始から完了までの間に、条件を満たしたOnNextが1つだけであるかを調べその結果を返す`Task<T>`に変換する。条件を満たすOnNextが発行されなかった場合は既定値が発行される。2つ以上発行された場合はInvalidOperationExceptionとなる。|１個だけか調べる|`Task<T>`|
|[SumAsync](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/SumAsyncTest.cs)|-|OnNextの合算値を返す`Task<T>`に変換する。このTaskはOnCompleted発行時に完了する。|合計する|`Task<T>`|
|[ToArrayAsync](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/ToArrayAsyncTest.cs)|(ToArray)|Observableの完了時に購読開始から発行されたOnNextを配列にまとめて返すTask<T[]>に変換する。|配列に変換する|`Task<T[]>`|
|[ToDictionaryAsync](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/ToDictionaryAsyncTest.cs)|-|Observableの完了時に購読開始から発行されたOnNextをDictionaryにまとめて返す`Task<Dictionary<TKey, TElement>>`に変換する。|辞書に変換する|`Task<Dictionary<TKey, TElement>>`|
|[ToHashSetAsync](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/ToHashSetAsyncTest.cs)|-|Observableの完了時に購読開始から発行されたOnNextをHashSetにまとめて返すTask<HashSet<T>>に変換する。|`HashSet<T>`に変換する|`Task<HashSet<T>>`|
|[ToListAsync](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/ToListAsyncTest.cs)|-|Observableの完了時に購読開始から発行されたOnNextをList<T>にまとめて返すTask<List<T>>に変換する。|`List<T>`に変換する|`Task<List<T>>`|
|[ToLookupAsync](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/ToLookupAsyncTest.cs)|-|Observableの完了時に購読開始から発行されたOnNextをLookUpにまとめて返すTask<ILookup<TKey, T>>に変換する。|`ILookUp<TKey, T>`に変換する|`Task<ILookup<TKey, T>>`|
|[WaitAsync](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/WaitAsyncTest.cs)|(Wait), (ToTask)|Observableが完了するのを待機するTaskに変換する。|待つ|`Task`|


## その他

上記の分類に当てはまらないもの、または特殊なものをここにまとめています。

|R3|UniRx|機能|一言でまとめると|戻り値|
|:----|:----|:----|:----|:----|
|[ForEachAsync](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/ForEachAsyncTest.cs)|(ForEachAsync)|Observableを購読しつつそれが完了まで待機するTaskに変換する。要するに完了までawaitができるSubscribe()。|Subscribe()をawatiできるようにする|Task|
|[AsObservable](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/AsObservableTest.cs)|AsObservable|Observable型に変換する。ソースとなっている型（SubjectやReactivePropertyなど）へのダウンャストを防止できる。|Observableに変換する|`Observable<T>`|
|[AsSystemObservable](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/AsSystemObservableTest.cs)|-|R3.`Observable<T>`から`System.IObservable<T>`へと変換する。|Rx/UniRxに繋ぎこむ|`System.IObservable<T>`|
|[Dematerialize](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/MaterializeDematerializeTest.cs)|Dematerialize|Materializeを解除する。|Materializeを解除する|`Observable<T>`|
|[Do](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/DoTest.cs)|Do/DoOnError/DoOnCompleted/DoOnSubscribe|ObservableのOnNext/OnErrorResume/OnCompleted/Subscribeのタイミングで任意のデリゲートを実行する。|副作用を起こす|`Observable<T>`|
|[DoCancelOnCompleted](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/DoCancelOnCompletedTest.cs)|-|OnCompleted時にCancellationTokenSourceをキャンセルする。|CancellationTokenSourceと連動させる|`Observable<T>`|
|[Materialize](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/MaterializeDematerializeTest.cs)|Materialize|OnNext/OnErrorResume/OnCompletedをすべてOnNext型に変換する。Materializeを適用したObservableはDematerializeを適用することでもとに戻る。|すべてをOnNextに変換する。|`Observable<Notification<T>>`|
|[SubscribeAwait](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/SubscribeAwaitTest.cs)|-|Subscribe()のメッセージハンドリング処理のasync/await対応版。指定するAwaitOperationで挙動が変化する。|非同期処理を使う|`IDisopsable`|
|[Synchronize](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/SynchronizeTest.cs)|Synchronize|それ以降のOnNext処理に排他ロックをかける。ただしSelectAwaitやWhereAwaitなどの非同期処理が使えるOperatorを挟んだ場合は排他ロックが外れるため注意。|排他ロックする|`Observable<T>`|
|[ToAsyncEnumerable](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/ToAsyncEnumerableTest.cs)|-|`Observable<T>`を`IAsyncEumerable<T>`に変換する。|`IAsyncEnumerable<T>`に変換する|`IAsyncEnumerable<T>`|
|[ToLiveList](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Operators/ToLiveListTest.cs)|-|発行されたOnNextをリアルタイムに格納するコレクション`LiveList<T>`に変換する。|リアルタイムに変動するコレクションに変換する|`LiveList<T>`|


# R3のファクトリー一覧

R3のファクトリーメソッドを列挙して紹介します。

|メソッド|機能|戻り値|
|:----|:----|:----|
|[Amb](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Factories/AmbTest.cs)|複数のObservableを同時に購読し、OnNextが先着した方のObservableのみを採択する。|`Observable<T>`|
|[CombineLatest](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Factories/CombineLatestTest.cs)|複数のObservableの入力のうち、それぞれ最新のものをセットにして1つのOnNextとして発行する。|`Observable<T>`|
|[Concat](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Factories/ConcatTest.cs)|OnCompleted発行時に次のObservableに購読先を切り替える（Observableを直列に合成する）。|`Observable<T>`|
|[Create](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Factories/CreateTest.cs)|手続き処理を用いて任意のタイミングでメッセージを発行するObservableを作成する。|`Observable<T>`|
|[CreateFrom](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Factories/CreateFromTest.cs)|IAsyncEnumerable<T>を`Observable<T>`に変換する。|`Observable<T>`|
|[Defer](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Factories/DeferTest.cs)|Observableの評価タイミングをSubscribe時まで遅延させる。|`Observable<T>`|
|[Empty](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Factories/EmptyTest.cs)|購読直後にOnCompleted()を発行する。|`Observable<T>`|
|[EveryUpdate](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Factories/EveryUpdateTest.cs)|毎フレームOnNext(Unit)を発行する。フレームタイミングは指定可能。|`Observable<Unit>`|
|[EveryValueChanged](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Factories/EveryValueChangedTest.cs)|指定オブジェクトを毎フレームチェックし、差分があれば値を取り出して発行する。|`Observable<TProperty>`|
|[FromAsync](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Factories/FromAsyncTest.cs)|非同期処理(ValueTask)をObservableに変換する。|`Observable<T>`|
|[FromEvent](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Factories/FromEventTest.cs)|デリゲートをObservableに変換する。|`Observable<Unit>` / `Observable<T>`|
|[FromEventHandler](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Factories/FromEventHandlerTest.cs)|EventHandlerを用いたデリゲートをObservableに変換する。| `Observable<(Object, TEventArgs)>`|
|[Interval](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Factories/IntervalTest.cs)|一定間隔でOnNextを発行する。|`Observable<Unit>`|
|[IntervalFrame](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Factories/IntervalFrameTest.cs)|一定フレーム間隔でOnNextを発行する。|`Observable<Unit>`|
|[Merge](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Factories/MergeTest.cs)|Observableを並列に合成する。|`Observable<T>`|
|[Never](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Factories/NeverTest.cs)|何も発行しないObservableを生成する。|`Observable<Unit>`|
|[NextFrame](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Factories/NextFrameTest.cs)|必ず次のフレームで1回だけOnNext(Unit)を発行し、その直後にOnCompletedを発行する。Observable.YeildFrame()と似ているが、こちらは必ず次のフレームで発行されることが保障される。|`Observable<Unit>`|
|[ObservePropertyChanged](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Factories/ObservePropertyChangedTest.cs)|INotifyPropertyChangedをObservableに変換する。|`Observable<TProperty>`|
|[ObservePropertyChanging](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Factories/ObservePropertyChangingTest.cs)|INotifyPropertyChangingをObservableに変換する。|`Observable<TProperty>`|
|[Range](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Factories/RangeTest.cs)|指定した数値から連番で指定個数OnNext(int)を発行し、最後にOnCompletedを発行する。|`Observable<int>`|
|[Repeat](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Factories/RepeatTest.cs)|指定した値を指定した回数繰り返し発行し、最後にOnCompletedを発行する。|`Observable<T>`|
|[Return](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Factories/ReturnTest.cs)|指定した値を1回だけ発行し、OnCompletedを発行する。発行タイミングは調整可能。|`Observable<T>`|
|[ReturnFrame](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Factories/ReturnFrameTest.cs)|指定した値を1回だけ発行し、OnCompletedを発行する。発行するフレームは調整可能。|`Observable<T>`|
|[ReturnOnCompleted](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Factories/ReturnOnCompletedTest.cs)|OnCompletedを発行する。Resultの成否は指定可能。発行タイミングは調整可能。|`Observable<T>`|
|[ReturnUnit](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Factories/ReturnUnitTest.cs)|OnNext(Unit)を発行し、OnCompletedを発行する。|`Observable<Unit>`|
|[Throw](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Factories/ThrowTest.cs)|異常終了のOnCompletedを発行する。Observable.ReturnOnCompleted<T>(Result.Failure(exception))と同義。|`Observable<T>`|
|[Timer](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Factories/TimerTest.cs)|指定時間後にOnNext(Unit)を1回発行し、OnCompletedを発行する。|`Observable<Unit>`|
|[Timer](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Factories/TimerTest.cs)|指定時間後にOnNext(Unit)を1回発行し、その後は別途指定した時間間隔ごとにOnNext(Unit)を発行し続ける。|`Observable<Unit>`|
|[TimerFrame](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Factories/TimerFrameTest.cs)|指定フレーム後にOnNext(Unit)を1回発行し、OnCompletedを発行する。|`Observable<Unit>`|
|[TimerFrame](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Factories/TimerFrameTest.cs)|指定フレーム後にOnNext(Unit)を1回発行し、その後は別途指定したフレーム間隔ごとにOnNext(Unit)を発行し続ける。|`Observable<Unit>`|
|[ToObservable](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Factories/ToObservableTest.cs)|Task/ValueTask/IEnumerable/IAsyncEnumerable/System.IObservableをR3.Observableに変換する。Rx/UniRxからR3に接続する時にもこれを使う。|`Observable<T>`|
|[Yield](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Factories/YieldTest.cs)|指定のTimeProviderの次の実行タイミングにメッセージを発行する。TimeProvider未指定の場合はThreadPoolからメッセージ発行される。|`Observable<T>`|
|[YieldFrame](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Factories/YieldFrameTest.cs)|指定のFrameProviderの次の実行タイミングにメッセージを発行する。Observable.NextFrame()に似ているが、こちらはタイミングによっては同一フレーム内でメッセージが発行されることがある。|`Observable<T>`|
|[Zip](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Factories/ZipTest.cs)|複数のObservableの入力をキューにつめて、揃ったものから順次1つのOnNextとして発行する。|`Observable<TResult>`|
|[ZipLatest](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples/blob/master/Assets/R3_Samples/Tests/Factories/ZipLatestTest.cs)|複数のObservableの入力のうち最新のものを1つだけ保持し、揃ったものから順次1つのOnNextとして発行する。CombineLatestとの違いはこちらは一度発行した値は再利用されない。|`Observable<TResult>`|

# R3とUniRxの違い

## 名称が変更されたオペレーター

[R3のREADME](https://github.com/Cysharp/R3?tab=readme-ov-file#classmethod-name-changes-from-dotnetreactive-and-neueccunirx)にまとまっていますが、次のオペレーターは名称が変更されています。

 * `Buffer` -> `Chunk`
 * `BatchFrame` -> `ChunkFrame`
 * `Throttle` -> `Debounce`
 * `ThrottleFrame` -> `DebounceFrame`
 * `Sample` -> `ThrottleLast`
 * `SampleFrame` -> `ThrottleLastFrame`
 * `StartWith` -> `Prepend`
 * `ObserveEveryValueChanged(this T value)` -> `Observable.EveryValueChanged(T value)`
 * `Distinct(selector)` -> `DistinctBy`
 * `DistinctUntilChanged(selector)` -> `DistinctUntilChangedBy`
 * `Finally` -> `Do(onDisposed:)`
 * `Do***` -> `Do(on***:)`
 * `AsyncSubject<T>` -> `TaskCompletionSource<T>`
 * `First()`や`FirstOrDefault()`など -> `***Async` (または `Take(1)`, `TakeLast(1)`)
 * `ToTask()`, `ToUniTask()` -> `LastAsync()` または `FirstAsync()`


一番大きな違いとしては、単発で値を取得する場合は`~Async()`といった`Task`を返すオペレーターを用いて`await`で待ちけるようになったところです。

## UniRxに存在したがR3で消滅したオペレーター等

(`First`と`FirstAsync`などの似た挙動をするものが存在するものは除外。本当に跡形もなくなったもの。)

|名前|R3での代替方法|備考|
|:--|:--|:--|
|AsSingleUnitObservable|`WaitAsync()`|挙動としては`AsUnitObservable().LastAsync()`の方が近いが、想定用途としては`WaitAsync()`の方が近い。|
|ContinueWith|`~Async()`と`async/await`を併用する。|`Observable`を用いた非同期処理用のオペレーター。現代では`async/await`があるのでそっちを使うことを推奨。|
|GroupBy|-|地味に便利だったがR3では存在しない。|
|Repeat|-|R3では`Observable`の再利用を推奨しないため存在しない。|
|RepeatUntil|-|R3では`Observable`の再利用を推奨しないため存在しない。|
|RepeatSafe|-|R3では`Observable`の再利用を推奨しないため存在しない。|
|Catch（`OnError`のハンドリング用途）|-|`OnError`が`OnErrorResume`に置き換わったため存在しない。|
|CatchIgnore|-|`OnError`が`OnErrorResume`に置き換わったため存在しない。|
|Reatry|-|`OnError`が`OnErrorResume`に置き換わったため存在しない。|
|OnErrorRetry|-|`OnError`が`OnErrorResume`に置き換わったため存在しない。|
|WhenAll|`LastAsync()`したものを`Task.WhenAll`で待ち受ける。|`Observable`を用いた非同期処理用のオペレーター。現代では`async/await`があるのでそっちを使うことを推奨。|
|Debug|`Do`を用いて再現する。|`Observable`上で起きた事象をログに吐き出すオペレーター。[再現方法はこちらの記事にて紹介。](https://qiita.com/toRisouP/items/4344fbcba7b7e8d8ce16#%E5%A4%89%E6%9B%B4-debug%E3%82%AA%E3%83%9A%E3%83%AC%E3%83%BC%E3%82%BF)|

R3ではUniRxと設計思想が異なるため、`Repeat`や`Retry`といったオペレーターが消滅しています。
そのためもしこれらを用いたUniRxコードをR3に置き換える場合は結構な改修が必要になります。
これらオペレーターは`OnErrorResumeAsFailure()`や`ForEachAsync()`をうまく使うことで挙動を再現することができるので、参考にしてください。

* [【Unity】R3のForEachAsyncが便利](https://qiita.com/toRisouP/items/a9c94ee008b1a68f79c7#%E5%BF%9C%E7%94%A8repeatretry%E3%81%AE%E4%BB%A3%E6%9B%BF%E6%89%8B%E6%AE%B5)

# R3 挙動がややこしいオペレーター等の解説

* `Debounce`,`ThrottleFirst`,`ThrottleLast`,`ThrottleFirstLast`
* `AwaitOperation`
* `Zip`, `ZipLatest`, `CombineLatest`, `WithLatestFrom`

これらオペレーターやプロパティは挙動が似ており非常にややこしいです。なのでわかりやすく挙動を確認できるページを用意したので活用してください。

* [挙動確認用のDEMOページ](https://torisoup.github.io/R3_Factories_and_Operators_Samples/)
* [リポジトリ](https://github.com/TORISOUP/R3_Factories_and_Operators_Samples)



## Debounce系の挙動の違い

|名前|挙動|
|:--|:--|
|Debounce|OnNextが連続した場合は落ち着くのを待って最後の1個を取り出す。|
|ThrottleFirst|OnNextが連続した場合の最初の1個を取り出す。|
|ThrottleLast|OnNextが連続した場合の最後の1個を取り出す。|
|ThrottleFirstLast|OnNextが連続した場合の最初と最後の1個ずつを取り出す。|

以下比較用のgif動画。

<details>
<summary>Debounce</summary>

![debounce.gif](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/47146/c16ca122-109f-403e-9cc1-8ff11bb76493.gif)


OnNextが連続した場合は落ち着くのを待って最後の1個を取り出す。

OnNextが来るたびにその待ち時間はリセットされる。
（今回の実装では待ち時間は毎回ランダムになるように設定）

</details>


<details>
<summary>ThrottleFirst</summary>

![ThrottleFirst.gif](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/47146/858f3d57-a7f2-4716-b4fd-de2dc8a30a61.gif)


OnNextが連続した場合は最初の1個を取り出す。一度発動すると一定時間はOnNextを遮断する。

待ち時間はOnNextが来てもリセットされない。
（今回の実装では待ち時間は毎回ランダムになるように設定）

</details>


<details>
<summary>ThrottleLast</summary>

![ThrottleLast.gif](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/47146/6b9ef991-0854-4364-af01-a491f3b86833.gif)


OnNextが連続した場合は最後の1個を取り出す。待機中にOnNextが到達したら「待ち」を開始しその間に発行されたOnNextのうちの最後を取り出す。

待ち時間はOnNextが来てもリセットされない。
（今回の実装では待ち時間は毎回ランダムになるように設定）

</details>


<details>
<summary>ThrottleFirstLast</summary>

![ThrottleFirstLast.gif](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/47146/5218d937-b6f1-4f6d-b3e1-07179c3492c9.gif)


`ThrottleFirst`と`ThrottleLast`が合体した挙動をする。

待ち時間はOnNextが来てもリセットされない。
（今回の実装では待ち時間は毎回ランダムになるように設定）

</details>

## AwaitOperationの挙動の違い

`SubscribeAwait`/`WhereAwait`/`SelectAwait`は指定する`AwaitOperation`で挙動が大きく変化します。

|AwaitOperation|非同期の実行中に次のメッセージが来たときの挙動|備考|
|:--|:--|:--|
|Sequential|今実行中の非同期処理を優先。余剰なメッセージはキューに積む。非同期処理が終わり次第、次の１つを取り出して順番に非同期実行する。|デフォルト設定がこれ|
|Drop|今実行中の非同期処理を優先。余剰なメッセージは無視してなかったことにする。||
|Switch| **今実行中の非同期処理をキャンセル。** 新しく到達したメッセージの処理を優先して開始する。|キャンセル処理は`CancellationToken`を使って自分で実装する必要がある。|
|Parallel|新しく来たメッセージを用いて即座に非同期を実行する。非同期処理が終わったものから早いもの勝ちで出力される。|`maxConcurrent`で同時実行数を制限できる。`maxConcurrent`を超える数のメッセージはキューに積まれる。|
|SequentialParallel※|新しく来たメッセージを用いて即座に非同期を実行する。その非同期処理の終了順によらず、出力順が入力順と同じになるように順序調整される。|`maxConcurrent`で同時実行数を制限できる。`maxConcurrent`を超える数のメッセージはキューに積まれる。|
|ThrottleFirstLast|非同期処理が実行されていないとき、新しく届いた値を処理する。非同期処理の実行中は最新の値を１つだけ保持し、非同期処理の終了時にそれを取り出して処理を行う。|`ThrottleFirst`と`ThrottleLast`が合体した挙動|

※ **SequentialParallelはWhereAwait/SelectAwaitでのみ利用可**  

以下比較用のgif動画。

<details>
<summary>Sequential</summary>

![Sequential.gif](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/47146/e29d4111-164c-4593-a434-a0a49eba3e15.gif)


メッセージを発行順にキューに積み、1つずつ順番に処理する。デフォルト挙動がこれ。

（今回の実装では待ち時間は毎回ランダムになるように設定）

</details>

<details>
<summary>Drop</summary>

![Drop.gif](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/47146/b9692382-c616-4541-8802-a5c10b0e4617.gif)


今実行中の非同期処理を優先。余剰なメッセージは無視してなかったことにする。`ThrottleFirst`と似ている。

（今回の実装では待ち時間は毎回ランダムになるように設定）

</details>

<details>
<summary>Switch</summary>

![Switch.gif](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/47146/702251fb-7957-4119-9b1c-2e920fce7efb.gif)


新しくメッセージがきたら今実行中の非同期処理をキャンセルし、新しく到達したメッセージの処理を実行する。`Debounce`と似ている。

（今回の実装では待ち時間は毎回ランダムになるように設定）

</details>


<details>
<summary>Parallel</summary>

![Parallel.gif](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/47146/10c1bf0b-7db8-4b7a-9540-2983e687cee7.gif)


新しく来たメッセージを用いて即座に非同期を実行する。非同期処理が終わったものから早いもの勝ちで出力される。

（今回の実装では待ち時間は毎回ランダムになるように設定）

</details>


<details>
<summary>SequentialParallel</summary>

![SequentialParallel.gif](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/47146/6e8f6ae2-7da5-4654-a653-e882a878c36c.gif)


新しく来たメッセージを用いて即座に非同期を実行する。その非同期処理の終了順によらず、出力順が入力順と同じになるように順序調整される。

（今回の実装では待ち時間は毎回ランダムになるように設定）

</details>



<details>
<summary>ThrottleFirstLast</summary>

![ThrottleFirstLast_Await.gif](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/47146/ca28ce7b-524b-4632-959a-caf8093d296e.gif)


非同期処理が実行されていないとき、新しく届いた値を処理する。非同期処理の実行中は最新の値を１つだけ保持し、非同期処理の終了時にそれを取り出して処理を行う。

（今回の実装では待ち時間は毎回ランダムになるように設定）

</details>


## Zip系の挙動の違い

 
|名前|挙動|
|:--|:--|
|Zip|複数のObservableの入力をキューにつめて、揃ったものから順次1つのOnNextとして発行する。|
|ZipLatest|複数のObservableの入力のうち最新のものを1つだけ保持し、すべてが揃ったらそれを1つのOnNextとして発行する。|
|CombineLatest|複数のObservableの入力のうち、それぞれ最新のものをセットにして1つのOnNextとして発行する。|
|WithLatestFrom|メインとなるObservableにOnNextが入力されたタイミングで別のObservableの最新値と合成して出力する。サブObservable側に一度もOnNextが発行されていない場合は何も出力されない。|

以下比較用のgif動画およびマーブルダイアグラム。

<details>
<summary>Zip</summary>


![Zip.jpg](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/47146/9ebb0284-9730-4938-82eb-915dd868c4c1.jpeg)

![Zip.gif](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/47146/943f0475-8d14-459e-99f8-cc46577778c0.gif)


複数のObservableの入力をキューにつめて、揃ったものから順次1つのOnNextとして発行する。


</details>

<details>
<summary>ZipLatest</summary>

![ZipLatest.jpg](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/47146/dff47c50-c1ea-46ca-afac-1fedf01dbb2f.jpeg)

![ZipLatest.gif](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/47146/666dd377-cf2a-487a-8c69-1f9da73e3c77.gif)


複数のObservableの入力のうち最新のものを1つだけ保持し、すべてが揃ったらそれを1つのOnNextとして発行する。

</details>

<details>
<summary>CombineLatest</summary>


![CombineLatest.jpg](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/47146/c3322f5d-ebb0-4b74-be25-14843f575546.jpeg)

![CombineLatest.gif](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/47146/bf4c7f9a-0185-4a79-bd7b-01737137b019.gif)


複数のObservableの入力のうち、それぞれ最新のものをセットにして1つのOnNextとして発行する。
</details>

<details>
<summary>WithLatestFrom</summary>

![WithLatestFrom.jpg](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/47146/b3bbe234-dd61-475c-9025-f75c16b565b7.jpeg)

![WithLatestFrom.gif](https://qiita-image-store.s3.ap-northeast-1.amazonaws.com/0/47146/dafa1518-24e1-4cbd-8bb2-a82abfa0671d.gif)

メインとなるObservableにOnNextが入力されたタイミングで別のObservableの最新値と合成して出力する。サブObservable側に一度もOnNextが発行されていない場合は何も出力されない。

今回はメイン側を「first」、サブ側を「second」と命名した。
</details>