问题标签 [subject]

我的应用程序中有 2 项服务。我用来Subject为所有应用程序发送数据。但是有一个问题，我只有一个Subject. 我StateService需要 3 个独立的 a 实例Subject：

我ConnectionService需要一个 a 的实例Subject：

我有 2 个不同的subscribe()方法来处理 2 个（在我看来）不同的 a 实例Subject：

但是当我运行应用程序并检查时，我发现有 1 个实例接收所有数据。

我有一个Alert.Service.ts将从另一个服务获取的警报保存在一个数组中。在另一个header.component.ts中，我想获得该数组的实时大小。

所以，在Alert.Service.ts我有

而且，在 中header.component.ts，我有

我希望alertListSize只要alerts数组Alert.Service.ts更改就会更新。但是，它始终是创建0时的初始值。BehaviorSubject订阅部分似乎不起作用。

我有一个包含 WebSocket 的主题（https://github.com/Reactive-Extensions/RxJS-DOM/blob/master/doc/operators/fromwebsocket.md），我想缓冲 WebSocket 接收到的消息。我查看了https://github.com/Reactive-Extensions/RxJS/blob/master/doc/api/core/operators/buffer.md但使用了 observable 而不是主题。此外，我读过主题可用于使用缓冲或缓存“您可以使用主题来实现具有缓存、缓冲和时移的自定义 observable”（https://xgrommx.github.io/rx-book/content /getting_started_with_rxjs/subjects.html），我如何使用主题和观察者来实现这类事情（缓冲，缓存，......）。

我对 Rx 的概念有点迷茫，它们比 akka-streams 更难！！

谢谢，

我在构造函数中使用 Observable.from() 制作了数组流，并在构造函数中订阅了它，数组正在更新，但订阅方法不起作用我想，我没有为数据获取 console.log，这里是编码

这是课

所以我刚刚开始使用 Angular 2 进行编程，并且刚刚开始学习订阅、Subject 和 BehaviorSubject。目前我有多个订阅来获取存储在我的服务中并发送到组件的值。我的应用程序有效，但我知道它的效率很低。它在我的组件中已经失控：

（和其他 5 个获得单个值并每次调用函数 getSession() 一样）

在我的威胁服务中：

所以我试过：

我的目标只是测试 res 是什么，因为我不确定如何访问这两个值......但我在控制台中得到了这个。;/

最终，我想从我的服务中获取 getSession() 需要的所有值并运行该函数一次。我非常感谢任何有关如何使用 concat、merge 或 forkJoin 来合并我的订阅的帮助或解释。谢谢！

• 我想要一个 pubsub 系统，它有流的生产者和消费者，通过数据平面层但没有主题。
• 许多生产者可以多播到相同的流名称（例如，'filters.add'），并且多个消费者可以订阅该流。
• 生产者注册名称和流以创建“已发布流的流”。

• 如果一个新的生产者注册了一个特定的流名称，流向消费者的流会动态更新，以便接收到的数据是所有当前活动的已发布流与请求的名称的合并。

• 一个生产者流完成不应导致聚合流完成，而是在发生这种情况时被排除（更新所有消费者）。

• 在生产者注册后获得流的消费者应该收到该流的最后一个发出的值（如果迄今为止有一个）。

这是我到目前为止的代码和我希望满足的测试。我可以满足基本情况但不能缓存，因为：

• 已完成的流被排除在外，即使它们可能已经发出了最新的值；
• .cache(1)afterstream.publish().refCount()重复4从第一个输入Observable，而不是8从第二个输入；
• 即使pluckActiveStreams注释掉了，这也不起作用，我只是无法让它与任何注释掉的方法一起工作......

我的问题是：

• 如何实现聚合流的缓存？注释掉的最后几行都没有relevantStreams$做到这一点。
• 我认为我需要从收到的聚合流中删除已完成的流，以便聚合流本身不会（永远）完成。这是（可能）使用 完成的pluckActiveStreams，它基于此处给出的解决方案，但仍为迟到的消费者提供流的最后发出的值，即使它可能来自现已完成的流？

我当前的实现已经在内部使用 ReplaySubjects 的 observables 作为生产者和消费者之间的“桥梁”成功地实现了这一点。但是这样：

1. 所有生产者流都会自动变热；
2. ReplaySubject 需要一个 hack 来确保它永远不会在任何多播到它的流中完成（否则它会关闭所有消费者的流，如此处所述）；
3. 一旦在第一个生产者注册时创建，代表特定生产者组的流名称的 ReplaySubject 永远不会再被冷处理，如果没有该名称的当前生产者，则不会被处置，或者像以前一样使用不同的参数重新实例化然后，该流的注册消费者将持有不正确的引用。因此，消费者需要对特定名称的活动流的响应式更新、声明性聚合的引用。

代码

测试

我没有在 angular cli 结构中更改任何内容。我尝试从 rxjs 导入 Subject 并像这样创建 Subject 对象：

加载我的网页时出错

index.html system.js 加载

system.config.ts（js编译成功）

和默认的 angular-cli-build.js

在 vendor/rxjs 中，我拥有 node_modules/rxjs 下的所有文件。没有像 index.js 这样的文件。

我有以下代码以电子邮件形式发送报告（pdf）。代码工作正常！但是，我希望我发送的当前记录的一个字段成为电子邮件主题的一部分。我尝试了很多东西，但没有任何效果。

当前主题是“订单已准备就绪！”

我希望这是“订单 [订单号] 已准备就绪！”

提前谢谢各位！

我目前正在使用 Mailgun 检查我的应用程序中收到的电子邮件。到目前为止，我可以获得电子邮件的收件人、发件人和正文；但不是主题。

我可以在邮件标题中看到主题：

它返回以下内容：

这看起来是一个数组，但通过 is_array 运行它，返回 false。

我尝试过的代码：

返回：ErrorException 为 foreach() 提供的参数无效

使用 phperror_log发送电子邮件时，主题始终显示为“ PHP error_log message ”。这是正在使用的代码：

error_log( $data, 1, 'test@domain.com', "Subject: This is the subject" );

我已经搜索过，我能找到的唯一相关问题是：

如何更改我的 php 错误电子邮件的主题？

上面的帖子中有一条评论表明该主题被添加了两次，这也得到了对php 文档的评论的支持

尽管有上述评论，但没有迹象表明如何“解决”这个问题。

关于我可能做错了什么或我需要做什么才能使其正常工作的任何建议？