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

Reactive Extensions

Reactive Extensions (Rx or ReactiveX) (https://msdn.microsoft.com) is a library for composing asynchronous and event-based programs using observable sequences and LINQ-style query operators. Data sequences can take many forms, such as a stream of data from a file or web service, web services requests, system notifications, or a series of events such as user inputs.

As stated in the preceding definition, these are APIs that allow stream composition using the Observer pattern. It's my duty to introduce you to the Observer pattern before going any further. The following is the definition of this pattern and it's quite intuitive:

The Observer pattern defines a provider (also known as a subject or an observable) and zero, one, or more observers (Subscriber). Observers register with the provider, and whenever a predefined condition, event, or state change occurs, the provider automatically notifies all observers by calling one of their methods. For more information about the Observer pattern, you can refer to this link: https://docs.microsoft.com/en-us/dotnet/standard/events/observer-design-pattern.

Data can flow in a number of forms, such as streams or events. Reactive Extensions lets you convert this dataflow into observables and aids you in programming reactive code.

Rx is implemented in a variety of languages, including Java (RxJava). A full list of implemented languages and more detail on Rx can be found at http://reactivex.io/.

主站蜘蛛池模板: 寿宁县| 大冶市| 舒城县| 田东县| 诸城市| 秦皇岛市| 通海县| 湘阴县| 文水县| 灌阳县| 嘉峪关市| 阳山县| 元江| 万全县| 吉首市| 甘孜县| 邢台市| 太谷县| 顺平县| 洪洞县| 万州区| 田林县| 无锡市| 芜湖县| 芜湖市| 上林县| 奉化市| 额济纳旗| 九龙坡区| 霞浦县| 正宁县| 南漳县| 勐海县| 隆化县| 左云县| 万安县| 冕宁县| 蓬溪县| 申扎县| 凌海市| 深泽县|