当我将主题订阅为可观察主题时，我无法获取数据(rxJS 5.5.2)
当将主题订阅为可观察主题时，无法获取数据的问题可能是由于以下几个原因导致的：
- 订阅未成功：确保你已经正确地订阅了可观察主题。在 rxJS 5.5.2 中，你可以使用
subscribe方法来订阅主题。例如：
observable.subscribe(
data => {
// 处理接收到的数据
},
error => {
// 处理错误
},
() => {
// 处理完成
}
);- 数据未发送：检查可观察主题是否在订阅之前发送了数据。有些可观察主题可能需要手动发送数据，而不是自动发送。你可以使用
next方法来发送数据。例如：
observable.next(data);- 数据发送顺序问题：确保数据发送的顺序是正确的。有时候，数据可能在订阅之前发送，导致无法获取到数据。你可以尝试调整数据发送的时机，确保在订阅之后再发送数据。
- 版本兼容性问题：确保你使用的 rxJS 版本与你的代码兼容。不同版本的 rxJS 可能有不同的 API 和行为。你可以查阅 rxJS 5.5.2 的官方文档或者 API 参考来确认你的代码是否符合该版本的要求。
如果以上方法都无法解决问题，你可以进一步检查你的代码逻辑，确保没有其他因素导致无法获取数据。此外，你还可以参考 rxJS 的官方文档和社区资源，寻求更多关于可观察主题订阅的帮助和解决方案。
腾讯云相关产品和产品介绍链接地址：
- 腾讯云云原生产品：https://cloud.tencent.com/solution/cloud-native
- 腾讯云音视频处理服务：https://cloud.tencent.com/product/mps
- 腾讯云人工智能服务：https://cloud.tencent.com/product/ai
- 腾讯云物联网平台：https://cloud.tencent.com/product/iotexplorer
- 腾讯云移动开发平台：https://cloud.tencent.com/product/mwp
- 腾讯云对象存储服务：https://cloud.tencent.com/product/cos
- 腾讯云区块链服务：https://cloud.tencent.com/product/tbaas
- 腾讯云元宇宙服务：https://cloud.tencent.com/product/umc
相关·内容
2回答
在角应用程序中，从服务器获取数据有不同的方法：
从服务中获得可观察性，并在组件上订阅它
在服务中创建主题，在组件上订阅主题
这两种方法都适用于我，但我不知道该用哪种方法。
First method.从服务中获得可观察性，并在组件上订阅它
article.service.ts
import { Injectable } from '@angular/core';
import { Article } from '../models/article';
import { AngularFirestore } from '@angular/fi
浏览 0提问于2019-08-24得票数 3
回答已采纳
2回答
在我的项目中有许多使用异步/等待的代码。但是我想把所有的代码都转到rxjs代码上。
但我不习惯用rxjs。请告诉我将异步/等待代码转换为rxjs的模式或方法。或者请推荐一个例子。
这是我的原始代码(使用异步/等待)
this.userHistory$ = new Subject();
async getUserStatue(userId, query){
const userData = await this.UserApi.getUserInfo(userId, query);
this.userHistory$.next(userData);
}
下面的代码是我试图使用rxjs
浏览 7提问于2022-05-16得票数 0
比方说，我在数据库中有100多个项目，确切的数量还不清楚。如果我提供开始项目ID和所需的项目数，我的后端API将给出所需的项目数。项ID从0开始，并增加1。
我希望一批一批地获取它们(例如，每批10项)，以便在客户端进行处理。处理完一批后，我想取下一批。
在我的RxJS项目中使用Angular 2实现这一目标的最佳方法是什么？
浏览 3提问于2017-02-05得票数 0
回答已采纳
所以，基本上，rxjs是新的，想知道，
我是否需要从Observable.of(数据)或更新的rxjs版本中取消订阅(数据)？
即
import {of} from 'rxjs';
const sub = of(data).subscribe();
这有必要吗？
sub.unsubscribe();
浏览 2提问于2019-04-28得票数 6
1回答
我正在从我的data.service.ts接收一个数组，并想知道如何访问它。我目前只是在控制台中打印它来尝试理解它，但是我不知道如何处理数组中的数据。
单击下面的链接查看控制台中的数据格式：
在我的footer.component.ts中：
import { Component, OnInit } from '@angular/core';
import { DataService } from '../data.service';
@Component({
selector: 'app-footer',
templateUrl: &
浏览 1提问于2020-12-23得票数 0
1回答
我正在升级到角5和RxJS 5.5.2，并试图导入Observable.of操作符。
在可租操作人员之前，我们这样做：
import 'rxjs/add/observable/of';
// Usage
Observable.of(...)
但是现在不鼓励从包含add的路径中导入。
那么，现在导入和使用可租静态操作符的正确方法是什么呢？
浏览 6提问于2017-11-08得票数 3
回答已采纳
2回答
我有一个使用ngx-formly(动态表单)的角应用程序，其格式类型(select)中有一个subscribe()。在组件中，formly表单是为formly类型使用Observable定义的，并动态创建。
在组件中，我有一个Subject和按钮，生成一个next()，格式类型不接收数据(也没有收到完整的)。组件本身中的subscribe()可以工作。
从Subject到BehaviorSubject<number>()，我只收到一次格式类型的数据，但没有收到关于next()的进一步数据。
代码用于步骤/向导中，更改为下一步，此步骤中的所有select都应该重新加载它们的选项。
这
浏览 0提问于2018-10-08得票数 0
回答已采纳
1回答
我问这个问题是因为我尝试了下面的代码：
//RxJs v5.5.2; NodeJs v7.10.1
var Rx = require('rxjs/Rx');
var observable = Rx.Observable.of(1,2,3);
var sub = observable.subscribe(console.log);
var sub1 = observable.subscribe(console.log);
它输出1 2 3 1 2 3(新行省略)。
然而，正如RxJs的文档所指出的，可观察是一个流，那么为什么第二个订阅会得到所有的值呢？我的理解是，在第一次订阅
浏览 2提问于2017-11-18得票数 0
回答已采纳
1回答
我想使用rxjs样式读取目录，但无法工作。
import { readdir } from 'fs';
import { bindNodeCallback } from 'rxjs/observable/bindNodeCallback';
import { tap } from 'rxjs/operators';
function test() {
bindNodeCallback(readdir).pipe(
tap((x: any) => console.log(x))
).subscribe();
}
tes
浏览 1提问于2018-05-26得票数 1
回答已采纳
我有一个父MatHorizontalStepper组件，它使用subscribe来检查服务中的Observable是否已经从false更新到true。如果可观测值发生了变化，则自动移动到步进器的下一步。
但是，我似乎无法让更新来正确地更改步骤。下面是我创建的两个组件。
父组件
import { Component, OnInit, ViewChild } from '@angular/core';
import { Observable } from 'rxjs/Observable';
import { MatHorizontalStepper } from
浏览 0提问于2018-06-19得票数 0
回答已采纳
1回答
我已经开发了一个应用程序，它使用行为主体为所有组件进行数据传输，这真的是一个使用可观察概念的良好实践吗？
import { BehaviorSubject } from 'rxjs';
const subject = new BehaviorSubject(123);
// two new subscribers will get initial value => output: 123, 123
subject.subscribe(console.log);
subject.subscribe(console.log);
// two subscribers wi
浏览 0提问于2020-03-02得票数 0
回答已采纳
1回答
以下是解决相同问题的两种方法，即对用户在文本框中输入的某些字符进行反应性搜索。第一个解决方案来自，第二个解决方案来自即时搜索课程。
第一个解决方案使用Observable，第二个解决方案使用Subject。
Observable解决方案只使用takeUntil调用服务器一次。Subject解决方案使用distinctUntilChanged。
有人能解释一下这两种方法的优缺点吗？
使用可观察到的搜索：
@Injectable()
export class BookEffects {
@Effect()
search$: Observable<Action>
浏览 2提问于2017-03-06得票数 1
2回答
热与冷观测
、、
在RxJS中，热观测是使用外部生产者的可观测性，而冷可观测的是使用本地生产者(参见)。
无论何时打电话，HttpClient.post都会使用冷观测值发送数据和重复。
有什么方法可以从角度上判断某一特定方法是否使用了可观察到的热或冷？
浏览 0提问于2017-09-06得票数 10
回答已采纳
所以，这就是我的用例:我从rest API获取一个observable，然后通过在模板中使用async来获取数据。单击时，我将获得特定用户的ID，然后使用该用户的数据填写表单。为了实现后者，我重用现有的观察值并过滤数据，然后订阅它。我想知道我的方法是否正确，因为我认为当我点击“编辑”来填写表单时，应用程序太慢了，所以我猜我在这里创建了太多的订阅或诸如此类的东西？
另外，为了便于讨论，我创建了两个可观察对象(user和users)，其中一个(user)获得了对另一个(users)的“引用”，然后它用async显示在模板中，同时我还订阅了它并将其设置为“常规”变量。这是一个问题吗？使用async显
浏览 0提问于2017-11-05得票数 0
1回答
在发布这篇文章之前，我讨论了许多其他类似的问题，但无法找到解决方案。就像
我正在使用AWS会话，它为我提供了发出HTTP请求的授权令牌。现在，获取会话可以是异步操作，具体取决于刷新令牌的需要。
问题: HTTP无法链接获取会话，然后进行调用。
版本的角5，RxJ 5.5.2
AuthService的get会话函数.
getSession(): Observable<any> {
const sessionOb = new Subject<CognitoUserSession>();
// AysnFn4session is a c
浏览 3提问于2017-12-18得票数 0
回答已采纳
我有一个简单的代码，返回缓存的公司或从数据库的公司。问题是我几乎在同一时间从两个不同的地方订阅了这个观察点。这会触发对数据库的2次调用，所以我只想在第一次调用完成并且缓存值已经存在的情况下运行第二次订阅。有没有通过rxjs运算符执行此操作的标准方法？
public current(): Observable<Company> {
if (this.cachedCompany) {
return Observable.of(this.cachedCompany);
} else {
if (this.
浏览 0提问于2018-05-25得票数 1
我正在从api(在服务文件中)获取数据，并且在ts文件中订阅。我没有使用rxjs(observable和subscription) .I对于在angular 7中不使用rxjs时是否需要取消订阅感到困惑。如果需要取消订阅，那么如果不使用rxjs，我们如何才能取消订阅
// ts
export class ViewDataComponent implements OnInit {
regions: Region[];
dataSource: MatTableDataSource<PaginatedMapData>;
constructor(private
浏览 2提问于2019-08-06得票数 0
1回答
我想使用现有的rxjs运算符来创建一个多播可观察对象，它在每次订阅其源时重新订阅，但不会在源完成时取消订阅其订阅者。 其意图是拥有共享相同数据源的短期组件和长期组件的混合。当创建一个新的短期组件时，应该更新新组件和任何也订阅了数据源的长期组件的共享数据。 使用Observable.create()，我能够创建一个定制的可观察对象来产生这种行为，但感觉上可能有一个开箱即用的解决方案，不需要编写定制代码。 这是我尝试过的方法。 import { of, Observable, Observer, zip, interval, merge } from "rxjs";
import
浏览 19提问于2019-08-24得票数 0
1回答
我正在尝试构建一个包含多个组件的应用程序，这些组件使用来自服务器的事件。该应用程序是在角，并使用rxjs。
我没有找到与我的用例相匹配的例子。
例如，以货币更新为例，在UI层中有多个订阅者，以及用于数据访问和业务逻辑的多个提供者(都在客户端)。
我实现了一个客户端服务，它获取货币并返回一个可观察到的：
update: function (from, to) {
var urlForCurrencies = createConverterUrl(from, to);
var observable = Rx.Observable.fromPromise(
$http
浏览 4提问于2015-08-17得票数 0
回答已采纳
2回答
我正在慢慢地学习RXJS，并学习如何在React的上下文中使用它。 我发现的所有Rxjs教程都是从可观察性开始的。这是有道理的。当我尝试在react中使用可观察对象时，它不起作用。相反，我必须创建一个主题，并将价值推向主题。 为什么会这样呢？为什么我不能在React中使用普通的老式观察值？我做错了什么吗？有人能解释一下为什么react中的RXJS必须使用主题吗？ 我意识到这有点模糊，但我还不能理解概念来表达更好的问题。这里有一个例子来说明我正在努力理解的东西。 下面是一个非常简单的组件，它接受输入值中的一个值并显示它。常规的react，没有RXJS。 const InputBox = ()
浏览 17提问于2019-10-14得票数 0
回答已采纳
我在我的应用程序中使用了RXJS websocket。登录后，数据从我的服务器发送到客户机，并将数据存储在一个可观察对象中，在导航应用程序时使用shareReplay保存数据。 if(!this.data$ || this.data$Completed) {
this.data$ = this.dataService.get(this.CTRL, 'list').pipe(
finalize(() => {
console.log('finalizing data list');
t
浏览 28提问于2021-02-11得票数 0
2回答
尝试用一些数据向我的服务器发布一个简单的帖子，并让它返回一些JSON数据。(目前，它在呼叫中运行，但我在我的网络选项卡上没有看到它真的试图进行吗？)
我的服务(api.service.ts)
import { Injectable } from '@angular/core';
import { Headers, Http, Response} from '@angular/http';
import {Observable} from 'rxjs/Rx';
// Import RxJs required methods
import
浏览 1提问于2016-12-28得票数 12
回答已采纳
6回答
在我的Angular 2应用程序中，我有很多观察点和订阅。当然，当我离开页面时，我应该取消订阅，但我想知道是否有可能获得活跃订阅的数量。只是为了提供调试信息或者当我忘记退订的时候。
在rxjs中有这样的信息吗？
浏览 2提问于2016-09-04得票数 26
我有个测试
const Rx = require('rx')
const fs = require('fs')
const {streamToRx} = require('rxjs-stream')
it('should not be infinite', done => {
let streamObservable = streamToRx(fs.createReadStream('/some/file.txt'));
Rx.Observable.of(1).flatMap(any => s
浏览 1提问于2018-04-11得票数 0
回答已采纳
1回答
角4元件与RxJ的通信
、、、
我正在遵循教程。使用可以很好地接收消息，但不适用于其他组件。我使用MessageService作为@ngModule中的整个应用范围。Appcomponent接收消息，但其他组件可以发送消息，但不接收消息。
import { Injectable } from '@angular/core';
import { Observable } from 'rxjs';
import { Subject } from 'rxjs/Subject';
@Injectable()
export class MessageService {
浏览 5提问于2017-12-23得票数 1
2回答
Subject和AnonymousSubject在RxJS 5中有什么区别？我在网上搜索过，但没有找到任何关于AnonymousSubject的信息。
我在网上找到了一个例子
Subject.create(observer, observable);
查看一下rxjs源代码，我看到这会创建和AnonymousSubject。您还能举个例子说明什么时候使用AnonymousSubject比较好吗？
浏览 9提问于2017-02-09得票数 5
回答已采纳
1回答
我有一个多页的网站(使用路由器)，并希望携带一个可变的价值从一个网页到另一个。
在我的联系人表单页面上，我有以下代码：
testName:string = "hello";
ngOnInit()
{
this.dataService.Stream
.subscribe(
(city:City) => this.processData(city),
(err) => console.log('Error at processing data'),
浏览 0提问于2018-10-24得票数 1
回答已采纳
示例：
import { BehaviorSubject } from 'rxjs';
import { share } from 'rxjs/operators';
const subject = new BehaviorSubject(123);
const obs = subject.asObservable().pipe(share());
obs.subscribe(console.log);
obs.subscribe(console.log);
obs.subscribe(console.log);
obs.subscribe(conso
浏览 0提问于2019-12-24得票数 0
回答已采纳
我是一个新手，不知道我的方法有什么问题，请建议如何解决以下问题。
下面是我要做的事情，当我访问主应用程序页面时，它从config.service.ts调用getConfigs()，并从后端update this.configStringSource.next(config)获取数据。在它重定向到this.router.navigate(‘/克隆/状态’)之后，我就没有从config.service.ts获得数据
如果我使用ngAfterContentChecked，config-server.service.ts在执行status.component.ts之前执行，并按预期的方式获取正确的数据
浏览 1提问于2017-09-05得票数 1
3回答
我试图从我的WebAPI中获取JSON数据，但它不起作用。每当我试图在组件中使用返回对象时，我都会得到undefined。
我想在我的网站的主页上显示学生和课程的数据。目前，我的控制器/ api正在返回硬编码的数据。
student.service.ts
import { Injectable } from '@angular/core';
import { Observable } from 'rxjs/Observable';
import { Http } from '@angular/http';
import 'rxjs/add
浏览 2提问于2017-03-20得票数 2
回答已采纳
我正在访问一个从服务器获取数据的服务。一旦数据到达，我希望将其处理成适当的结构，然后精炼的结果就是我希望存储在另一个服务中的结果。为了将这些数据从数据处理器函数共享到服务，我希望使用一个事件。
有没有办法让我这么做。我使用了RxJS的广播事件。
浏览 2提问于2018-01-08得票数 0
我遇到一个正在进行的项目，让多个不相关的组件互相通知更新数据，有没有更干净的编码方法？
有3个组件(更可能在后面)和一个公共数据组件。它们彼此之间没有父子关系，只显示在同一个屏幕上。
期望的效果是按下任何组件的按钮，更新公共数据的内容，并通知您自己和其他组件从公共数据中获取新的消息。
目前，我的方法是使用Rx的Observable和Subscription，但是它们必须导入到每个组件的component.ts和service.ts文件中，并且出现了很多重复的代码，非常混乱，不知道哪个更好。练习？
谢谢!
我的代码:示例名称为test-a-comp (a.b.c以此类推，代码相同)
test-a
浏览 1提问于2018-11-24得票数 0
我用角度4和材料设计写表格，我想把数据从服务绑定到表。我的服务是使用http从服务器获取数据，因此返回承诺或可观察。如何将可观测或承诺方法的结果分配给dataChange类型的变量BehaviorSubject<>？
import { Component, OnInit, ElementRef, ViewEncapsulation, ViewChild } from '@angular/core';
import { DataSource } from '@angular/cdk';
import { BehaviorSubject } from &
浏览 2提问于2017-07-25得票数 1
回答已采纳
我用角写这个应用程序，我用的是解析器。
一旦用户加载了给定的页面，就会有一个API被解析器击中，需要传递的参数之一是用户的国家。为了获取这些信息，我使用了ip-api.com API。
这是我的问题。因为我使用的是可观测数据，所以在请求发出之前，我无法及时得到国家的位置。我需要先让用户的国家，然后发送请求。
我的想法是创建一个在root中注入的服务，所以一旦应用程序启动它的构造函数，就会执行一个方法来获取用户位置数据。然后，我将数据存储在BehaviorSubject上，以便以后需要它的任何类都可以访问它。
如何确保在任何请求发出之前，我总是拥有所需的数据？
如果用户来自主页面，一切正常工作，
浏览 1提问于2021-09-11得票数 2
当最后一个主题观察者从主题中取消订阅时，AsyncSubject变得可观察。这是
当它完成了，它就完成了。主题在未订阅、完成或错误后不能重用。
下面是演示：
const ofObservable = Rx.Observable.of(1, 2, 3);
const subject = new Rx.AsyncSubject();
ofObservable.subscribe(subject);
subject.subscribe((v) => {
console.log(v);
});
subject.unsubscribe((v) => {
cons
浏览 2提问于2017-07-14得票数 4
回答已采纳
2回答
我对角度非常陌生，我正在尝试将异步数据从服务中显示到组件中。当我这样做，数据似乎更新，但组件只显示新的数据后，我单击一个按钮。在我看来，当我的服务中的数据被更改时，DOM似乎没有被更新，只有当我告诉它的时候，才会更新，在这个例子中，单击一个按钮。
我的app.component.ts：
import { Component } from '@angular/core';
import { AuthserviceService } from './services/authservice.service';
import { Subscription } from
浏览 1提问于2019-03-13得票数 0
我发现可以在我的组件中显示警报，但是从Angular 5.2.0和rxJS 5.5.2开始，我无法获得警报。
我在每个地方都放了一些控制台日志，以了解问题是什么，但我没有找到它。
我认为问题与主题asObservable有关:我可以订阅它，但没有数据。
alert.service.ts
import { Injectable } from '@angular/core';
import { Router, NavigationStart } from '@angular/router';
import { Observable } from 'rxjs&
浏览 1提问于2018-02-06得票数 0
回答已采纳
我正在尝试创建一个服务来对用户进行身份验证并将令牌存储在localStorage中。我希望其他服务(特别是auth卫士)能够访问当前用户，因此我已经设置了身份验证服务的构造函数，如下所示：
currentUserSubject: BehaviorSubject<Token>;
constructor(private http: HttpClient) {
this.currentUserSubject = new BehaviorSubject<Token>(JSON.parse(localStorage.getItem('currentUser
浏览 2提问于2019-08-21得票数 1
回答已采纳
4回答
我发现将它们定义为
什么是主题？RxJS主题是一种特殊的可观察类型，它允许对许多观察者多播值。虽然普通的可观测性是单播的(每个订阅的观察者都拥有一个独立的可观测执行)，但主题是多播的。
它接着给出了一些例子，但我正在寻找一个基本的ELI5解释。据我所知，它有助于处理和定义序列中的项。对吗？
我认为，使用和不定义rxJS Subject来理解为什么它是重要的，这将对我和其他人非常有帮助。
谢谢!
浏览 5提问于2016-10-05得票数 14
1回答
我必须从两个订阅者那里获得数据，但我总是得到第一个订阅者的数据。
我有一个数据共享服务：
import { Injectable } from '@angular/core';
import { BehaviorSubject } from 'rxjs/BehaviorSubject';
@Injectable()
export class DataService {
private source = new BehaviorSubject<any>('');
data = this.source.asObser
浏览 1提问于2018-01-29得票数 3
回答已采纳
2回答
我感到困惑的是，这个rxjs tap()操作符从未在这个简单的角度组件中触发，而Subject值却在屏幕上得到更新。我还尝试使用BehaviorSubject代替使用相同的结果。我在这里做错了什么？
import { Component } from '@angular/core';
import { Subject, BehaviorSubject } from 'rxjs';
import { tap } from 'rxjs/operators';
@Component({
selector: 'my-app',
浏览 0提问于2019-06-24得票数 2
回答已采纳
我正在通过这个学习Angular2。
下面的代码突然出现了。为什么"missionAnnounced$“没有变量声明？让任务宣布$= ...下面代码的逻辑是什么？
import { Injectable } from '@angular/core';
import { Subject } from 'rxjs/Subject';
@Injectable()
export class MissionService {
// Observable string sources
private missionAnnouncedSource = n
浏览 0提问于2016-10-30得票数 9
3回答
在我的角度应用程序中，当我登录到应用程序时，我会得到一个访问令牌，我需要在其他组件(而不是父/子关系)的API调用中使用它。我试过使用共享服务，但它不起作用
数据服务：
import { Injectable } from '@angular/core';
import { Subject } from 'rxjs/Subject';
@Injectable()
export class DataService {
private userInfo = new Subject<any>();
currentuserInfo$ = t
浏览 4提问于2018-04-17得票数 0
回答已采纳
3回答
目前正在学习RxJS。我在服务中有一个整数selectedCourseIndex，我希望订阅一个单独的组件。
courses-section.service.ts
private selectedCourseIndex: number = -1; //this number can change from another method
private selectedCourseIndexUpdated = new Subject<number>();
getSelectedCourseUpdateListener(){
return this.selectedCours
浏览 1提问于2019-06-05得票数 5
2回答
这里有组件代码，当我订阅可观察到的服务时，这个服务会被调用两次，但是如果我订阅了行为主题，它只被触发一次，
我可以在我的日志中看到这些结果，请查看我的组件下面的代码--在ngOninit上调用方法ngOninit()方法。
import { Component, OnInit } from '@angular/core';
import { Router } from '@angular/router';
import { Observable } from 'rxjs/Observable';
import
浏览 0提问于2017-08-16得票数 5
回答已采纳
我有一个数组，如下所示。
data = [
{
id: 1,
name: 'a',
status: true,
},
{
id: 1,
name: 'b',
status: true,
},
{
id: 1,
name: 'c',
status: false,
},
];
我通过将初始值设置为上面的数组来创建BehaviorSubject。
我希望获得数据数组，通过使用rxjs pipe
浏览 2提问于2022-02-18得票数 0
回答已采纳
我有一个组件，我将数据发送到Service，在Service中，我使用Subject发出数据。在2 2ndComponent中，我订阅了这个主题。但是我无法获得我订阅的第二个组件中的数据。
组件一
editUser(user){
this.dashboardService.editUser(user);
this.router.navigate(['/form']);
}
Service.ts
import { Subject } from 'rxjs';
mySubject= new Subject<any>();
formData
浏览 5提问于2020-04-13得票数 0
回答已采纳
import { of, Subject, interval } from 'rxjs';
import {
tap,
startWith,
map,
delay,
publishReplay,
publish,
refCount,
withLatestFrom,
switchMap,
take
} from 'rxjs/operators';
const a$ = new Subject();
const b$ = a$.pipe(
map(a => {
console.log('expen
浏览 45提问于2021-07-06得票数 4
根据我目前对ReplaySubject在RxJS中的理解，下面的代码应该可以工作：
import { ReplaySubject } from 'rxjs/ReplaySubject';
private dataObs = new ReplaySubject(1);
get_posts(value) {
console.log(this.dataObs.observers.length);
if (this.dataObs.observers.length) {
console.log('Going cache');
浏览 0提问于2018-03-12得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
