Use RxExtensions to aggregate stream of data
I have a play project to learn Rx as it is something I have always wanted to learn and could be useful.
I just can’t seem to grasp it like I did Linq.
So I have a stream of data and would like to perform some aggregation on the stream.
System.Reactive, processing azure queue message one at a time
Having a little trouble with this one and hoping you guys can help… I am using C# System.Reactive. I have one observable that is simply an interval that gets azure queue messages from an azure storage queue, one at at time. This looks like this: