Summary

• 简介
• Reactor简介
  • 什么是Reactor？
  • 项目简介
  • 使用要求
  • 架构总览
  • Reactive流
  • Reactive扩展
• reactor-core模块
  • 核心模块概览
  • 函数式模块
    • 组织功能模块
    • 元组
  • Environment和Dispatcher
    • Environment
    • Dispatcher
    • DispatcherSupplier
    • 定时器
  • 核心Processor
  • RingBuffer Processors
    • RingBufferProcessor
    • RingBufferWorkProcessor
  • Codecs and Buffer
• reactor-stream模块
  • 通过Stream和Promise协调任务
  • Stream基础
  • 创建Streams和Promises
    • From Cold Data Sources
    • From Existing Reactive Publishers
    • From Custom Reactive Publishers
    • From Hot Data Sources
    • Wiring up a Stream
    • Setting Capacity
    • Functional Composition
  • 理解线程模型
  • 微批次
    • Into Buffers
    • Into Windows
  • Backpressure and Overflow
  • Combinatory Operations
  • MicroServices
    • Creating Non-Blocking Services
    • Composing multiple Services Calls
    • Supporting Reactive Backpressure
  • Error Handling
  • Persisting Stream Data
  • Analytics
  • Partitioning
  • Other API beyond Rx
• reactor-bus模块
  • 路由数据
  • 发布/订阅
  • 请求/应答
    • 取消任务
  • Registry
• reactor-net
• Extensions