Streamたとえば、JSON にシリアル化されたオブジェクトのコレクションが含まれています。
{"Name":"Alice","Age":20}{"Name":"Bob","Age":30}{"Name":"Charlie","Age":35}{"Name":"Danielle","Age":50}...
このストリームは非常に大きい可能性があるため、ストリーム全体を文字列に読み取るのではなく、アイテムが入ってくるたびに処理したいと考えています。また、ストリームがネットワーク ストリームの場合、無期限に開かれます。
一部のオブジェクトは非常に複雑な場合があるため、JSON.NET によって提供される JSON シリアル化を利用したいと考えています。
Newtonsoft Json を使用してストリームをに変換しIObservable<Person>、アイテムが到着したときに反応的に処理する方法はありますか?