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

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.

主站蜘蛛池模板: 西乌珠穆沁旗| 万全县| 盖州市| 共和县| 大竹县| 娄烦县| 高碑店市| 嵊泗县| 北票市| 黄大仙区| 根河市| 大洼县| 会宁县| 襄樊市| 许昌县| 云阳县| 体育| 山阴县| 手游| 教育| 双鸭山市| 通山县| 滦平县| 乌鲁木齐县| 平舆县| 竹山县| 丹寨县| 河东区| 揭西县| 怀集县| 海门市| 军事| 兴安盟| 宾川县| 土默特左旗| 台江县| 雅安市| 象州县| 莱西市| 桃园市| 固阳县|