How does Rx query behave when stream of data comes faster than Subscribers can consume ?


  • To give you preface for this question :

    I am very excited about using Rx in production application; where I will be listening to incoming notification updates coming from different channel. I will be writing Rx query on top this stream where I will throttling using .Window() operator. Subscriber (In my case it is ActionBlock) will process this data in blocking fashion; (i.e it will not spawn Task from Subscriber). Keeping above in mind if data comes at much faster rate than what my Subscriber can consume then what will happen to incoming data. Does Rx query uses any buffer internally; will it get overflowed ?

    Wednesday, December 18, 2013 3:04 PM