RxJS 6:仅订阅onComplete
RxJS 6是一个用于处理异步数据流的JavaScript库。它提供了一种响应式编程的方式，通过使用Observables来处理数据流，使得异步编程更加简洁和可维护。
RxJS 6的核心概念是Observables、Operators和Subscriptions。
- Observables（可观察对象）：Observables是表示异步数据流的对象。它可以发出多个值，包括数据、错误和完成信号。通过使用Observables，我们可以处理异步操作，如HTTP请求、事件处理等。
- Operators（操作符）：Operators用于对Observables进行转换、过滤和组合等操作。它们可以帮助我们处理数据流，实现各种功能，如映射、过滤、合并、缓冲等。
- Subscriptions（订阅）：Subscriptions用于订阅Observables并接收它们发出的值。通过订阅，我们可以处理Observables发出的数据，并在不需要时取消订阅，以避免资源泄漏。
RxJS 6的优势包括：
- 响应式编程：RxJS 6提供了一种响应式编程的范式，使得处理异步数据流更加直观和简洁。它可以帮助开发人员更好地管理和组合异步操作。
- 强大的操作符：RxJS 6提供了丰富的操作符，可以处理各种数据转换和操作需求。这些操作符可以帮助开发人员简化代码，提高开发效率。
- 可组合性：RxJS 6的Observables和Operators具有高度的可组合性，可以轻松地组合和重用代码。这使得代码更具可读性和可维护性。
- 广泛的应用场景：RxJS 6可以应用于各种场景，包括前端开发、后端开发、移动开发等。它可以处理异步数据流，如用户输入、网络请求、事件处理等。
在腾讯云中，可以使用腾讯云函数（SCF）来处理RxJS 6的相关任务。腾讯云函数是一种无服务器计算服务，可以帮助开发人员在云端运行代码，无需关心服务器的管理和维护。您可以通过腾讯云函数来创建和管理RxJS 6的任务，并将其与其他云服务进行集成。
更多关于腾讯云函数的信息，请参考：腾讯云函数产品介绍
总结：RxJS 6是一个用于处理异步数据流的JavaScript库，它提供了响应式编程的方式，通过使用Observables、Operators和Subscriptions来处理数据流。它具有响应式编程、强大的操作符、可组合性和广泛的应用场景等优势。在腾讯云中，可以使用腾讯云函数来处理RxJS 6的相关任务。
相关·内容
如果观察体完成，我是否仍然必须取消订阅/处置(在Rxjs中)观察体以移除观察者(防止内存泄漏)，或者一旦发生onComplete或onError事件，这是否由Rxjs内部处理？
浏览 0提问于2018-10-01得票数 2
我想使用可观察的RXJS。基本上，它工作得很好，但我不仅需要在observer.next()时做出反应，而且需要在调用observer.complete()时作出反应。如何使RXJS的OnComplete事件可以观察到？在我看来，RXJS文档令人困惑。
export class Service {
myMethod():Observable<any> {
return Observable.create((observer:any) => {
for(let i=0; i<10; i++) {
observer.
浏览 2提问于2016-07-05得票数 17
回答已采纳
在角2中，mySubject (参见代码)编译一个完整的()函数，但是在执行过程中它会错误地表示没有这样的函数。我无法让onComplete()编译。
import { Component, OnInit } from '@angular/core';
import { NgForm } from '@angular/forms';
import * as Rx from "rxjs";
import {BehaviorSubject} from 'rxjs/BehaviorSubject';
浏览 3提问于2017-08-04得票数 9
回答已采纳
3回答
管道和Tap与使用ngxs的订阅
、、、、
我在玩弄管道和订阅。如果我使用带水龙头的管道，则不会在控制台中登录任何内容。如果我使用的是subscribe，它就能正常工作。那么我做错了什么呢？
import { Observable } from 'rxjs';
import { tap, take } from 'rxjs/operators';
this.store.select(state => state.auth.authUser).pipe(
take(1),
tap((data) => {
//Not Working - no console output
浏览 8提问于2018-05-19得票数 13
回答已采纳
在app.component中，我需要基于ActivatedRoute执行一个操作。使用: Angular6，rxjs6 (用它的新语法)
import {Observable} from 'rxjs';
import {map} from 'rxjs/operators';
....
constructor (private route:ActivatedRoute){
const url: Observable<string> =route.url.pipe(map(segments=>segments.join(''
浏览 0提问于2018-05-17得票数 0
回答已采纳
1回答
我知道一个Promise只能使用一次，而一个Rxjs主题可以提供多个事件。
如果您在应用程序中使用rxjs，那么将主题用于Promise可以做的事情是一种好的实践吗？
为我效劳：
const addedItem: Subject = new Subject();
addedItem.next(res);
addedItem.complete();
我的消费者只需订阅，并在收到消息时导航。这是一个很好的实践吗？
浏览 0提问于2019-03-17得票数 1
RxJS允许使用onNext、onError、onComplete订阅源。
我正在寻找一种方法来构造一个允许用户使用onError处理错误的可观察的方法，但是如果存在未处理的错误，我可以显示全局咆哮(来自primeng库的通知)。
是否有一种很好的方法来捕获订阅错误中未处理的错误。
Update1: --我注意到Angular2有一个中央ErrorHandler (模块级)。问题是以某种方式将其附加到UI中。
浏览 2提问于2016-12-14得票数 3
1回答
当使用collectionView时从web服务获取新内容时，我愿意强制重新加载RxSwift。当正确地调用我的newContent闭包时，我不知道为什么在onComplete上没有收到具有以下代码的事件。
class ListingView : UIView {
var newContentStream: Observable<Bool>?
let disposeBag = DisposeBag()
@IBOutlet weak var collectionView: UICollectionView!
weak var viewModel:
浏览 3提问于2016-08-19得票数 5
回答已采纳
我正试图更好地理解如何使用Rx进行单元测试，但我未能成功地将主题设置为“已完成”。因此，我总是等待5秒的超时( onComplete应该是立即的)，然后在assertComplete上失败。
我对的理解是，它只应该阻塞直到调用onComplete。我也研究过，但我认为这里不应该需要它。
任何帮助或文件，可以引导我朝着正确的方向，将不胜感激。
@Test
fun testObservable() {
val subject = BehaviorSubject.create<Int>()
subject.onNext(0)
TestSubscriber<
浏览 2提问于2017-05-04得票数 3
回答已采纳
1回答
我试图在一个可以观察到的简单代码中抛出一个错误：
return Observable.create((observer) => {
observer.throw(new Error('Test'));
});
然而，出于某种原因，throw还没有定义。我不知道为什么在我们班的第一名，我有以下的重要内容：
import 'rxjs/observable/throw';
我也尝试过：
import 'rxjs/Observable/throw';
以及：
import 'rxjs/add/observable/throw';
浏览 5提问于2016-09-01得票数 0
回答已采纳
我使用的是一个不支持rxjs的库，只是一个好的ol‘回调。我试图将它包装在一个可观察的地方，但当有人没有订阅时，我需要内部流来处理它自己。
subscribeToQuotes() {
return new Observable(observer => {
const stream = someLibrary.getStream();
stream.onNewData(data => {
observer.next(data);
});
stream.onComplete(() =&g
浏览 1提问于2019-08-09得票数 0
回答已采纳
我正在学习RxJS。我对下面的代码片段有疑问。
var arr = [1,2,3,4,5];
var arraysource = Observable.from(arr);
arr.push(6);
var subscription = arraysource.subscribe(
x => console.log('onNext: %s', x),
e => console.log('onError: %s', e),
() => console.log('onCompleted'));
ar
浏览 2提问于2016-06-09得票数 2
回答已采纳
我想把我的rxjs代码更新到6get，我不明白。
在此之前，我每隔5秒就会对新数据进行一次轮询：
import { Observable, interval } from 'rxjs';
import { switchMap, map } from 'rxjs/operators';
var result = interval(5000).switchMap(() => this._authHttp.get(url)).map(res => res.json().results);
Now...of当然，它坏了，文档让我无处可去。
如何编写上述代码
浏览 2提问于2018-05-06得票数 22
回答已采纳
2回答
我创造了一个从5到0的倒计时。当您单击“开始”按钮时，它就会启动：
<html>
<head>
<meta charset="utf-8"/>
<script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/6.5.5/rxjs.umd.js">
</script>
</head>
<body>
<button id="start">START</button>
COUNT
浏览 1提问于2020-05-26得票数 1
回答已采纳
1回答
我有一个问题，当使用最新版本的rxjs与角6。代码；
import { Observable, throwError } from "rxjs";
import { map, filter, catchError, mergeMap } from 'rxjs/operators';
isValidUser(user, password) : Observable<any> {
let urlString = "http://localhost....=" + user + "&password=" + pa
浏览 0提问于2018-06-14得票数 2
回答已采纳
3回答
TL;DR，我有一个从网络请求中返回的名称数组，我想对这些名称进行洗牌，这样每次请求时，名称都会以不同的顺序排列。此外，我希望从集合中选择6个名称，而不需要重复。我有一个CodePen来重现这个问题，使用of而不是Angular的http.get，在接下来选择的6：组中，我看到了重复的
问题：
我正在致力于一个小应用程序的角度，让你知道你的同事的名字。我提出一个网络请求，得到一个JSON响应，其中包括游戏的名称和图像。为了使游戏更有趣，而不是每次按相同的顺序，我在评估可观测值时使用了lodash.shuffle操作。我期望这应用洗牌操作一次，但我可以看到它被评估，每次我要求分组6人。这导致在多
浏览 4提问于2020-06-03得票数 3
回答已采纳
我有两个可观察到的。
这是返回可观察到的
const rxjs = require('rxjs');
const op = require('rxjs/operators');
const retornaObs = (arg, timeout) => {
return rxjs.of(arg)
.pipe(tap(res => {
setTimeout(() => {
console.log(res);
}, timeout);
}));
}
打电话的人
ret
浏览 1提问于2020-02-27得票数 0
回答已采纳
io.reactivex.rxjava2:rxjava:2.1.13
kotlin_version = '1.2.30'
我有以下可观察到的，并且我试图抛出一个异常来测试OnError中异常的捕获。但是，当我将以下内容传递给onExceptionResumeNext(Observable.just(10))时，会得到以下输出：
1
2
10
onComplete
fun main(args: Array<String>) {
Observable.fromArray(1, 2, 0, 4, 5, 6)
.doOnNext {
浏览 1提问于2018-05-29得票数 3
回答已采纳
所以，基本上，rxjs是新的，想知道，
我是否需要从Observable.of(数据)或更新的rxjs版本中取消订阅(数据)？
即
import {of} from 'rxjs';
const sub = of(data).subscribe();
这有必要吗？
sub.unsubscribe();
浏览 2提问于2019-04-28得票数 6
3回答
从RxJS5升级到RxJS6
、、、、
从RxJS5升级到版本6有问题。
private captureEvents(canvasEl: HTMLCanvasElement) {
Observable
.fromEvent(canvasEl, 'mousedown')
.switchMap((e) => {
return Observable
.fromEvent(canvasEl, 'mousemove')
.takeUntil(Observable.fromEvent(canvasEl, '
浏览 1提问于2018-07-11得票数 0
回答已采纳
我使用的是角6和RxJS 6，当我尝试下面的示例时，会得到以下错误：
ReferenceError: async is not defined
浏览 1提问于2018-05-28得票数 0
调用不工作，因为升级在RXjs版本6是合并在角version8。有关完整的源代码，请参阅：-
import { Component } from '@angular/core';
import {ServicexampleService} from './servicexample.service';
@Component({
selector: 'app-root',
templateUrl: './app.component.html',
styleUrls: ['./app.component.cs
浏览 0提问于2019-08-01得票数 0
回答已采纳
3回答
如何完成可观察性？
、、、、
学习rxjs玩它。我的代码：
// RxJS v6+
import { withLatestFrom, map } from 'rxjs/operators';
import { interval } from 'rxjs';
const source = interval(1000);
const example = source.pipe(
map(value => value +1),
map(value => {
if(value === 40) {
finish();
}
else if (v
浏览 1提问于2019-12-02得票数 5
回答已采纳
3回答
在一本“角度2”的指南中，它说：
可观察运算符的默认行为是在.complete()或.error()消息发布后立即释放订阅。请记住，RxJS的设计目的是在大多数情况下使用“失火而忘记”的方式。
在较早的一页中，有一个可观察和订阅的例子。
。
您可以看到，3秒后，onbservable ".complete()“的。但是，当再次单击Init()按钮并调用init()方法时，仍然会通知订阅者。
代码：
import {Component} from '@angular/core';
import {Observable} from 'rxjs/Observable&
浏览 1提问于2016-11-29得票数 1
1回答
在我的应用程序中，人们发布其他人可以看到的广告。他们使用annonce的创建者和阅读它的人之间的距离进行过滤。如果有人发布广告，我需要确保得到他的位置。如果有人寻找广告，我需要确保获得他的位置来对广告进行排序。 在我的代码中，我有一种方法来获取位置，但有时它会返回null。 下面是小代码(我已经检查了权限等) FusedLocationProviderClient mFusedLocationProviderClient;
mFusedLocationProviderClient = LocationServices.getFusedLocationProviderClient(c
浏览 13提问于2020-03-29得票数 0
在rxjs5(angular6应用程序)中，我使用
this.router.events .filter(event => event ).map() => this.activatedRoute) .map(路由=> { while (route.firstChild) {en21= route.firstChild；}返回路径；enter code here }) .filter(路由=> route.outlet === 'primary') .mergeMap(路由存储)(事件){(事件标题‘+’+)；this.appDataLogic.ur
浏览 0提问于2018-09-21得票数 4
使用跟踪RxJS。我怀疑我使用的可观察性可能与本例中的可观察性不同吗？
下面是我是如何设置的：
@ViewChild('searchInput') input: ElementRef;
...
var keyups = Observable.fromEvent(this.input.nativeElement, 'keyup')
// this returns FromEventObservable instead of Observable which may be the reason?
此时，我可以调用.subscribe并看到事件流到：
keyups.
浏览 0提问于2016-07-05得票数 0
回答已采纳
1回答
I have a simple service in Angular-6 app.
console.log("01: try to get Users...");
let subScription = this.userService.getUsers().subscribe(
data => {
this.Users = data;
console.log("03: set users...");
},
(error) => {
console.error
浏览 0提问于2018-07-14得票数 0
2回答
角9从可观测的角度返回
、、、、
我正在寻找一种从另一个可观察到的返回一个可观察的方法。我发现您可以使用pipe和map操作符来实现这一点，但它似乎不适合我。我做错什么了？
我使用角9.1.12和rxjs ~6.5.4。
示例: Service1
import { Observable, of } from 'rxjs';
export class Service1 {
test(): Observable<string> {
console.log(1);
return of('hey');
}
}
Service2
import { Obser
浏览 1提问于2021-07-15得票数 0
回答已采纳
为什么rxjs不包含onComplete操作符，即当源观察值完成时允许执行某些操作的操作符？finalize操作符既适用于完成，也适用于错误，而我只需要对完成做出反应。
是的，我知道我可以使用subscribe()函数的onComplete回调，但这是完全不同的。有时，您只想在rxjs管道内完成时执行某些操作，而不是在subscribe调用内。
我是不是遗漏了什么？
浏览 3提问于2019-11-20得票数 1
我使用angular9、rxjs6并实现了canActive: Observable
但我在使用catchError时遇到一个错误，如下所示：
我该如何解决这个问题呢？
我试着更新:但它仍然不能工作。
浏览 0提问于2021-01-05得票数 0
2回答
在本例中，source Observable生成介于0到6之间的数字，并将6视为错误。如何创建一个将错误带回到正常事件流的target Observable。
我试过了，但是当发生错误时，它就停止工作了。
const { of, interval, throwError } = rxjs;
const { switchMap, map, catchError } = rxjs.operators;
const source = interval(1000).pipe(
map(() => Math.floor(Math.random() * 7)),
switchM
浏览 2提问于2020-05-21得票数 0
回答已采纳
下面是components.ts中一个角的代码，下面是用X编译的错误代码。
错误
合并/merge.Component.ts:75:12-错误TS2551:属性‘un订阅’在类型‘可观察’上不存在。你是说“订阅”吗？
$().unsubscribe()~
../../node_modules/rxjs/dist/types/internal/Observable.d.ts:53:5 53订阅(观察者:部分)：订阅；~‘订阅’在这里声明。
import { Component, ElementRef, OnDestroy, OnInit, ViewChild } from '@angul
浏览 8提问于2021-12-17得票数 1
回答已采纳
1回答
从另一个类调用init函数，则从不调用console.log。稍后，调用broadcast会产生以下错误：
TypeError:无法读取未定义的属性“next”
带有可观察代码的文件：
import 'rxjs/add/operator/filter';
import 'rxjs/add/operator/mergeMap';
import 'rxjs/add/operator/share';
import 'rxjs/add/observable/of';
import { Observable } from '
浏览 1提问于2017-09-12得票数 2
在调用EventEmitter并调用取消订阅之后，在第二次尝试订阅ngOnDestroy时，我得到了以下错误：
ngOnInit() {
this.route.params.subscribe(params => {
this.resources.eco_id= params['id']
});
this.http.ReloadForm.subscribe(res=>this.OnFormLoad(res));
}
ngOnDestroy(){
this.http.R
浏览 0提问于2018-08-04得票数 13
回答已采纳
我有一个 符合spec的ECMAScript观察值 ，特别是来自 wonka库 ..。我正在尝试将这种类型的可观察对象转换为rxjs 6可观察对象，但没有运气。 在rxjs 5中，这似乎是可能的。我已经尝试过了： import { pipe, toObservable, fromArray } from 'wonka';
import { from } from 'rxjs';
...
from(
pipe(
fromArray([1, 2, 3]),
toObservable
)
); 我在浏览器中看到以下错误： ERROR Type
浏览 101提问于2021-02-22得票数 2
回答已采纳
我已经订阅了一个ReplaySubject，并且正在尝试用ngOnDestroy方法取消订阅。当我离开subscription组件，返回到相同的组件而没有发出数据时，它又被订阅了。我可以知道如何解决这个问题吗？ Shared.service.ts import { Injectable } from '@angular/core';
import { TestCase } from './test-case-form/test-case.model';
import { Subject } from 'rxjs/Subject';
import
浏览 23提问于2019-06-11得票数 0
回答已采纳
我正在尝试从可观察对象中提取最后一个发射值。但是rxJS有两个运算符和。
rxJS中的last运算符和publishLast运算符有什么区别？
浏览 0提问于2019-05-09得票数 1
我正在用angular2开发应用程序，这里我使用消息广播将数据从一个组件更新到另一个组件。
这是代码，message_event.ts
import {Injectable} from '@angular/core';
import {Observable} from 'rxjs/Observable';
import {Broadcaster} from './broadcaster';
@Injectable()
export class MessageEvent {
constructor(private broadcaster: B
浏览 4提问于2017-09-05得票数 1
说：
// RxJS v6+
import { from } from 'rxjs';
import { groupBy, mergeMap, toArray } from 'rxjs/operators';
const people = [
{ name: 'Sue', age: 25 },
{ name: 'Joe', age: 30 },
{ name: 'Frank', age: 25 },
{ name: 'Sarah', age: 35 }
];
//emit each
浏览 2提问于2018-08-01得票数 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
我想实现一个搜索组件，如角教程。
问题:
search方法触发并修改searchTerms: Subject<string>，但switchMap从不触发。
代码：
进口
import { Component, OnInit } from '@angular/core';
import { SearchService } from "./search.service";
import { Observable } from 'rxjs/Observable';
import { Subject }
浏览 2提问于2017-07-26得票数 0
回答已采纳
2回答
我用一个名为'getQuestionsWithInterviewId‘的函数来填充我的字符串'Questions’，但是当我在ngOnInit和ngAfterContentInit方法中用console.log调用它时，它看起来是空的。 import { Component, OnInit } from '@angular/core';
import { QuestionService } from '../_services/question.service';
import { Question } from '../_models
浏览 42提问于2020-08-09得票数 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回答
如演示所示，如标题所示
const { combineLatest, interval, of } = rxjs;
const { first, last, sample, take, withLatestFrom } = rxjs.operators;
const numbers = interval(1000);
const takeFourNumbers = numbers.pipe(take(4));
takeFourNumbers.subscribe(x => console.log('Next: ', x));
setTimeout(()=>{
浏览 4提问于2022-03-12得票数 0
1回答
我在catchError中使用了rxjs，并且熟悉pipe流中使用的pipe操作符，特别是对于HttpClient (XHR)调用
我的问题是catchError操作是如何工作的？它是如何捕捉引擎盖下的错误的？
import { throwError, of } from 'rxjs';
import { catchError } from 'rxjs/operators';
//emit error
const source = throwError('This is an error!');
//gracefully handle erro
浏览 0提问于2018-12-01得票数 2
回答已采纳
我在我的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
回答已采纳
我使用的是RxJS 6，我有以下
我们希望为指定的bufferTime缓冲元素，但是如果在超过bufferTime的时间内没有发生任何事情，我们希望第一个元素立即触发。
顺序：
[------bufferTime------]
Input over time:
[1, 2, 3, -------------|---4, 5, 6 ----------------]
Output over time:
[1]-----------------[2,3]---[4]------------------[5,6]
这就是把我带到那里的密码：
source$.pipe(
buffer(sou
浏览 2提问于2020-09-21得票数 1
回答已采纳
1回答
我有一个测试，它可以工作，但如果我尝试将活动设置为不同的值，它将破坏测试。因此，在进行任何其他测试之前，我希望取消订阅a (当前活动的可观察对象)：
let a:Observable<Todo> = store.observeActive();
a.subscribe(active=> {
expect(active).toEqual(todo1);
});
a.unsubscribe();
看起来好像RxJS 6不再有unsubscribe() ...有什么想法？
跟进
因此，我们取消了对Subscription引用的订阅，但是设计者没有将unsubscribe方法放
浏览 4提问于2018-12-13得票数 0
回答已采纳
我有一个创建倒计时的Observable.timer函数，当计时器在我的@组件中结束而不使用setTimeout()时，我想调用一个名为endTimer()的特定函数。我可以在视图中检查计数器== 0的值，但是如何签入@组件
import { Component } from '@angular/core';
import { IonicPage, NavController, NavParams, ModalController } from 'ionic-angular';
import { Storage } from '@ionic/storag
浏览 1提问于2018-03-26得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储活动推荐
腾讯云开发者
