Eloquent 不支持 Reactive Streams 和背压，因其运行于 PHP 同步阻塞模型，无原生协程、Publisher/Subscriber 接口及事件循环；应使用 Laravel 事件、异步 Job 或流式 HTTP 响应替代。
Eloquent 没有 Reactive Streams，也不支持背压（backpressure）——这是 Java / JVM 生态（如 Project Reactor、RxJava）或 Node.js 的 RxJS 等场景的概念，PHP 运行时本身是同步阻塞模型，Laravel 也从未将 Eloquent 设计为响应式流式处理引擎。
为什么 Eloquent 不能用 Reactive Streams
PHP-FPM 或 CLI 模式下，每个请求对应一个独立进程/线程，无原生协程调度（除非用 Swoole + 协程适配层），更不提供 Publisher/Subscriber 接口、Subscription.request() 背压信号机制。所谓“Eloquent Attribute Reactive Streams”是概念混淆，常见于被错误翻译的博客或跨语言类比误导。
-
Attribute在 Eloquent 中仅指访问器（getFooAttribute）或修改器（setFooAttribute），是同步计算逻辑，不是流式数据源 - Laravel 10+ 的
Streamable（如Streamable::make()）仅用于 HTTP 流式响应（yield输出 chunk），与 Reactive Streams 规范无关 - 试图在 Eloquent 模型里注入
Flux、Mono或实现org.reactivestreams.Publisher接口，会导致 Fatal error：Class not found 或无法注册到事件循环
想实现类似“属性变更自动触发下游”的真实替代方案
若你实际想解决的是「模型字段变化后，自动通知其他模块或更新缓存」，应使用 Laravel 原生事件机制，而非强行套用响应式术语：
- 监听
Saving/Updating事件，在boot()中定义：static::updating(fn ($model) => $model->original['status'] !== $model->status && event(new StatusChanged($model))) - 用
casts+ 自定义 accessor 控制读取行为，例如：protected $casts = ['metadata' => 'array']，再配合getMetadataAttribute做运行时转换 - 避免在 accessor 中做 I/O（如查库、调 API），否则会放大 N+1 问题；真需联动，改用
dispatch(new SyncMetadataJob($this))异步解耦
如果必须处理大量数据流（比如导入百万行 CSV 并实时反馈进度）
这不是 Eloquent 的职责边界，应分层处理：
立即学习“PHP免费学习笔记（深入）”；
- 用
fopen()+fgetcsv()流式读取文件，每处理 1000 行echo "progress: ". $percent . "\n"; ob_flush(); flush();推送进度（HTTP 场景） - 写入数据库时，禁用模型事件（
withoutEvents()）和批量插入（upsert()或原生DB::insert()）提升吞吐 - 前端用
EventSource或 WebSocket（推荐 Laravel Websockets + Pusher 封装）接收服务端推送，而非让 Eloquent “发流” - 不要尝试给
Collection::map()包一层Flux.fromIterable()—— PHP 不识别该类，Composer 也无法安装reactive-streams-php（该包不存在）
真正容易被忽略的点：很多人把「链式调用」（$user->posts()->where(...)->get()）误认为“流”，其实它只是 Query Builder 的延迟执行对象，底层仍是单次 SQL 查询 + 数组返回。背压的核心是消费者控制生产者速率，而 PHP 没有跨请求的长期存活订阅关系，这个前提就不存在。
