rxjava

RxJava 是响应式扩展（Reactive Extensions）在 Java VM 上的实现：一个通过使用可观察序列来组合异步和事件驱动程序的库。它扩展了观察者模式，以支持数据和事件序列，并添加了操作符，让开发者可以声明式地组合序列，同时屏蔽掉底层线程、同步、线程安全和并发数据结构等担忧。 README 文档描述的是 4.x 版本，这是一个原生 Java 实现，不需要第三方运行时库，支持 JPMS 和 OSGi，具有基于 java.util.concurrent.Flow 的实现、虚拟线程支持，以及围绕虚拟阻塞构建的新 Streamable 类型。还提到了 Reactive Streams 测试兼容性套件的使用、Java Cleaner API 用于资源泄漏检测，以及 RxJava 3.x 支持将在 4.x 发布后减少。 入门指南涵盖了添加依赖项（io.reactivex.rxjava4:rxjava）和使用 Flowable.just(...).subscribe(...) 的 Hello World 示例。基础类型包括：Flowable（带背压的 0..N）、Observable（不带背压的 0..N）、Single（恰好一个项或错误）、Completable（仅完成或错误）、Maybe（无项、一项或错误），以及 Streamable（虚拟阻塞带原生背压）。 README 解释了上游/下游、发射、背压、组装时间、订阅时间和运行时间等术语，包含背景计算、调度器、流内并发、并行处理、依赖子流、续体和响应式类型之间转换的代码示例。它还记录了由 Java 关键字驱动的操作符命名约定、类型擦除和类型歧义。