2回答
在RxJS 6中取消订阅的最佳方式是什么？
我的“旧”RxJS 5代码如下所示
export class MyComponent implements OnInit, OnDestroy {
private ngUnsubscribe: Subject<any> = new Subject();
this.myService.myEventEmitter
.takeUntil(this.ngUnsubscribe)
.subscribe(this.onDataPolling.bind(this));
public ngOnDestroy(): voi
浏览 1提问于2018-05-30得票数 8
使用RxJS和角2处理服务器重连接的最佳方法是什么？
到目前为止，这就是我所拥有的：
import { Injectable } from '@angular/core';
import { Http, Response } from '@angular/http';
import { Observable } from 'rxjs/Observable';
import { BehaviorSubject } from 'rxjs/BehaviorSubject';
import 'rxjs/add/operator/
浏览 4提问于2017-08-04得票数 1
回答已采纳
我看到，在角5中，应该以不同的方式使用rxjs操作符，并从'rxjs/operators'导入，但我有点不清楚它应该如何工作。我有这样的东西：
import { Observable } from 'rxjs/Observable';
import { combineLatest, takeUntil } from 'rxjs/operators';
@Component({ ... })
export class FooComponent implements OnInit, OnDestroy {
constructor(priv
浏览 1提问于2018-03-13得票数 0
回答已采纳
我有我的observable with interval和takeuntil，它在angular 5中工作得很好，现在当我将它更新为angular 6和rxjs6时，它失败了。我从Observable.interval更改为interval，但takeuntil不起作用。我需要takeuntil，因为当组件被销毁时，我需要停止这个可观察对象。 import { Observable, Subject } from "rxjs";
private onDestroy$ = new Subject<void>();
Observable.interval(6000
浏览 8提问于2019-04-04得票数 2
回答已采纳
2回答
RXJS倒计时器突然停止，当没有发出可信数据时，我可以发现它被switchMap取消了。
怎么修呢？我需要通过点击按钮来启动计时器。请找到我的例子的jsbin。
const start = Rx.Observable.fromEvent(document.querySelector('#btn'), 'click');
start
.switchMap(() => {
return Rx.Observable.timer(0, 1000)
.takeUntil(Rx.Observabl
浏览 2提问于2017-05-17得票数 1
回答已采纳
在使用Rxjs时，对于takeUntil运算符在使用pipe时与combineLatest的行为有一些混淆。
是否有必要将takeUntil添加到每个可以观察到的内部，包括管道takeUntil
import {combineLatest} from 'rxjs';
import {takeUntil} from 'rxjs/operators';
combineLatest(
this._store.pipe(select(stateOfLocation), takeUntil(this._destroy)),
this._store
浏览 0提问于2019-03-03得票数 2
回答已采纳
我认为我应该在特定的用例中利用RXJS。用例是，我有一个订阅，我希望它一直存在，直到某个特定的值从其他地方的某个主题发出。 例如： // The sub to unsub when a certain <value> is emitted from a Subject elsewhere.
this.someObservable.subscribe(() => ...)
// Somewhere in the code far, far away, this should kill the subscription(s) that cares about <val
浏览 13提问于2020-08-12得票数 0
回答已采纳
3回答
如何轮询服务，直到服务的返回值满足条件或总时长超过超时阈值时才停止轮询？
例如:后端系统正在生成资源，前端应用程序可以通过调用返回布尔值的REST api调用来检查该资源是否可用。在我的NGRX应用程序中，我希望每隔200ms轮询一次此api调用，直到此api调用返回布尔值true或总轮询持续时间超过10000毫秒的阈值。
下面的代码示例显示了一种轮询机制，但是，这种轮询不能取消，也不能超时。这是怎么做的？
import { Observable } from 'rxjs/Observable';
import 'rxjs/add/observable/of';
浏览 0提问于2018-01-08得票数 5
3回答
我有一个订阅event listener Observable (fromEvent)的主题。单击按钮stop时，主题完成，事件侦听器应被删除。目前，我正在跟踪订阅和取消订阅，这也会删除事件侦听器： const { fromEvent, Subject } = rxjs
const { map } = rxjs.operators
const subject = new Subject()
subject.subscribe(() => console.log('focused'))
const sub = fromEvent(document.querySe
浏览 9提问于2020-09-17得票数 2
回答已采纳
1回答
我有一段代码，在这里我试图捕捉所有的拖动事件。此代码仅适用于第一次拖动，停止将不适用于连续拖放。
是因为takeUntil取消了外部的可观测性吗？我怎样才能让代码工作。
const { Observable, fromEvent } = rxjs;
const { takeUntil, switchMap } = rxjs.operators;
const mouseups = fromEvent(document.querySelector('.container'),
'mouseup');
const mousedowns = fromEvent(d
浏览 1提问于2018-06-06得票数 1
回答已采纳
我想在我的Angular前端定期从服务器调用一个方法。我只想收到当前的时间。我的问题是浏览器的内存使用量越来越大！ 我不确定订阅是每秒续订一次，还是真的只有在触发时才续订。因此，如果呼叫需要几秒钟，订阅在这段时间内不会续订十次-作为一个初学者，我当然有可能在程序中犯了几个错误…… 我的服务： import { Injectable } from '@angular/core';
import { HttpClient } from '@angular/common/http';
import { Observable } from 'rxjs'
浏览 9提问于2021-04-15得票数 0
回答已采纳
我在高阶可观测值之前使用takeUntil运算符：
import { of, Subject, fromEvent, interval } from "rxjs";
import { takeUntil, mergeMap } from "rxjs/operators";
const subject = new Subject();
const source = fromEvent(document.querySelector("h1"), "click");
fromEvent(document.querySelector
浏览 5提问于2020-04-28得票数 0
你能给我解释一下observable.takeUntil和observable.pipe(takeUntil…？)的区别吗？
示例：
this.api
.testMethod(
this.queryParam,
)
.takeUntil(this.destroy$)
.subscribe(
this.api
.testMethod(
this.queryParam,
)
.pipe(takeUntil(this.destroy$))
浏览 2提问于2021-03-09得票数 2
我正在为我的应用程序使用ionic 3，我正在使用cordova-plugin-network-information用于android设备中的互联网连接检测事件，我可以订阅它，但不能取消订阅它。 我已经尝试了rxjs，订阅取消订阅观察，但没有得到预期的结果。 以下是我的代码： import {Subscription } from 'rxjs/Subscription';
private _netConnection : Subscription = new Subscription();
_netConnection = this.network.onConnect(
浏览 39提问于2019-05-22得票数 0
我想在拦截器内的请求关闭事件之后返回一个不同的状态代码。现在，下面的代码将返回状态200。在这种情况下，我应该在哪里抛出异常？
import { fromEvent, Observable } from 'rxjs';
import { takeUntil } from 'rxjs/operators';
@Injectable()
export class RequestCloseInterceptor implements NestInterceptor {
intercept(context: ExecutionContext, next: Call
浏览 10提问于2021-05-23得票数 1
1回答
在这个中，searchQuery$是一个RxJS Observable。我了解到，当搜索查询字符串在UI上更改时，这个Observable就会发出变化。
我在这个控件中引入了另一个名为Observable的paging$来执行分页。这个Observable发出页码。当页面发生变化时，我必须进行另一次服务器调用来检索其余的书籍。
当我在用户单击页面时调用服务器时，我有页面号，因为它直接来自UI，而不是searchQuery$已经发出的搜索字符串。
如何将searchQuery$和paging$组合起来，使用RxJS检索搜索字符串和页码？
更新：
事件：
用户在搜索框中键入an。
展示了前
浏览 3提问于2017-03-14得票数 1
回答已采纳
Metronic主题角8中的可观测误差
我在metronic主题角8的另一个组件中使用auth服务，但是相同的服务正在产生错误，但是在默认的逻辑组件中它是工作的
this.auth
.login(authData.email, authData.password)
.pipe(
tap(user => {
console.log(user);
if (user) {
this.store.dispatch(new Login({a
浏览 1提问于2019-11-14得票数 0
我想从RxJS中的触摸事件中重新创建RxJS事件，因为iOS 是触控上的contextmenu事件。
在简单的语言中，这个可观察到的应该在以下情况下发出：
发生了touchstart事件
2000毫秒(基本上是长压机)
接着是触底
它不应在下列情况下发出：
触摸端发生在少于2000 in的时间内。
在touchstart事件之后是touchmove事件。
我不知道如何跳过，如果触点结束发生得更早，或者是先开始后再进行触地移动。到目前为止，这就是我所做的：
const touchStart$ = fromEvent<TouchEvent>(this
浏览 3提问于2022-05-19得票数 2
回答已采纳
在下面的代码示例中，意图是通过向主题second$发出1来阻止事件发生。
import { Subject, timer } from "rxjs";
import { switchMap, takeUntil, tap } from "rxjs/operators";
const first$ = timer(1000);
const second$ = timer(2000);
const mid$ = new Subject();
first$.pipe(
tap(() => {
mid$.next(1);
}),
sw
浏览 3提问于2021-02-15得票数 3
回答已采纳
1回答
各位，我有一个应用程序使用RxJS来处理鼠标事件。我正在将这些事件组合成更复杂、可观察的“手势”。这样的手势之一就是“摇动”。
我试图撰写的一系列事件是：
mousedown
mousemove left
mousemove right
mousemove left
mousemove right
mouseup
我发现
mousedown
mouseup
mousemove left
mousemove right
mousemove left
mousemove right
也会触发同样的结果。
我做了。
我的问题是:您如何在RxJS中表示一个可实现
浏览 5提问于2014-07-06得票数 0
回答已采纳
有几种方法可以取消订阅角度组件上的可观测数据(通过使用ngOnDestroy)。下面哪个选项应该是首选的，为什么(例如，技术原因、性能等)？
选项1: takeUntil
使用RxJS takeUntil取消订阅
@Component({
selector: "app-flights",
templateUrl: "./flights.component.html"
})
export class FlightsComponent implements OnDestroy, OnInit {
private readonly destroy$ = n
浏览 2提问于2019-10-17得票数 19
回答已采纳
我有以下的，希望是相当标准的，拖放代码使用Rxjs在角2。
blockElement恰好是一个SVG矩形，但我认为这对问题没有任何影响。
当blockElement最终被删除时，我需要设置它的坐标，即当mouseup事件在拖放的末尾触发时。这样用户就可以大致地将其放置在正确的位置，并且代码行正确地排列其位置。
我可以通过运行函数来响应takeUntil来实现这一点吗？或者，我还可以使用其他Rxjs操作符在拖动结束时运行函数来响应mouseup吗？
(为了清晰起见，我已经编辑了代码，但是实际的代码确实有效，所以如果下面的代码有任何错误，它应该与问题无关，希望您能理解)
const taskMou
浏览 2提问于2017-05-25得票数 0
回答已采纳
我使用RxJs delayWhen将一些后端请求之间的延迟配置为60秒。我想要实现的是在某个时候取消正在进行的延迟的可能性。 假设延迟过了30秒，用户正在进行一些操作。我想立即触发一个后端请求，而不是等待接下来的30秒。 有没有办法使用rxJs做到这一点？
浏览 16提问于2020-04-03得票数 0
回答已采纳
我最近升级到了角11.2.9和RXJS 6.6.7。我的部件里有这个..。
ngOnInit(): void {
window.addEventListener('blur', this.onBlur, false);
...
}
...
onBlur(): void {
this.trendingSet$ = timer(1, HotComponent.REFRESH_INTERVAL_IN_MS).pipe(
switchMap(() => this.apiService.getTrending()),
浏览 1提问于2021-04-19得票数 0
回答已采纳
1回答
如何循环史诗调用
、、、、
我有以下史诗：
import {
map,
catchError,
switchMap,
takeUntil,
} from 'rxjs/operators';
import {
FETCH_JOKES,
jokesReceived,
FETCH_JOKES_CANCELLED,
jokesFetchFailed,
} from '../actions/jokes-action';
import { ofType } from 'redux-observable';
import { of, concat } fr
浏览 0提问于2018-09-25得票数 1
回答已采纳
1回答
我是Rxjs/Observables的新手，它真的开始困扰我了。我使用了一个可观察对象来遍历方法，并确保在每个方法完成后逐个调用它们(使用next()函数)。那么，在假设所有5个next调用中的第二个调用某些数据出现问题后，如何取消整个订阅？下面是一个简化的示例代码，便于您了解情况。
我正在导入以下数据：
import { Observable } from 'rxjs';
在构造函数中，我准备好我的Observable：
this.myObservable = new Observable( observer => {
observer.next( this.fun
浏览 5提问于2018-11-19得票数 1
1回答
假设我想要定期地发出值，直到另一个可观测到的发射。因此，我可以使用timer和takeUntil来实现这一点。但是，我希望处理每个发出的值，并在某些条件变为真时停止(错误)发出。所以我写了下一段代码：
const { timer, Subject } = 'rxjs';
const { takeUntil, map } = 'rxjs/operators';
const s = new Subject();
let count = 0;
function processItem(item) {
count++;
return count < 3;
浏览 3提问于2019-10-04得票数 1
回答已采纳
我是rxjs的新手，所以我可能不会像一个有经验的用户那样使用它。
我也在使用rxjs 5.1.0。
我有一个服务，其中有一个名为file$的BehaviorSubject和一个来自file$的名为files的observable
@Injectable()
export class UploadService {
files$: BehaviorSubject<FileToUpload[]> = new BehaviorSubject([]);
files: Observable<FileToUpload[]> = this.files$.asObservabl
浏览 45提问于2019-02-21得票数 2
我有一个带有计时器的子组件，每2秒我就向服务器发送api调用。我需要做这个调用，只要用户在页面上，即使他/她去参加婚礼，并离开页面(父组合窗口)打开。
下面是我组件中的一些代码：
this.myTimer = Observable.timer(1, 2000);
this.myTimer
.mergeMapTo(this.myService.doSomeWork(this.myId))
.subscribe((data) => {
this.myData = data;
浏览 1提问于2019-06-19得票数 3
回答已采纳
2回答
我试图在RxJ上创建类似事件循环的东西，我使用firstValueFrom作为一个门，等待所有事件在进一步处理之前被处理。目标是让nodejs服务运行并对各种事件做出反应，处理这些事件，并且能够在接到命令时优雅地关闭。
我可以看到我无法向自己解释的行为--当退出条件能够满足时--所有事情都按预期工作:事件由发行者发布，由处理程序处理。
但是，当我消除退出事件出现的可能性时，代码会在rx.firstValueFrom调用之后立即退出。
守则：
import * as rx from "rxjs";
import * as op from "rxjs/operators&#
浏览 1提问于2021-10-29得票数 0
我想做从Angular 9/RxJ到rest服务的池化，每5秒返回一个状态。rest服务是一个典型的get，它只返回事务的状态。下面的代码基于一些搜索，包括StackOver flow中的一些答案。我不断得到错误粘贴的bellow。 到目前为止，我找到的所有答案都告诉我导入我已经导入的内容。 任何额外的东西需要检查将非常感谢。 错误： core.js:6185 ERROR TypeError: rxjs__WEBPACK_IMPORTED_MODULE_2__.Observable.interval is not a function
at AppComponent.ngOnInit
浏览 17提问于2020-03-24得票数 1
回答已采纳
RxJS/角专家，需要您的输入/指针
我正在尝试将一个逻辑放在可观察的(从http调用创建的)上。
如果第一个事件在前3分钟内无法从可观测到的位置发出，我想返回(从等待中退出并停止对可观测到的订阅)。
但是，如果在前3分钟内发出了第一个事件，我希望继续订阅&获取总共10分钟的数据(从订阅开始时起)。
到目前为止，使用takeUntil(计时器(1000* 60 * 10) )等待总共10分钟，但要将此等待除以3分钟，如果某些响应->仅延长7分钟
伪码
Observable
.pipe(
takeUntil(timer(10* 60 * 1000)),
map (r
浏览 2提问于2019-08-13得票数 2
回答已采纳
嗨，我对Angular非常陌生。我有大约4个数据库查询，每个查询都是Subscriptions(rxjs/Rx)。因此，我知道我需要取消订阅每个订阅，以避免内存泄漏。如何优化呼叫？我的意思是，我不想给每个订阅打电话，然后一个接一个地取消订阅。我想在一个电话里完成所有的取消订阅。如果这是一个愚蠢的问题，很抱歉。伙计们，你们知道吗？提前感谢
浏览 7提问于2017-03-08得票数 3
回答已采纳
我正在尝试使用RXJS进行拖放。
有谁知道如何使用RXJS正确地执行onDrop或onDragOver吗？
这是我尝试过的。但不能工作。
let mouseup = Observable.fromEvent(document, 'mouseup');
let mousemove = Observable.fromEvent(document, 'mousemove');
let mousedown = Observable.fromEvent(target, 'mousedown');
const
浏览 2提问于2017-04-20得票数 0
由于某些原因，我不能在我的任何可观测数据上使用takeUntil方法。
我的IDE (Visual )在我编写代码时显示它是一个有效的方法，它编译得很好(从类型记录)，但是当我运行它时，我可以在我的任何一个可观察到的数据上得到takeUntil is not a function。
我使用的是rxjs 5.3.0版本。
我可以通过各种各样的方式来实现这一点，但这可能是最直接的：
let subject:BehaviorSubject<any> = new BehaviorSubject<any>({});
let unsubscribe: Subject<void
浏览 2提问于2017-04-20得票数 15
回答已采纳
1回答
我想根据两个条件停止可观察的订阅：
使用import { timer } from 'rxjs/internal/observable/timer';)的时间
或
执行状态(使用从请求返回的对象，您将在下面看到)
正在发生的事情：
它只是基于时间停止执行(使用import { timer } from 'rxjs/internal/observable/timer';)
这是我目前的代码：
属性、变量及其值的名称已经更改，例如：
import { finalize } from 'rxjs/internal/operators/finalize
浏览 3提问于2020-07-16得票数 7
回答已采纳
我有一个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
我在为这件事而挣扎，我不知道该怎么做。我只想捕捉鼠标事件，只有当用户停止使用mousemove在一定时间内，它在特定的元素。
const { fromEvent } = rxjs;
const { debounceTime, tap, filter } = rxjs.operators;
const square = document.querySelectorAll("#square");
let isCursorOverSquare = true;
const move$ = fromEvent(square, "mousemove");
cons
浏览 1提问于2018-09-26得票数 0
回答已采纳
试图在React中实现rxjs可观察的管道。
代码框示例->
在React中创建html元素(div)，并绑定mouseover和mouseout事件。
将“响应代码”初始化如下：
useEffect(() => {
const elMouseOut$ = fromEvent(elRef.current, "mouseout").subscribe(() =>
setState({ hover: "mouseout", eventType: "mouseout" })
);
cons
浏览 3提问于2021-08-09得票数 2
1回答
我是RxJs的新手，一旦符合条件，我发现取消订阅循环很困难，你能帮我吗？
在下面的函数中，如果任何时候代码到达if块，我想取消订阅可观察的
在问这个问题之前，我先问了以下几个问题，但没有一个问题对我有很大帮助。
Javascript函数
this.router.events.subscribe((url: any) => {
url = this.router.url;
if ((url === "/profile" || url === "/summary") && this.filterConfigF
浏览 1提问于2018-07-05得票数 7
回答已采纳
@effect()
public loadAccommodations$: Observable = this.actions$
.ofType(PAA.PROPERTY_LOAD_REQUEST)
// .debounce(300)
// introducing this mitigates the flood but does not resolve the issue
.switchMap((action: Action) => {
return this.propertyAccommodationsService.loadAccommo
浏览 2提问于2017-09-13得票数 0
我得到了上面提到的错误与我的角度ts文件。但不能理解并修复。有人能帮我吗？
ts文件：
import { Component, OnInit, OnDestroy } from '@angular/core';
import { ScullyRoute, ScullyRoutesService } from '@scullyio/ng-lib';
import { Subscription } from 'rxjs';
@Component({
selector: 'app-articles',
templateU
浏览 4提问于2021-11-25得票数 0
我已经阅读了关于这个错误的文档，我想我理解为什么会出现这个问题。我想找出一种适合我的替代架构，我遇到了麻烦。
my site的根组件(app.component)上有一个“加载”组件。这是一个第三方组件(ngx- that )，它基本上会弹出一个加载指示符，以显示用户在应用程序中发生了一些需要一些时间的事情。加载组件接受一个参数，该参数告诉它是否显示：
<ngx-loading [show]="loading" [config]="{ backdropBorderRadius: '14px' }"></ngx-loading&g
浏览 2提问于2017-10-19得票数 1
回答已采纳
我试图实现rxjs函数distinctUntilChanged但没有工作..。
public searchVal(val: string) {
this.suggestions = (new Observable((observer: Observer<string>) => {
observer.next(val);
})).pipe(
takeUntil(this.destroy$),
distinctUntilChanged(),
switchMap((
浏览 2提问于2021-11-26得票数 0
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
在Angular应用中，特别是在使用NGRX的时候，我们有很多RxJS订阅。是的，我们(开发人员)可能会忘记取消订阅。有没有什么工具可以帮助分析这个问题？
浏览 10提问于2018-01-12得票数 2
1回答
我有以下功能，它在急流下载时发出数据：
torrentBuffer.on('download', () => {
})
这个函数非常快地触发事件，我只需要每秒钟更新一次数据。
如何使用可观察的rxjs实现这一目标？
浏览 3提问于2020-09-23得票数 0
回答已采纳
1回答
我有两个可以观察到的
clients$是客户端连接的流。
data$是一个源源不断地传递数据的流。
每当客户端连接时，我都订阅data$并将其发送给客户端。
我读到嵌套订阅在RxJS中是不可接受的，所以这种方法可能是错误的。
const clients$ = createClientStream()
const data$ = Observable.interval(1000).share()
clients$.subscribe(c => {
const s = data$.subscribe(d => c.send(d))
c.on('disconnect
浏览 1提问于2016-05-23得票数 1
回答已采纳
在角7组件中，我使用RxJS takeUntil()正确地取消对可观察订阅的订阅。
当方法ngOnDestroy中缺少this.destroy$.next()时会发生什么(参见下面的示例)？它是否仍然正确地取消订阅？，当方法ngOnDestroy中缺少this.destroy$.complete()时会发生什么(参见下面的示例)？它是否仍然正确地取消订阅？是否有任何方法来强制使用takeUntil()来取消订阅(例如，tslint规则，npm包)？
@Component({
selector: 'app-flights',
templateUrl: '.
浏览 9提问于2019-10-17得票数 7
回答已采纳
1回答
我对观察和打字很陌生，所以这可能是个新手问题。我想构建一个简单的计时器，但我希望能够取消订阅定时器本身内的所有订阅者。
到目前为止，我的代码是这样的。
import { Observable } from "rxjs/Rx";
export class Timer {
private interval: number;
private ticker: Observable<any>;
constructor() {
this.interval = 1000; // Miliseconds
this.tic
浏览 0提问于2018-04-05得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
