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

Processor

A Processor represents a processing stage--which is both a Subscriber and a Publisher, and MUST obey the contracts of both. A of can be chained by connecting a Publisher and Subscriber:

    public interface Processor<T, R> extends Subscriber<T>, 
Publisher<R> {
}

Reactor has two implementations for Publisher--Flux and Mono. Flux can emit 0...N events, whereas, Mono is for a single event (0...1). Flux is required when many data elements or a list of values is transmitted as Streams.

主站蜘蛛池模板: 梁平县| 凤翔县| 岑巩县| 上思县| 赫章县| 崇义县| 苗栗市| 灵璧县| 新巴尔虎左旗| 高邑县| 准格尔旗| 仁怀市| 清镇市| 黄梅县| 泸溪县| 翁源县| 磴口县| 沂南县| 佳木斯市| 江川县| 湘潭市| 南召县| 塘沽区| 中卫市| 会同县| 叶城县| 周口市| 璧山县| 三门县| 雷州市| 岳阳县| 镶黄旗| 宁乡县| 怀远县| 洪湖市| 常山县| 潍坊市| 巩义市| 连城县| 太谷县| 资溪县|