3回答
我有一个简单的函数，包含在一个服务中，返回一个对象的可观察值： return Observable.of(this.someData);我订阅了一个组件的这个函数onInit： this.dataService.getDataStreamWORKS AND ALWAY
浏览 13提问于2017-07-12得票数 1
我想使用rxjava2实现简单的生产者-消费者模型，当下游请求一个，上游发出一个。
我知道flatMap或observeOn具有默认的缓冲区大小128，所以我设置缓冲区大小为1，但它也不起作用。
浏览 5提问于2017-12-01得票数 0
回答已采纳
当在类属性声明级别初始化可观察到的管道时，为什么ngOnInit中的管道在异步管道打开可观察到的包时不被触发？我知道我可以在ngOnInit本身中进行初始化，但我只是想更好地了解RxJS流是如何工作的。我也知道我可以在subscribe()中调用ngOnInit，但这不是我的意图。
浏览 3提问于2022-07-13得票数 0
在我的服务中，我创建了一个可观察到的，我将在另一个组件中使用的import { Subject } from '，我订阅了可观察到的内容。this.autoShownModal.hide(); this.isModalShown = false;因
浏览 0提问于2018-03-06得票数 2
我试图从我的角度前端调用后端API，并在使用Postman客户端应用程序进行测试时获取数据。当我试图在我的订阅函数中记录控制台日志时，它会进入控制台。但是，当我试图打印后函数子句时，它给出的是未定义的。我的函数调用类似于component.ts文件中的以下内容，.getWeightedAverageByRoomAllocationIdApiMethod
浏览 8提问于2022-04-25得票数 0
1回答
问题：--我使用Subject可观察到在组件之间传递字符串数据(在层次结构中相距太远)。当组件订阅或取消订阅时，我想知道主题的订阅者有多少。如何才能实现上述目标？对不起，我是RxJS的新手。背景：我在顶部(导航栏)有一个简单的搜索/筛选字段。主视图显示一个组件，一些组件是可搜索的，另一些则不是。每个可搜索组件订阅搜索/过滤器(通过服务)。I希望
浏览 9提问于2021-04-27得票数 0
此日志应包括详细信息，如：该日志还应该存储在文件系统上的文件中，一些可能性ActiveRecord：：观察者
观察者为观察这些特殊事件提供了一种很好的</em
浏览 5提问于2012-06-06得票数 3
回答已采纳
我希望订阅A和订阅B都能收到videosNeedFix observable发出的数据。
然而，根据控制台日志，只有订阅A将接收数据，而不是subscriptionB。如果我交换两个订阅的顺序，则只有subscriptionB才能看到数据。为什么可观察对象只向第一个订阅发送数据？
浏览 0提问于2014-09-03得票数 3
1回答
如何将额外的对象添加到集合中，该集合最初已订阅了模板中可观察到的对象。因此，我的组件中有一个变量，它是可观察的，然后我执行一些http请求，并将可观察的设置为这个服务请求，如下所示.
this.logs$ = this.service.getLogs然后，在模板中，我使用异步管道订阅了这个可观察的对象。
浏览 0提问于2018-10-19得票数 0
回答已采纳
2回答
我有以下可观察的：messages$: Observable<Message[] | undefined>。Message有两个字段：id和content，这两个字段都是字符串。我想做的是修改messages$，以便在每个Message的content上调用一个函数foo(string)。
从表面上看，这似乎并不困难，但我对可观察到的东西并不熟悉，不幸的是，我被困住了。
浏览 2提问于2022-04-05得票数 0
问题当用给定的数据调用Observable.of时，HttpClient应该将数据返回给已经订阅它的方法。演示有一个服务(mock.service.ts)使用HttpClient发出模拟HTTP请求，该请求到达mock.interceptor.
浏览 3提问于2017-12-04得票数 0
回答已采纳
当某些订阅者订阅一个可流动的并且这个可流动的项发送给订阅者时，每个订阅服务器能得到不同的值吗？例如，如果一个可流动的一个观察者得到0，2，另一个观察者得到1，3，等等，就像负载均衡器一样。
浏览 1提问于2016-11-10得票数 2
回答已采纳
2回答
我遇到了一个问题，在谓词为true时，我想订阅一个可观察的流，在谓词为false时停止订阅。当谓词在将来的某个点再次为真时，它应该重新订阅可观察的流。用例：
如果无法将日志实体插入到应该取消订阅流的数据库中，则有可观察的流作为输入(IObservable<IList<LogEntity>> items)；当数据</
浏览 0提问于2016-02-03得票数 1
回答已采纳
我正在开发一个web应用程序，它显示事件日志数据，类似于事件查看器。应用程序还必须为用户提供一种方式，以便在将条目写入订阅的日志时使用web服务订阅事件日志并接收通知。eventLog.EntryWritten += new EntryWrittenEventHandler(eventLog_EntryWritten);我正在尝试使用观察者作为事件日志的订阅
浏览 0提问于2011-05-19得票数 6
回答已采纳
我在代码中使用了几个可观察对象来从数据库中检索数据。但是，在我的一个可观察的订阅中，还有另一个嵌套订阅，当调用第一个订阅时，它会导致第二个订阅中的代码被调用三次。然而，这没有任何意义，因为第一个订阅只接收一个对象，因此它的next()函数中的代码应该只调用一次。但是，如果我查看我的控制台，我的
浏览 0提问于2019-07-24得票数 0
1回答
我有一个API调用，我想用可观察到的方式包装它： final Observablereturn Observable.from(accounts); });
如何使用可观察到的我需要处理帐户流，并从中提取不同的数据集。
浏览 2提问于2015-03-26得票数 2
回答已采纳
我派了一个有角度的路由创作者把我的页面。我有一个api，它检查令牌是否有效，并在此基础上返回true或false，以便进一步导航。但似乎在“订阅”中，我指定了我的“结果”标志true，而不是在订阅之外持久化。“结果”变量在错误的范围内吗？我该怎么纠正呢？请帮助我理解我在以下代码中的错误。result = false; }); return res
浏览 5提问于2017-12-21得票数 2
回答已采纳
我不太清楚可观察和订阅是如何工作的。特别是一个可观察的和它的订阅是如何交换信息的。
可观察的“将”数据
浏览 0提问于2018-08-24得票数 0
回答已采纳
2回答
与多个订阅者一起调用部分流？
、、、、
我有用于套接字通信的自定义Rx适配器。在它之外，我观察到消息是可流动的。然后我有一个管理器来处理每条消息，然后进一步发出它。.doOnNext{ }
然后我有两个订阅者执行我想要找到的方式，其中的一部分流将是常见的每一个订户。不幸的是，.share()操作符在observeSocket()结尾处不能工
浏览 1提问于2017-10-12得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
