链接rxjs运算符
RxJS（Reactive Extensions for JavaScript）是一个用于处理异步数据流的库。它基于观察者模式和迭代器模式，提供了丰富的操作符来处理数据流的转换、过滤、合并等操作。
RxJS的运算符可以分为以下几类：
- 创建运算符：用于创建数据流，例如
of、from、interval等。推荐的腾讯云相关产品是腾讯云函数（SCF），可以使用云函数来创建和处理数据流。 - 转换运算符：用于对数据流进行转换，例如
map、filter、pluck等。腾讯云相关产品是腾讯云消息队列 CMQ，可以使用消息队列来进行数据流的转换和处理。 - 组合运算符：用于将多个数据流进行组合，例如
merge、concat、zip等。腾讯云相关产品是腾讯云云函数 SCF，可以使用云函数来进行数据流的组合和处理。 - 错误处理运算符：用于处理数据流中的错误，例如
catchError、retry等。腾讯云相关产品是腾讯云日志服务 CLS，可以使用日志服务来记录和处理数据流中的错误信息。 - 辅助运算符：用于辅助数据流的处理，例如
tap、delay、debounceTime等。腾讯云相关产品是腾讯云云函数 SCF，可以使用云函数来进行数据流的辅助处理。 - 多播运算符：用于将数据流进行多播，例如
share、publish、multicast等。腾讯云相关产品是腾讯云消息队列 CMQ，可以使用消息队列来进行数据流的多播处理。
RxJS的优势在于它提供了一种响应式编程的方式，可以简化异步数据流的处理逻辑，使代码更加清晰和易于维护。它适用于各种场景，包括前端开发、后端开发、移动开发等。
推荐的腾讯云相关产品和产品介绍链接地址如下：
- 腾讯云函数（SCF）：https://cloud.tencent.com/product/scf
- 腾讯云消息队列 CMQ：https://cloud.tencent.com/product/cmq
- 腾讯云日志服务 CLS：https://cloud.tencent.com/product/cls
请注意，以上推荐的腾讯云产品仅供参考，具体选择应根据实际需求和情况进行。
相关·内容
1回答
我还不确定这是不是问这个问题的合适地方，或者StackOverflow可能是最好的。所以我要开始了。
我对add/operator的介绍是通过优秀的框架进行的，在整个教程中都是“从rxjs导入所需的任何内容，然后将其链接起来”。
import { Observable } from 'rxjs/Observable';
import { empty } from 'rxjs/observable/empty';
import 'rxjs/add/operator/catch';
import 'rxjs/add/operator/map&
浏览 2提问于2018-01-07得票数 0
我在React Native中使用rxjs。我调用Observable.fromPromise(storage.load({key: key})).map(() => value);显示错误。
我的rxjs版本：
"rxjs": "^6.5.3",
"rxjs-compat": "^6.5.3",
我有三个步骤。
Step1：
rxInit().flatMap(() => {
console.log('I can not see the console log');
return rxIni
浏览 18提问于2019-10-30得票数 2
回答已采纳
我正在升级从角2到角5
我使用了下面的链接并进行了更新。
每个步骤都不确定如何更新导入的每个RxJS操作符，现在应该从‘rxjs/ Operator’导入并使用管道操作程序。
我在代码库中使用过这样的Rxjs，但不确定如何更改它。
<!-- language-all: lang-or-tag-here -->
import { Subject } from 'rxjs/Subject';
import { Observable } from 'rxjs/Rx';
@Injectable()
export class pl
浏览 0提问于2018-01-26得票数 0
我有一个出租车预订应用程序，使用离子地理定位和Firebase Firestore。我的代码不能与firestore包一起使用，所以我必须将rxjs更新到版本6。
'Property 'filter' does not exist on type 'Observable<Geoposition>'. '
以下是我的代码
import { filter } from 'rxjs/operators';
const subscription = this.geo.watchPosition()
浏览 0提问于2018-11-08得票数 0
2回答
如何更新Observable.merge()在rxjs 6+中的旧语法？旧的语法如下：Observable.merge(...array).map(() => {});，使用rxjs 6的正确语法应该是什么？
浏览 0提问于2018-10-12得票数 1
回答已采纳
在升级到Angular 6.0和Rxjs到6.0之后，我收到以下编译错误：
Property 'do' does not exist on type 'Observable'.
代码如下：
import { Observable, of } from 'rxjs';
import 'rxjs/add/operator/do';
import 'rxjs/add/observable/throw';
import 'rxjs/add/operator/catch';
import { IProduct
浏览 2提问于2018-05-07得票数 46
import { map } from 'rxjs/operators';和import 'rxjs/add/operator/map';有什么区别？
我在执行登录的服务方法中使用它：
// import { map } from 'rxjs/operators'; // Fails at runtime
import 'rxjs/add/operator/map'; // Works fine at runtime
public login(username: string, password: string): Obse
浏览 32提问于2018-09-04得票数 3
回答已采纳
在我的代码中，我有一个拦截器，它处理所有出站http请求，并将令牌添加到其中。代码如下所示
intercept(request: HttpRequest<any>, next: HttpHandler): Observable<HttpEvent<any>> {
const promise = this.storage.get('token');
return Observable.fromPromise(promise)
.mergeMap(token => {
const clonedReq = this.addTo
浏览 0提问于2020-06-26得票数 0
5回答
我正在迁移一个角形5应用程序到最新的CLI和Range6RC，并且我所有的可观察到的导入都被破坏了。我看到了角度6改变了导入的工作方式，但是我找不到任何关于语法是如何工作的明确的参考。
我5岁的时候就有了这个，效果很好：
import { Observable } from 'rxjs/Observable';
import 'rxjs/add/operator/map';
import 'rxjs/add/operator/catch';
import 'rxjs/add/observable/throw';
现在使用新的语法，
浏览 0提问于2018-04-13得票数 42
回答已采纳
2回答
我有一个角度项目，其中的东西，如RxJ库操作符，地图，do等不导入。源中似乎没有通配符导入。
我的离子和角度项目都是这样的：
import { Observable } from 'rxjs';
然后我有一个Ionic项目，它抱怨如果我不解释，说明进口。
import 'rxjs/add/operator/map';
import 'rxjs/add/operator/do';
此外，在Ionic项目中，我似乎也无法在的node_modules文件夹中找到RxJS。虽然现在，我开始认为我需要一个像rx.lite.js这样的特定包.我不知道rx.l
浏览 2提问于2017-06-14得票数 1
试图为rxjsv6.3.3导入catchError，但导入看起来不起作用。我在使用catch时出错了。
发现了类似的问题，但看上去对我没有帮助。
代码：
import { Injectable } from '@angular/core';
import { HttpClient, HttpErrorResponse } from '@angular/common/http';
import { IWinServices } from './WinServices';
import { Observable } from 'rxjs
浏览 0提问于2019-05-14得票数 2
回答已采纳
我正在学习thinkster.io的一篇教程，内容是使用角2+编写“用于与服务器交互和身份验证的服务”。我使用RXJS v5继续使用这个部分，无法将其转换为新的RXJS v6以使代码工作。
我正在处理下面的文件表单，在那里我得到了错误：
user.service.ts
import { Observable } from 'rxjs';
import { BehaviorSubject } from 'rxjs';
import { ReplaySubject } from 'rxjs';
import { m
浏览 0提问于2018-07-06得票数 0
回答已采纳
在一个Range5项目中，我试图处理，但不明白在导入分离的operators时它是如何工作的。
fromPromise 考虑将与 map**:**链接起来
import { fromPromise } from 'rxjs/observable/fromPromise';
import { map } from 'rxjs/operator/map';
使用fromPromise().map()返回错误：fromPromise_1.fromPromise(...).map is not a function
和
import 'rxjs/add/obs
浏览 1提问于2018-03-19得票数 0
回答已采纳
在我的Angular10项目中，尽管我import 'rxjs/operator/map';和import { map } from 'rxjs/operators';
服务代码是
import { Injectable } from '@angular/core';
import { HttpClient } from '@angular/common/http';
import { map, filter, scan } from 'rxjs/operators';
import 'rxjs/add/o
浏览 0提问于2020-10-04得票数 1
回答已采纳
1回答
我有一个从web服务获取一些信息的函数：
const rxjs = require('rxjs');
const request = require('request');
const moment = require('moment');
function getAvailableGroupClasses() {
return rxjs.Observable.create(observable => {
request(`https://myservice.com/get.json`, (error, respon
浏览 0提问于2018-04-27得票数 1
以前，我只能使用以下代码导入使用的运算符：
import 'rxjs/Observable';
import 'rxjs/add/operator/map';
import 'rxjs/add/operator/mergeMap';
import 'rxjs/add/operator/catch';
import 'rxjs/add/operator/finally';
import 'rxjs/add/observable/empty';
import 'rxjs/add/observab
浏览 1提问于2018-05-19得票数 3
在将应用程序更新到RxJs 6(使用rxjs)时，我们面临一个问题。仍然在RxJ 5上的引用库使用ErrorObservable作为方法的返回类型。
public handleError(error: Error): ErrorObservable {
...
return Observable.throw('some error message');
}
到目前为止，ErrorObservable是RxJs：中的一种非泛型类型。
export class ErrorObservable extends Observable<any> {
...
浏览 0提问于2018-06-18得票数 4
在将应用程序从Angular 5迁移到Angular 6时出现以下错误，
Module '/node_modules/rxjs/observable/TimerObservable' has no exported member 'TimerObservable'.
代码：
import { Injectable } from '@angular/core';
import { TimerObservable } from 'rxjs/observable/TimerObservable';
import { Observable
浏览 4提问于2018-09-11得票数 3
我们如何转换：
Rx.Observable.timer(3000).mapTo({ id: 1 })
到RxJS 6？
例如，如果我们：
import { Observable, timer } from 'rxjs';
我们仍然得到：
在“可观察类型”类型上不存在ts属性'timer‘。
总之，我试图让这个示例开始工作：
// Simulate HTTP requests
const getPostOne$ = Rx.Observable.timer(3000).mapTo({id: 1});
const getPostTwo$
浏览 0提问于2018-08-16得票数 0
回答已采纳
1回答
假设我们有两个按钮。第一个按钮以1000 it的延迟执行操作，而另一个按钮以2000 it的延迟执行操作。当单击一个按钮时，我希望等待它的执行，然后才允许从另一个按钮执行操作。
例如，单击按钮2，然后单击按钮1，只会导致执行操作2按钮(基本上，button1的操作将被忽略，因为action2尚未执行)。如何使用rxjs库实现这一点？
const btnOne = document.querySelector('#btn1');
const obs1 = rxjs.fromEvent(btnOne, 'click').pipe(
rxjs.operator
浏览 0提问于2018-11-27得票数 0
回答已采纳
下面是我在URL中看到的优点：
承诺：
返回单个值。
未取消
更具可读性的代码尝试/捕捉和异步/等待
可观察
随时间使用多个值。
可取消
支持映射、筛选、缩减和类似的操作符
使用反应性扩展(RxJS)
一个数组，其项随着时间的推移异步到达。
在“可观测”中，我看到了支持运算符和RXJS的3&4点。我只是有一个基本的问题，比如我不能用RXJS和操作符来承诺吗？第5点的含义是什么？
浏览 0提问于2018-02-05得票数 0
回答已采纳
我正在开发一个库，它将RxJS作为对等依赖项，并使用webpack捆绑它。我通过设置RxJS将webpack配置为从包中排除externals: [require("webpack-rxjs-externals")()]。
在这个库中，我有一个函数返回一个可观察的函数。类似于：
import { from } from 'rxjs/observable/from'
import { map, distinctUntilChanged } from 'rxjs/operators'
export default function xpto(pre
浏览 2提问于2017-11-28得票数 0
1回答
大家好，链接RXJS5结果的最好方法是什么，比如promises？
interface MyObj{
name : string
url: string
html: any // async
}
// promise chaining, pretty simple
getMyObjWithPromise()
.then(myObj=>{
// promise, we get back html from myObj.url async
return getMyObjHtmlWithPromise(myObj)
})
.then(myObj=>
浏览 2提问于2016-11-30得票数 2
当试图导入"Interval“时，我得到了错误”无法读取未定义的属性‘调用’“
我的进口产品是：
import { Observable } from 'rxjs/Observable';
import 'rxjs/add/observable/merge';
import 'rxjs/add/observable/of';
import 'rxjs/add/operator/catch';
import 'rxjs/add/operator/map';
import '
浏览 1提问于2018-01-17得票数 2
回答已采纳
在角5中，我想使用第一个()方法，如下所示：
this.ccService.mode.first().subscribe(mode => {
this.mode = mode;
});
我是这样进口的：import { first } from 'rxjs/operators/first';。我也尝试过从'rxjs/add/operator'、'rxjs/operators'、'rxjs'导入，似乎都没有用。
但是，它拒绝工作，只提供您在标题：[ts] Property 'first' does not
浏览 0提问于2018-05-22得票数 11
回答已采纳
目前，我很高兴地使用R角(2.4.0)和R角/cli (1.0.0-rc1)，在许多地方使用RxJs库。整个安装是相当标准的(即我没有个性化的任何配置文件)。
我的package.json
{
"name": "sharewithfriends",
"version": "0.0.0",
"license": "MIT",
"scripts": {
"ng": "ng",
"start": "ng
浏览 3提问于2017-03-12得票数 2
rx从5升级到6，抛出错误
类型'BehaviorSubject‘上不存在ts属性'filter’。
电流行为
import {BehaviorSubject} from 'rxjs';
tokenSubject: BehaviorSubject<string> = new BehaviorSubject<string>(null);
return this.tokenSubject
.filter(token => token != null)
.take(1)
浏览 0提问于2018-07-03得票数 10
回答已采纳
问题：
我有个拦截器
@Injectable()
export class AuthInterceptor implements HttpInterceptor {
constructor(private injector: Injector, private router: Router) {
}
intercept(request: HttpRequest<any>, next: HttpHandler): Observable<HttpEvent<any>> {
const auth = this.injector.get(
浏览 1提问于2018-06-05得票数 5
回答已采纳
3回答
我很难在我的角5应用程序中导入last操作符。我们使用的是Rxjs 5.5.2。
我所做的是：
import { Observable } from 'rxjs/Observable';
import 'rxjs/add/operator/last';
/* ... */
getData() {
return Observable.last(/* ... */);
}
我得到一个Property 'last' does not exist on type 'typeof Observable'.错误..。
我做错什么了？
浏览 3提问于2017-11-10得票数 0
回答已采纳
我有一个Firestore数据库，它包含的字段包括：day、morning、afternoon、night，其中一天中的时间是在这段时间内的数字使用。我正在尝试使用这段代码来求出每天morning等的值的平均值(sunday，monday，...)。
import { Subscriber, Observable, from } from 'rxjs';
import { map, filter, toArray, reduce, switchMap, groupBy } from 'rxjs/operators';
import * as _ from
浏览 3提问于2020-01-21得票数 0
我用的说明将我的from应用程序从5.2版升级到了6.0版。
现在，由于“rxjs-5-to-6迁移”迁移，我的角应用程序没有构建：
Bla.ts中的错误:错误TS2339:属性'map‘在类型’可观察‘上不存在。
我有下列进口产品：
import { Observable } from 'rxjs/observable';
import { of } from 'rxjs/observable/of';
import { map } from 'rxjs/operators';
如果我像这样改变进口，它会起作用：
import
浏览 0提问于2018-05-18得票数 2
回答已采纳
2回答
角4排定形自动磁道
、、、
我试图在角4中实现表单数据自动保存。它应该是这样工作的：
用户在表单->中更改某些数据，调用对DB的保存请求。让我们假设这里为2s启动了一些计时器。
在上一次保存请求的2s期间，所有更改都不会调用任何请求(以减少DB负载)，而是会触发另一个保存请求，然后2s计时器将过期。
如果此时没有启动计时器，则应立即调用保存请求。
我想Observable、Subject和RxJS的Scheduler会帮我，但我对此完全陌生。你能提出实现上述功能的最佳方法吗？
浏览 1提问于2017-10-03得票数 15
回答已采纳
我曾经将方法与可观察的链接在一起，比如
Observable
.of('bla')
.map(text => 1)
.filter(value => value === 1)
.subscribe(value => console.log(value));
但是现在，我意识到由于角度管道，我们应该使用V6 ()方法，比如
Observable.of('bla').pipe(
map(text => 1),
filter(value => value === 1)
).subscribe(value => console.log
浏览 21提问于2019-10-20得票数 1
1回答
在我的Angular (v10)项目中，我可以导入所有类型的RxJS (v6.6.2)操作符，比如 import { debounceTime, filter, map, ... and so on } from 'rxjs/operators'; 除了merge。我像这样导入merge import { merge } from 'rxjs/internal/observable/merge'; 但我认为这不是正确的做法。我也可以写 import { merge } from 'rxjs'; 但是建议的tslint黑名单规则是禁止的：
浏览 31提问于2020-08-19得票数 0
回答已采纳
我正在尝试理解导入rxjs运算符的最佳实践
看起来我应该以这种方式导入share，但是，下面的代码不起作用，因为它说share需要0个参数。我不太确定如何正确地调用share。
import { share } from 'rxjs/operators';
...
public currentUser: Observable<User> = share(this.currentUser$.asObservable());
用老方法做不会有任何问题。然而，我似乎已经了解到，这不是导入的首选方法
import 'rxjs/add/operator/share
浏览 2提问于2018-01-14得票数 2
RxJS 是一个实例方法。要调用该方法，必须更新/创建可观察到的实例。
方法是一种静态方法。不需要实例。
为什么RxJS withLatestFrom不是静态方法，而是实例方法？
浏览 1提问于2017-04-17得票数 3
回答已采纳
我正在尝试按照中的描述实现一个自定义的RxJS操作符。下面是我的应用程序中的相关代码片段：
rxjs-extensions.ts
import { Observable } from 'rxjs/Observable';
function restrictToCommand<T>(this: Observable<T>): Observable<T> {
console.log('works');
return Observable.empty()
}
declare module 'rxjs/Ob
浏览 8提问于2017-03-10得票数 2
回答已采纳
我正在使用AngularJS 2 Beta0，并试图从窗口对象上的事件创建一个RxJS可观察对象。我相信我知道在我的服务中捕获事件作为可观察对象的公式：
var observ = Observable.fromEvent(this.windowHandle, 'hashchange');
问题是，每次我尝试运行这段代码时，都会得到一个错误，指出'fromEvent‘不是一个函数。
Uncaught EXCEPTION: Error during evaluation of "click"
ORIGINAL EXCEPTION: TypeError: Ob
浏览 5提问于2015-12-21得票数 53
回答已采纳
1回答
在unix环境中运行我的代码时，我会遇到这个非常恼人的错误。当我通过ng serve在本地运行代码时，这很好，但是当我将代码部署到服务器时，这个错误会停止所有的程序执行：
ERROR TypeError: this.http.get(...).catch is not a function
Google结果表明，我应该直接从它们的位置导入rxjs名称空间，而不是通过rxjs/Rx包导入，但是不管如何，我都会得到这个错误。其他结果指出，我可能错过了导入rxjs操作符，但它们肯定包含在我的例子中。
我甚至使用DevTools检查了包含的源代码地图，并将操作符包含在浏览器中。
有人能告诉我为
浏览 3提问于2017-11-21得票数 10
回答已采纳
2回答
我正在使用angular 7。这是我的服务。 get(){
return this.http.post(this.url).pipe(
catchError(this.handleError)
)
} 这是错误处理程序代码。 handleError(errorResponse: HttpErrorResponse) {
if (errorResponse.error instanceof ErrorEvent) {
return throwError(errorResponse.error.message)
} else {
switch (error
浏览 28提问于2019-02-06得票数 0
我有一个非常基本的示例，它使用lettable运算符map和来自rxjs@5.5的pipe
import { map } from 'rxjs/operator/map';
let o = of(1, 2, 3, 4).pipe(
map((v) => v * 2)
);
但它会产生错误，Error:(34, 5) TS2684:The 'this' context of type 'void' is not assignable to method's 'this' of type 'Observ
浏览 0提问于2017-11-09得票数 63
回答已采纳
尝试用rxjs创建一个极简的纯js应用程序。
流动：
npm安装rxjs
index.html
myscript.js
Index.html：
<!DOCTYPE html>
<html lang="en">
<head>
<meta charset="UTF-8">
<script src="node_modules/rxjs/bundles/rxjs.umd.min.js" ></script>
<script
浏览 0提问于2019-04-09得票数 3
回答已采纳
这是使用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
回答已采纳
1回答
我刚刚了解了RxJS对象的内存泄漏。因此，我创建了一个小代码来测试当我取消订阅主题时是否正常。下面是我的代码：
let subj = new rxjs.Subject();
const sub1 = subj.subscribe(text => console.log(text));
subj.next('subject 1');
subj.unsubscribe();
subj = new rxjs.Subject();
const sub2 = subj.subscribe(text => console.log(text));
subj.next('s
浏览 4提问于2019-12-29得票数 0
在<1.5.0的角度CLI版本中，您可以将项目的RxJs操作符导入到单个文件中，并在整个应用程序中使用它们。
即
rxjs-operators.ts
// Statics
import 'rxjs/add/observable/throw';
import 'rxjs/add/observable/of';
import 'rxjs/add/observable/range';
import 'rxjs/add/observable/concat';
import 'rxjs/add/observable/merge
浏览 1提问于2017-12-11得票数 2
回答已采纳
2回答
我的史诗如下
export const fetchSomethingEpic = (action$, state$) => {
return action$.pipe(ofType(someActions.FETCH_LEADS),
mergeMap(action =>
from(api().get('SOMETHING'))
.map(response => fetchSomethingSuccess(response.data))
.catch(error => Observable.of(fe
浏览 1提问于2019-08-01得票数 1
回答已采纳
我需要创建一个事件流，其中包含我的应用程序的所有事件，我需要该流是可重放的，并且能够(如果需要)将旧事件广播到后来初始化的服务。
因此，我尝试使用ReplaySubject，但不知道操作符，以避免在必要时重播：
import {ReplaySubject, of} from 'rxjs'
import {combineLatest} from 'rxjs/operators'
const bus$ = new ReplaySubject
const one$ = of(1)
// later
bus$.next('foo')
bus$.nex
浏览 2提问于2018-06-07得票数 1
RxJS 5.5允许抓取lettable运算符，并像这样对它们进行管道处理：
import { ajax } from 'rxjs/observable/dom/ajax'
import { catchError, map, retry } from 'rxjs/operators'
ajax.getJSON('https://example.com/api/test')
.pipe(
retry(3, 1000),
map(fetchUserFulfilled),
catchError(console.error)
)
浏览 4提问于2017-12-30得票数 9
回答已采纳
当使用角6和swagger码元时，我会得到与rxjs相关的类型记录编译器错误
Cannot find module 'rxjs-compat/Observable'
我发现了下面的
我在mac上使用swagger-codegen: stable 2.3.1 (与brew一起安装)。
我很感激你的指导。
更新
我使用以下方法将rxjs-compat添加到angular6项目中
npm install --save-dev rxjs-compat
我现在收到编译器警告，但是编译器错误消失了，该项目似乎正在运行。
浏览 0提问于2018-05-18得票数 3
回答已采纳
如何使用rxjs在以下代码中只有一条subscribe语句：
this.authStore.jwtContainer$.subscribe(x =>
this.userService.getUserById(x.userLoginId).subscribe(z => this.user = z));
我对rxjs比较陌生，希望它是map操作符之一？
浏览 31提问于2018-12-04得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
