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

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/.

主站蜘蛛池模板: 武定县| 鸡西市| 本溪市| 简阳市| 大方县| 镇巴县| 华蓥市| 静安区| 东平县| 嘉善县| 上饶县| 乌拉特中旗| 衡东县| 汝城县| 信丰县| 西乡县| 望江县| 富川| 河津市| 镇康县| 禹城市| 丰原市| 噶尔县| 手机| 陈巴尔虎旗| 万山特区| 宁河县| 三都| 三亚市| 长丰县| 嘉峪关市| 巴楚县| 井研县| 武川县| 云南省| 莱西市| 玛曲县| 西华县| 株洲县| 迭部县| 金堂县|