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

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.

主站蜘蛛池模板: 盱眙县| 卢湾区| 宜宾市| 灵石县| 图木舒克市| 泰宁县| 鄂托克前旗| 吉安县| 吉木萨尔县| 石棉县| 博兴县| 公主岭市| 桐庐县| 大洼县| 稻城县| 丹阳市| 仁寿县| 莎车县| 洪湖市| 阜新市| 白水县| 太仓市| 巨鹿县| 平舆县| 定西市| 安达市| 南乐县| 黄冈市| 陆丰市| 喜德县| 浦县| 大埔区| 丰镇市| 七台河市| 沭阳县| 无极县| 北川| 五华县| 丽水市| 新河县| 陇川县|