I got a Repository of type Item My goal is to have the Repository provide an Observable or basically a "stream" of Item using an Observable.

I'm a complete beginner regarding RX but think I got a good grasp of the basics. My problem has been finding a way to keep an Observable alive and manually push Item to it as they come in (which might be sockets or anything else async based). Basically a Hot Observable.

I got it working using a Subject<Item> to which I subscribe but I'm missing the power of a "regular Observable", i.e. LINQ queries to filter the stream. I'm afraid that I'm overlooking something or looked past a fitting approach.

Any insight or direction for a beginner like me would be highly appreciated.