RxJS:接受自己的旧值作为输入的可观察对象
RxJS是一个用于处理异步数据流和事件的库，它基于观察者模式和迭代器模式。它提供了一种响应式编程的方式，使得处理数据流变得更加简单和可组合。
RxJS中的可观察对象是一种特殊的对象，它可以发出多个值，并且可以被订阅以便接收这些值。可观察对象可以接受自己的旧值作为输入，这意味着它可以对自身的状态进行监测，并在状态发生变化时发出新的值。
RxJS的可观察对象具有以下特点：
- 异步处理：可观察对象可以处理异步操作，例如从服务器获取数据或处理用户输入。
- 可组合性：可观察对象可以通过各种操作符进行组合和转换，以便对数据流进行处理和转换。
- 错误处理：可观察对象可以处理错误，并通过错误处理机制传递错误信息。
- 取消订阅：可观察对象可以通过取消订阅来停止接收值，以便释放资源或取消不再需要的操作。
RxJS的应用场景包括但不限于：
- 前端开发：在前端开发中，可观察对象可以用于处理用户输入、异步请求、事件处理等。
- 后端开发：在后端开发中，可观察对象可以用于处理异步操作、数据库查询、事件处理等。
- 移动开发：在移动开发中，可观察对象可以用于处理用户输入、网络请求、数据更新等。
- 数据流处理：可观察对象可以用于处理数据流，例如数据过滤、转换、合并等。
- 响应式编程：可观察对象可以用于实现响应式编程，使得数据的变化能够自动传播和更新。
腾讯云提供了一些与RxJS相关的产品和服务，例如：
- 云函数（SCF）：腾讯云函数是一种无服务器计算服务，可以使用RxJS来处理函数的异步事件和数据流。
- 云数据库 MongoDB 版（TencentDB for MongoDB）：腾讯云数据库 MongoDB 版支持使用RxJS来处理数据库查询和数据流。
- 云消息队列（CMQ）：腾讯云消息队列是一种高可靠、高可用的消息队列服务，可以使用RxJS来处理消息的异步处理和传递。
更多关于腾讯云产品和服务的信息，请访问腾讯云官方网站：https://cloud.tencent.com/
相关·内容
1回答
我想将一段代码从NodeJS回调转换为RxJS，但我不确定我是否以正确的方式完成了它。我一直在犯错。
原始代码：
function signup(poolData, body) {
const { username, password, attributes } = body;
userPool.signUp(username, password, attributes, null, (err, res) => {
if (err) return cb(err);
const cognitoUser = res.user;
const data = {
浏览 2提问于2020-03-01得票数 0
回答已采纳
对于rxjs中操作符的各种定义，我有点困惑。
下面我提供一些定义：
A Pipeable Operator是一个函数，它以一个可观察的输入作为输入，返回另一个可观察的。
Creation Operators是另一种操作符，可以称为独立函数来创建一个新的可观察的。
操作符是一个函数，它以一个可观测的(源)作为其第一个参数，而返回另一个可观测的(目标，或外部可观测的)。
操作符接受配置选项，并返回一个函数，该函数接受一个可以观察到的源。
运算符应该总是返回一个可观察到的。--如果您创建了一个方法，它返回的不是一个可观察到的东西，那么它不是一个操作符，这很好。
因为1,2,4似乎与3有冲突
浏览 2提问于2020-02-06得票数 2
我有一个Svelte应用程序，其中我使用watchQuery订阅查询。我想使用rxjs中的takeWhile运算符，但是我得到了这个错误： TypeError: $client.watchQuery(...).takeWhile is not a function 有没有办法将takeWhile与apollo-client的watchQuery订阅一起使用？ 这是我的代码： $client.watchQuery({
query: SomeRandomQuery,
variables: {},
})
.pipe(takeWhile(() => isAlive))
.subscri
浏览 26提问于2020-07-02得票数 0
我在尝试运行git bash时遇到了这个问题。.switchMap未执行，并显示错误为“error TS2339:属性'switchMap‘在类型'Observable’上不存在”“
我使用的代码是：
import { User } from './../classes/user';
import { Injectable } from '@angular/core';
import { Router } from '@angular/router';
import { Observable, of } from 'rxj
浏览 0提问于2019-03-17得票数 2
我试着从网址栏中得到路线和查询。下面的代码来自CodeWithMosh的一个教程。我在combineLatest方法中得到编译错误。
错误如下：
(property) paramMap:类型'{ paramMap:可观测的；queryParamMap:可观测的；}‘的可观测参数不能分配给类型“观察者输入”的参数。
对象文字只能指定已知的属性，而'paramMap‘在'ObservableInput’类型中不存在。
我是一个角度方面的新手，我不知道这个错误意味着什么，我试着遵循堆栈溢出的答案，但是我仍然得到了错误。谢谢。
完整的代码如下：
import { A
浏览 3提问于2019-09-27得票数 2
回答已采纳
我正在尝试用RxJS大理石创建一个简单的测试。
我在用摩卡咖啡和印度茶。
我正在实例化一个新的测试调度程序，并且我不想使用"testScheduler.createHotObservable方法“，因为我想使用我自己的可观察对象"Observable.of(4)”。
const testScheduler = new TestScheduler(assert.deepEqual.bind(assert));
const expected = "a";
const expectedStateMap = {
a: 4
浏览 4提问于2017-11-16得票数 0
1回答
最近，我一直试图在一个react应用程序中使用rxjs来提取API请求，这就是我想出的解决方案。
你对这件事的看法如何？
我是否应该跟进一些好的做法呢？
如果有什么好的解决办法，请告诉我。
import axios from 'axios';
import { Observable } from 'rxjs';
import './App.css';
export class App extends Component {
state = {
users: []
};
componentDidMount() {
c
浏览 2提问于2020-03-01得票数 0
所以，基本上，rxjs是新的，想知道，
我是否需要从Observable.of(数据)或更新的rxjs版本中取消订阅(数据)？
即
import {of} from 'rxjs';
const sub = of(data).subscribe();
这有必要吗？
sub.unsubscribe();
浏览 2提问于2019-04-28得票数 6
我得到了这个错误。我在试着用 import { catchError } from 'rxjs/operators' 而不是 import 'rxjs/add/operator/catch' 但是如何使用rxjs/add/operator/do和rxjs/add/operator/toPromise的instaed呢
浏览 9提问于2020-10-07得票数 3
在Angular 5中，我使用两个服务调用来查看是否应该允许用户查看页面，这是使用Route guard。然而，对于RXJS，我不确定处理这个问题的最好方法。
import { Injectable } from '@angular/core';
import { Router, CanActivate, ActivatedRouteSnapshot, RouterStateSnapshot } from '@angular/router';
import { AuthService } from './auth.service';
import
浏览 12提问于2018-08-21得票数 0
回答已采纳
嘿，我是下一个我的角度，我和一个团队一起工作，他们使用非常老的角度，我试图升级很多东西，我以前的rxjs是在5.4版本，现在我升级到6.5地图，捕捉和抛出不再接受，我读了一些文章也是如何转换它们，但仍然不清楚，因为大多数文章没有解释如何得到json()的回应。
下面是我以前的rxjs5.4语法
import { Observable } from "rxjs/Observable";
import "rxjs/add/operator/catch";
import "rxjs/add/operator/map";
import "rxjs
浏览 0提问于2019-05-23得票数 0
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
1回答
我一直在用房顶变换(地图，过滤器等)数据以角1。现在在@角(角2)中，显示如何使用http服务请求json的第一个例子之一使用RxJS的映射。我已经检查过RxJS有更多有用的操作符。那么，我是否应该将每个集合转换为可观测的( asObservable() )，并使用RxJS的运算符，因为它们已经包含在“角”中，并且是必需的？
浏览 0提问于2016-10-12得票数 2
回答已采纳
2回答
Subject和AnonymousSubject在RxJS 5中有什么区别？我在网上搜索过，但没有找到任何关于AnonymousSubject的信息。
我在网上找到了一个例子
Subject.create(observer, observable);
查看一下rxjs源代码，我看到这会创建和AnonymousSubject。您还能举个例子说明什么时候使用AnonymousSubject比较好吗？
浏览 9提问于2017-02-09得票数 5
回答已采纳
3回答
你好，在Rxjs文档中，我看到了这段代码：
first()(of(1, 2, 3)).subscribe((v) => console.log(`value: ${v}`));
// Logs:
// value: 1
我知道它就像[1, 2, 3].map(x => x * x)一样，但我想知道我们是否可以用原生JavaScript做同样的事情，如果可以，请给我一个例子？
我的问题是：
我不明白first()(of(1，2，3))是怎么回事，你能解释一下这段代码如何返回一个带操作符和源的可观测对象吗？我知道运算符是第一个()，源代码是()，但是它们是如何合并在一个新的可观察对象
浏览 18提问于2020-07-10得票数 1
在rxjs中，如果调用了complete方法，我是否也应该调用取消订阅？
例如，我有一个来自rxjs的timer，我将其设置为5秒。
在调用订阅函数后，我是否也应该从计时器运行取消订阅？
import { timer } from "rxjs";
const token = timer(5 * 1000).subscribe({
next: () => {
console.log("xxx");
token.unsubscribe(); // <---- should I do it to to free memory?
浏览 2提问于2021-03-23得票数 0
1回答
以下是解决相同问题的两种方法，即对用户在文本框中输入的某些字符进行反应性搜索。第一个解决方案来自，第二个解决方案来自即时搜索课程。
第一个解决方案使用Observable，第二个解决方案使用Subject。
Observable解决方案只使用takeUntil调用服务器一次。Subject解决方案使用distinctUntilChanged。
有人能解释一下这两种方法的优缺点吗？
使用可观察到的搜索：
@Injectable()
export class BookEffects {
@Effect()
search$: Observable<Action>
浏览 2提问于2017-03-06得票数 1
2回答
我正在慢慢地学习RXJS，并学习如何在React的上下文中使用它。 我发现的所有Rxjs教程都是从可观察性开始的。这是有道理的。当我尝试在react中使用可观察对象时，它不起作用。相反，我必须创建一个主题，并将价值推向主题。 为什么会这样呢？为什么我不能在React中使用普通的老式观察值？我做错了什么吗？有人能解释一下为什么react中的RXJS必须使用主题吗？ 我意识到这有点模糊，但我还不能理解概念来表达更好的问题。这里有一个例子来说明我正在努力理解的东西。 下面是一个非常简单的组件，它接受输入值中的一个值并显示它。常规的react，没有RXJS。 const InputBox = ()
浏览 17提问于2019-10-14得票数 0
回答已采纳
我已经创建了一个服务，从模拟中检索数据，如下所示：
export const PHOTOS: Photo[] = [
{
title: "title 1",
srcImage:"https:/34297040313_3436fd2556_k.jpg"
},
{
title: "title 2",
srcImage:"https://34297040313_3436fd2556_k.jpg"
}
浏览 2提问于2018-07-13得票数 1
回答已采纳
我有一个事件发射器testEvent。testEvent有一个管道链，在这个链中抛出了一个错误。但我也在链中的两个地方捕捉到了错误。尽管如此，我的testEvent还是会自动退订。
有人能解释一下原因吗？
import { Component, EventEmitter } from '@angular/core';
import {map} from 'rxjs/operators';
import {catchError, switchMap} from 'rxjs/internal/operators';
import {forkJoin
浏览 0提问于2019-08-22得票数 3
1回答
下面是我尝试使用RxJS“油门”操作符的组件代码。
import { Component , OnInit , OnChanges , DoCheck } from '@angular/core';
import { Observable } from 'rxjs/Observable';
import 'rxjs/add/operator/map';
import 'rxjs/add/observable/fromEvent';
import 'rxjs/add/operator/throttle';
@Co
浏览 0提问于2016-11-05得票数 2
回答已采纳
1回答
在正式的中，它包含以下代码
getHeroes(): Promise<Hero[]> {
return Promise.resolve(HEROES);
}
ngOnInit(): void {
this.route.params
.switchMap((params: Params) => this.heroService.getHero(+params['id']))
.subscribe(hero => this.hero = hero);
console.log(this.route.params);
cons
浏览 9提问于2017-01-29得票数 4
回答已采纳
1回答
有人能说明一下Angular 6 / rxjs 6中的take(1)的语法吗？
在下面的代码中，我从Firestore中检索了一个文档，然后将其作为一个可观察对象。
然后，我订阅了该可观察性，读取文档的时间戳，并以人类可读的格式格式化年龄。这很有效，但是不需要在文档流中每次发生更改时都执行。它只需要执行一次，因为文档时间戳永远不会改变。
如何修改此代码以合并take(1)，以便只生成一次年龄字符串，并且items订阅不会保持打开状态？在Angular / rxjs版本6下，我找不到任何清晰的take(1)语法示例，我能找到的所有示例都是针对以前版本的。
import { Component,
浏览 4提问于2018-08-05得票数 2
回答已采纳
5回答
我想我有一个基本概念，但也有一些模糊之处。
所以一般来说，这就是我使用Observable的方式
observable.subscribe(x => {
})
如果我想过滤数据，我可以使用以下方法：
import { first, last, map, reduce, find, skipWhile } from 'rxjs/operators';
observable.pipe(
map(x => {return x}),
first()
).subscribe(x => {
})
我也可以这样做：
import 'rxj
浏览 1提问于2018-02-07得票数 166
回答已采纳
在RxJS中，可观测实例的catch方法和onErrorResumeNext方法似乎几乎没有区别，除了onErrorResumeNext将原始可观测参数与可观测参数连接起来之外，无论是否发生错误。
如果是这样的话，命名是不是有点混乱？因为在出现错误的情况下，onErrorResumeNext的工作方式与catch完全相同：
var testObservable = Rx.Observable.return(1).concat(Rx.Observable.throw("Error"))
// Both onError and onCatch will emit the same
浏览 2提问于2014-10-29得票数 8
回答已采纳
我正在尝试在我的ionic 4应用程序中过滤结果。我有一个离子列表，它显示了我在ngOnInit中设置的观察值的结果。我在页面上也有一个搜索栏，可以调用一个搜索函数。我可以捕获输入，它正在传递输入，但它看起来不像是在过滤，或者可能没有更新离子列表。 我已经尝试了搜索函数和过滤函数的多次迭代，但都没有结果。我已经用( console.log )和(ionInput)尝试过了，现在我改变了输入，它可以工作，但是离子列表永远不会更新。 HTML文件 <ion-header>
<ion-toolbar>
<ion-buttons slot="star
浏览 5提问于2019-06-03得票数 0
2回答
我在试着理解。在JQuery中，我可以像这样触发自定义事件
$(document).bind('eventbus', function(e, d) { console.log(d);});
$(document).trigger('eventbus', 'test');
并传递数据(即“test”)。目前还不清楚如何在RxJS中做到这一点。我可以尝试将jquery事件转换为
var observable = $(document).ToObservable('eventbus');
但是observable返回事件对象，而不是我的
浏览 3提问于2010-06-27得票数 3
我有一个组件，我将一个对象作为它的输入传递给它。 该对象来自API，因此它不能立即可用。并且从API返回的对象也可以为空。 在模板中，我希望隐藏该值，除非它不是空对象。 所以我在我的组件中有这个： import { Component, Input, OnChanges, SimpleChanges } from "@angular/core";
import { BehaviorSubject, Observable, of } from "rxjs";
import { tap } from "rxjs/operators";
import
浏览 33提问于2020-12-14得票数 3
我正在学习使用Angular 2和Typescript在离子2中进行开发。
我马上要做的就是创建一个函数，它返回一个promise，当观察到的变量发生变化时，这个promise就会得到解析。
这将有助于我在页面组件尝试使用提供程序之前检测到提供程序中的初始化何时已完成。例如：
api.isInitialized()
.then(() => {
//api provider is initialized. Now safe to call it!
return api.fetch("NEWS");
});
.then(
浏览 0提问于2017-03-02得票数 3
我看到一些与Rx订阅/观察者相关的问题/答案，但它们可能适用于旧版本的Rx，也不适用于RxJS，它可能符合不同的API。
我的印象是订阅/订阅者和观察者都是一样的。如果您查看文档，您会发现它们位于不同的相邻部分，但似乎完全相同：
观察者：
订阅：
到底有什么不同呢？有没有人能举个例子说明两者之间的实际区别？
浏览 1提问于2017-01-31得票数 0
1回答
在查看时，我遇到了一个特定的javascript代码。
import { of } from 'rxjs';
import { map } from 'rxjs/operators';
map(x => x * x)(of(1, 2, 3)).subscribe((v) => console.log(`value: ${v}`));
我理解它的作用，但据我所知，我以前从未见过这种语法。这是哪种语法？
编辑：
我对map(x => x * x)(of(1, 2, 3))这个角色很困惑。@Olian04 04很好地解释了map()是一个高阶函数。
浏览 3提问于2020-06-02得票数 2
回答已采纳
我需要澄清操作管道在RxJS中的效率。
我目前对RxJS中的操作符管道的了解是，管道中的每个操作符接收一个可观测的，并创建一个新的(可能修改的)可观测的，作为输入返回给下一个操作符。这种行为将类似于JavaScript过滤器，映射，减少行为。因此，保留原始的可观测(流)或数组未接触/纯。
这个假设得到了RxJS文档：的支持。
Pipeable运算符是一个函数，它将一个可观测的输入作为其输入，并返回另一个可观测的函数。这是一个纯粹的操作:以前的可观察到的保持不变。
考虑到长的操作员管道，创建中间可观测数据对我来说似乎是很昂贵的。
此外，我正在阅读由Sergi编写的“用RxJS 5进行反应
浏览 0提问于2020-02-25得票数 3
1回答
管理角订阅
、、
在角应用程序中，从服务器获取数据有不同的方法：
从服务中获得可观察性，并在组件上订阅它
在服务中创建主题，在组件上订阅主题
这两种方法都适用于我，但我不知道该用哪种方法。
第一种方法。可以从服务中观察到，并在组件上订阅它：
article.service.ts
import { Injectable } from '@angular/core';
import { Article } from '../models/article';
import { AngularFirestore } from '@angular/fire/firestore
浏览 0提问于2019-08-24得票数 5
回答已采纳
import { interval } from 'rxjs';
import { take } from 'rxjs/operators'
const source$ = interval(1000).pipe(
take(4),
);
source$.subscribe(value => console.log(`Observer 1: ${value}`));
setTimeout(() => {
source$.subscribe(value => console.log(`Observer 3: ${value}`))
浏览 22提问于2020-12-18得票数 0
为了明确起见，我希望能够提供关于RxJS的事实信息，以及它与JavaScript的发展之间的关系，而不是关于RxJS有多好的意见等等。
我的问题是: RxJS ( )是否具有前瞻性，因为等在浏览器中还不是标准的，还是从根本上说，它提供的东西超出了本地JS提供的范围，超出了JS标准在可预见的将来寻求提供的范围？(诚然，也许有一天，原生的JS可能能够做到X，Y，Z，目前还没有出现在雷达上；我对这些猜测并不感兴趣。)也许是个组合。
我对这个问题的动机/兴趣在于考虑在应用程序中进行学习和实现RxJS的投资，与可用的原生JS解决方案的时间表进行权衡，以及/或是否还有其他需要提及的考虑因素，我在这里还没
浏览 2提问于2015-02-02得票数 18
回答已采纳
我正在从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
我搜索了更多关于这个论点的结果，但没有一个答案对我有帮助。我尝试使用firebase：中的url在angular中执行http.get()
正如您可以尝试的那样，它可以返回一个json。我尝试了不同的方法，但结果仍然是“不确定的”。现在我正在尝试这种模式：
import { Injectable } from '@angular/core';
// install rxjs first: npm install rxjs-compat --save
import { Observable } from 'rxjs/Observable';
import {
浏览 18提问于2020-05-12得票数 1
回答已采纳
我正在看一个关于RxJS的视频，并且遇到了一些我从未见过的TypeScript语法。这不重要，它是RxJS，这是一个通用的问题，但我想我应该补充说，它是RxJS。
我不明白这是对super()的呼唤：
class MyObservable extends Rx.Observable {
constructor(initialValue) {
super(observer) => {
observer.next(initialValue);
this.observer = observer;
}
浏览 0提问于2018-05-04得票数 0
回答已采纳
我在我的rxjs应用程序中注意到，rxjs操作符，如switchMap、map等，不起作用。(我的IDE也给出了一个提示。)当然，我运行了以下代码。如果我将switchMap替换为subscribe，就会在控制台中看到“返回的值”。
知道运营商为什么不工作吗？
import { Component, OnInit } from '@angular/core';
import {Observable} from "rxjs/Observable";
import 'rxjs/add/operator/switchMap';
@Component(
浏览 1提问于2016-12-05得票数 1
回答已采纳
2回答
我有点困惑，因为。
另一方面，有提到他们将依赖它。
因此，据我所知，角2并不直接依赖于Object.observe，而是依赖于使用Object.observe的RxJS
你能帮我了解一下这次撤退的影响吗？我也很困惑，这将如何影响功能反应的javascript开发。
如果这是个愚蠢的问题，很抱歉，但所有这些概念对我来说都是全新的。
浏览 5提问于2015-11-10得票数 11
回答已采纳
我有一个滑块组件，它会在您拖动滑块时发出数字，它的使用方法如下：<my-slider (change)="onSlide($event)"></my-slider>。我想摆脱onSlide方法，转而将change事件流绑定到Observable<number>属性(而不是回调)。
我正在为我的@Output使用Angular 2 EventEmitter。EventEmitter继承自RxJs Subject，RxJs是一个Observable和一个Observer。我希望重用EventEmitter的Observable端。
当然，我可以将
浏览 4提问于2016-01-01得票数 18
1回答
使用ES6中的新符号类型，您可以对对象设置不可迭代的属性。但是，在使用Knockout时，默认情况下不会观察到这些符号。
可以绑定符号的值，但它从未更新过，因为它没有添加到可观察的对象中。
有没有人能够解决这个问题，强迫Knockout观察符号？
浏览 6提问于2015-10-29得票数 1
这是一个在RXJS Gitter频道上提出的问题，但是没有人回答，所以我在这里发布它，希望有一个解释。
大家好，
我是一个尝试学习rxjs的Java开发人员。关于Observable声明，我有一个愚蠢的问题。为了让我的生活更轻松，我告诉自己，使用Observable就像使用Java (即使Observable是一个拉基模型)。困扰我的例子是这个:在java中，我有
Integer[] intArray =新的Integer[] {1，2，3，4，5}；流流= Arrays.stream(intArray)；//这里有一个整数流而不是Integer[]流，数组是扁平的
使用rxjs如果我这样做的
浏览 2提问于2021-08-17得票数 1
回答已采纳
https://rxjs-dev.firebaseapp.com/api/ajax/ajax 为什么rxjs ajax操作符返回一个Observable？我认为一个请求返回一个响应，连接就结束了。为什么它是可观察的，而不是单个响应消息？
浏览 13提问于2020-03-30得票数 1
回答已采纳
这是使用rxjs操作符的示例代码，我想打印/获取第二个最后的值。
类型标
import { from } from 'rxjs';
import { map, last } from 'rxjs/operators';
//emit (1,2,3,4,5)
const source = from([1, 2, 3, 4, 5]);
//add 10 to each value
const example = source.pipe(map(val => val + 10)).pipe(last());
//output: 11,12,13,14,15
c
浏览 6提问于2020-01-13得票数 7
回答已采纳
尝试创建一个rxjs管道，它将执行以下操作:本质上，我有一个动态数量的API调用数组。每次需要进行新的API调用时，我都会将其推送到数组中。
然后，我将该数组转换为RXJS切换映射操作符的数组。(调用的顺序并不重要，只是我需要在前一次调用结束后进行一次调用，而不是在同一时间)。
最后，我尝试在管道中扩展rxjs操作符的数组：
const obsArray = [randomQuote(), getCatFacts(4), recipeSearch('oil')]
const OperatorWrap = obsArray.map((obs) => {
return r
浏览 0提问于2021-01-11得票数 0
回到学习Angular和扩展英雄之旅教程。我有一个将数据加载到BehaviorSubject中的共享数据服务。问题是，当我尝试使用*ngFor迭代数据时，我得到了“无法找到不同的支持对象”错误。从所有其他问题中，我知道它试图绑定到一个对象，而不是一个数组，但在我的生活中，我不知道为什么。或者需要将哪个对象转换为数组。
我使用的是Angular 5.0.5。有趣的是，这是与Angular 4一起工作的，但显然我在升级过程中弄坏了一些东西。
你觉得我做错了什么吗？除了所有的东西。:D lol
这是我的服务
import { Injectable, EventEmitter } from '
浏览 0提问于2017-12-07得票数 0
我在一个angular 4项目中使用RxJS。
我正在尝试初始化一个Websocket，特别是想知道这个是何时打开的。
我目前使用的是RxJS的WebSocket (v5)。
我注意到WebSocketSubjectConfig中有一个openObserver，但我找不到如何创建观察者。我已经被锁定了好几个小时了。
下面是到目前为止我的代码的摘录：
import { Injectable } from '@angular/core';
import { webSocket} from 'rxjs/observable/dom/webSocket';
import
浏览 12提问于2017-07-19得票数 4
1回答
我正在学习一门关于如何使用firebase和角设计身份验证的课程。直到我在名为getCurrentUser()的函数中遇到这个错误之前，一切都运行得很好。
这是错误消息
(error TS2345:类型为'OperatorFunction<firebase.User，User>‘的参数不能分配给'OperatorFunction<User \ null，User>’类型的参数。输入'User \ null‘不能分配给键入'User’。类型'null‘不能分配给键入’User‘)。)
你知道如何解决这个问题吗？
import {
浏览 1提问于2020-08-13得票数 0
3回答
我有一个组件，它需要多个get请求才能返回我需要的所有数据。这些是相互独立的，但我想一起进行所有的调用，并在此成功完成后加载UI。 为了实现这一点，我正在使用forkJoin，但我是RxJS的新手，我不能完全肯定我这样做是正确的。请看我下面的例子。任何帮助都将不胜感激。 import { Component, Input, OnInit, ElementRef, ViewChild } from '@angular/core';
import { Observable, forkJoin, of } from 'rxjs';
import { flatMap
浏览 43提问于2020-10-06得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
