官术网_书友最值得收藏!

Data stream types

Broadly, data streams can be categorized into two types:

  • Cold data streams: There are a number of names by which this is known, such as Cold Source, Cold Observable, and Cold Publisher. These emit data only when one subscribes to it and because of this, all messages produced from start are delivered to the subscriber. If a new Subscriber connects to it, the messages are replayed in ascending order and this is same for any new Subscriber. The Subscriber also has a provision to dictate the rate at which the Publisher should emit messages. These data streams are good candidates for applying reactive backpressure (request(n)), for example, a database cursor or file stream (reading a file).
  • Hot data streams: Again, this has a number of different names, such as Hot Source, Hot Observable, and Hot Publisher. These emit data irrespective of any subscribers connected. When a new Subscriber connects, it just emits the messages from that point in time and cannot replay messages from the start. These cannot pause message emissions, so an alternate mechanism is required to control flow, such as a buffer. Examples of this stream include mouse events and stock prices.

It's important to note that operators on a stream can change their property, going from cold to hot and vice versa. Also, there are times when a merge between hot and cold can happen and their properties change.

主站蜘蛛池模板: 朔州市| 公安县| 淮安市| 洪江市| 平邑县| 汉川市| 麻城市| 永川市| 濉溪县| 赤壁市| 奎屯市| 介休市| 彰化市| 固原市| 水城县| 固镇县| 镇赉县| 清苑县| 永宁县| 武宣县| 庆城县| 绵阳市| 榕江县| 大竹县| 万山特区| 阿克陶县| 南和县| 昆山市| 岫岩| 通州市| 西林县| 西平县| 麟游县| 新宁县| 汾阳市| 论坛| 高雄县| 东乡族自治县| 太保市| 镶黄旗| 清水县|