如何在取消订阅时取消异步可观察线程
在取消订阅时取消异步可观察线程，可以通过以下步骤实现：
- 确保订阅者能够取消订阅：在异步可观察线程中，订阅者应该提供一个取消订阅的方法或接口，以便在需要时能够主动取消订阅。
- 在取消订阅时停止异步可观察线程：当订阅者调用取消订阅的方法时，异步可观察线程应该被停止。具体的实现方式取决于所使用的编程语言和框架。
- 使用合适的线程管理机制：为了确保在取消订阅时能够正确地停止异步可观察线程，可以使用线程管理机制来管理线程的生命周期。例如，在Java中可以使用线程池来管理线程，通过调用线程池的相关方法来停止线程。
- 销毁资源：在停止异步可观察线程后，需要确保释放相关的资源，以避免资源泄漏。这包括关闭数据库连接、释放网络连接、销毁对象等。
总结起来，为了在取消订阅时取消异步可观察线程，需要订阅者提供取消订阅的方法，异步可观察线程在接收到取消订阅请求后停止运行，使用合适的线程管理机制来管理线程的生命周期，并在停止线程后销毁相关资源。这样可以确保在取消订阅时能够正确地取消异步可观察线程，避免资源泄漏和不必要的计算开销。
腾讯云相关产品和产品介绍链接地址：
- 腾讯云云服务器（CVM）：https://cloud.tencent.com/product/cvm
- 腾讯云云数据库 MySQL 版：https://cloud.tencent.com/product/cdb_mysql
- 腾讯云云原生容器服务（TKE）：https://cloud.tencent.com/product/tke
- 腾讯云音视频处理（VOD）：https://cloud.tencent.com/product/vod
- 腾讯云人工智能（AI）：https://cloud.tencent.com/product/ai
- 腾讯云物联网平台（IoT）：https://cloud.tencent.com/product/iotexplorer
- 腾讯云移动开发（移动推送）：https://cloud.tencent.com/product/umeng
- 腾讯云对象存储（COS）：https://cloud.tencent.com/product/cos
- 腾讯云区块链服务（BCS）：https://cloud.tencent.com/product/bcs
- 腾讯云元宇宙（Tencent Real-Time Render）：https://cloud.tencent.com/product/trr
相关·内容
2回答
我想将一个IEnumerable，IDisposable (源代码)改编成一个可观察的，并且想知道最好的方法来做到这一点，并让source.Dispose方法被取消订阅。
现有的 on introtorx.com适用于IEnumerable，但明确指出其存在着处理模式不正确、并发模型差、没有错误处理等缺点。内置版本处理这些。但是内置版本似乎没有在取消订阅时调用对源IEnumerable的Dispose。
理想情况下，我希望使用.Publish().RefCount()模式在同一个源上拥有多个订阅者，并且只有当源Dispose()全部未订阅时才调用它们。
以下是我尝试的代码，尽管它不起作用。
s
浏览 4提问于2016-12-20得票数 3
回答已采纳
最近我遇到了一些解释“可观察”的文章，因为我对“角度”还不熟悉，所以我一直在试图找到最好的方法来做每件事。
我看到了这篇文章：，它查看订阅和异步管道。
然而，即使在研究了这篇文章和这些关于是否订阅的文章之后，我仍然发现很难得到一个明确的答案。
因此，我知道您对服务的订阅可能会泄漏，根据，如果您要使用subscribe()，那么您应该在ngOnDestroy()期间使用unsubscribe()。
否则就会发生这样的情况：
订阅永远不会取消订阅，因此，如果可观察到的对象本身不完成，那么整个组件、它的模板及其所有相关对象都将永远存在于内存中。
然而，我也看到过，有时人们会说，在调用组件中的
浏览 0提问于2019-01-15得票数 2
回答已采纳
我使用Observable.create()来创建一个可观察的，以便在调度程序上执行一些工作(例如，Schedulers.io()，然后在AndroidSchedulers.mainThread()上返回一个结果)。
val subscription = observable<T> {
try {
// perform action synchronously
it.onNext(action.invoke(context, args))
it.onCompleted()
} c
浏览 0提问于2015-05-12得票数 6
回答已采纳
1回答
当我的服务调用返回HTML页面的数据时，使用异步绑定与只映射到具体对象有什么好处或好处？
下面是这两个选项的一个例子。
映射到组件属性
// component
event: any;
// ngOnInit()
this.eventService.getEvent(this.id).pipe(take(1)).subscribe(response => {
this.event = response;
}, error => {
console.log(error);
});
// service
getEvent(id: number): Observable&
浏览 1提问于2021-12-03得票数 1
1回答
使用RX创建可观察到的IO绑定
、、、、
我有一个进行阻塞调用(ReadFrame)的工作线程从套接字(IO绑定)读取传入数据。线程运行一个循环，该循环将数据输入到Subject中，使用者可以观察该循环。
private void ReadLoop()
{
while (!IsDisposed)
{
var frame = _Socket.ReadFrame();
_ReceivedFrames.OnNext(frame);
}
}
我想知道是否有更多的RX方式来做到这一点。
下面是我所做的一个尝试(玩具示例)：
var src = Observable
.Re
浏览 1提问于2015-07-03得票数 3
我需要确定两种处理可观测值的不同方法是否同样有效，或者其中一种方法是否会导致内存问题。
在下面的示例中，foo$和bar是从服务接收其值的模板变量。每个人都有自己的可观察性。在组件中，从订阅中显式地给出了bar的值，然后在OnDestroy()中结束该订阅。然而，foo$没有显式地订阅服务，而是在模板中使用async管道。
foo$和bar都是显示服务数据的有效方式，还是foo$有问题，因为没有取消对内存清理的订阅？
ExampleService:
Injectable()
export class ExampleService {
get foo$(): Observable<
浏览 2提问于2019-05-08得票数 3
回答已采纳
考虑在Service中查询two服务的以下两种方法：
getAssessmentById(id: number): Observable<MotorAssessorReport> {
const url = environment.endPoints.assessment.base +
environment.endPoints.assessment.assessmentById + id;
return this.httpClient.get<MotorAssessorReport>(url)
}
async getAssessmentByIdAs
浏览 0提问于2019-04-28得票数 7
我有一个组件，它从数据服务中调用一个返回可观察的方法。是否必须取消在ngOnDestroy方法中可观察到的订阅？
服务
public class BlogService {
public getPosts(): Observable<Array<Post>> {
return this.http.get('');
}
}
组件
public class ListComponent implements OnInit {
constructor(private blogService: BlogService) {}
浏览 0提问于2019-07-03得票数 1
回答已采纳
1回答
我必须捕捉管道中事件发射器发出的事件，并在此基础上执行一些操作。
下面是html和ts文件的代码片段。
xyx.component.html
<div *ngIf="count | async as count">
<div style="text-align: center">
<div>{{ count.counter }}</div>
<div>
<input type="button" value="start" (c
浏览 2提问于2020-03-31得票数 1
我们是否需要取消可观察到的订阅？什么时候我们需要使用取消订阅？
我读了一篇关于使用angularfire2检查用户登录状态的firebase.auth的文章。在代码的末尾，他不订阅auth.subscribe。 (请见app.component.ts)。
我真的很困惑，因为我认为，在完成或错误后，可观察到的将“取消订阅”本身。
和
浏览 5提问于2017-02-05得票数 1
回答已采纳
我正在使用连接到Firebase列表
tasks: FirebaseListObservable<ITask[]>;
constructor(private af: AngularFire) {
this.tasks = this.af.database.list("/tasks");
}
现在，当我的用户注销时，我想取消该连接。
我已经尝试过this.tasks.unsubscribe()，但是该方法看起来是未定义的(我尝试这样做是因为FirebaseListObservable是一个可观察的对象)。
我还按照文档中的建议尝试了this.tasks.off(
浏览 9提问于2017-02-20得票数 5
回答已采纳
1回答
当组件被破坏时，角自动“处理/关闭/完成”组件使用的可观测值及其相关订阅吗？
或者应该在组件的onDestroy中显式地处理它们？
根据公认的答案，至少在2017年4月之前，需要手动处理可观测数据。
我想知道现在的情况是否仍然如此
编辑1
在角度文档上，我找到了，它似乎解决了这个问题，但我不知道如何在组件中使用它。开发人员应该在属性中存储可观察的属性，而不是在subscribe.next中设置属性。如果我使用异步管道并将属性设置为可观察的，下面的组件模板将如何变成？
<h1>{{property.title}}</h1>
<p>{{property.desc
浏览 2提问于2018-02-13得票数 0
回答已采纳
1回答
如何取消正在运行的store.dispatch(xxx)操作，使底层的http请求也被取消？
我尝试从store.dispatch(new FetchSomeStuffOverHttp())调用中执行.unsubscribe()，并预计底层的http请求也会被取消。
但它将继续运行，即使该操作返回了httpClient的observable：
@Action(FetchStuffOverHttp)
fetchStuffOverHttp({ patchState }: StateContext<AuftragStateModel>) {
return this.httpClien
浏览 1提问于2020-04-02得票数 2
在模板中使用异步管道时，是否有一种方法可以像这样重新发送HttpRequest？
myObservable$ = this.http.get('api');
<div *ngFor='let item of myObservable$ | async'>{{item}}</div>
浏览 1提问于2019-05-17得票数 5
回答已采纳
从eslint-rxjs中有一条规则是。
禁止的模式是(禁止使用async关键字)：
of(42).subscribe(async () => console.log(value));
为什么这是件坏事？
我在某个地方看到了这是因为它不受支持，但是我已经测试了它，并且它可以工作，我可以在回调函数中使用await，并且它可以工作。
浏览 2提问于2022-03-21得票数 0
回答已采纳
我是一个业余爱好者，正在自学angular一年。当我试图开发一个自定义分页服务来从firebase中检索数据时，我想出了一个在使用异步管道或普通订阅时返回不同数组的观察值。 基本上，我的observable使用扫描操作符来累积从firebase获取的数据。它有两个方法: init获取第一个数据并使用初始数据设置observable，以及addData获取更多数据。 在启动服务并添加一些数据后，如果我再次初始化它，如果使用正常订阅，它将不会重置数据。但如果使用异步管道，该服务将按预期重置数据。为什么订阅管道和异步管道具有不同的行为，而预期具有相同的行为？ 我在stackblitz中创建了一个错
浏览 7提问于2019-06-09得票数 1
2回答
很多角度教程都建议使用异步管道来实现自动不可观测。
他们声称的：
异步管道用于自动取消订阅观察者，否则需要手动取消订阅。
他们做了什么：
他们使用角http调用REST作为async管道的示例。
然而，根据我的理解，角HTTP自动取消订阅可观察到的内容。因此，异步管道实际上并没有达到预期的目的，因为即使没有异步管道，可观察到的用户也会自动取消订阅。
在这个用例中，为什么需要在这里使用异步管道，还有其他原因吗？
抽样实施情况：
getUserList() {
return this.http.get(apiUrl);
}
this.getUserList().subscribe(use
浏览 6提问于2017-09-22得票数 6
回答已采纳
3回答
所以我在玩RX (真的很酷)，我一直在转换我的api，这个api访问Android中的sqlite数据库，以返回可观测值。
因此，我开始尝试解决的问题之一自然是，“如果我想要进行3个API调用，得到结果，然后在它们都完成后进行一些处理，怎么办？”
这花了我一两个小时，但我最终找到了，它帮助我轻松地走出了困境：
Observable<Integer> one = getNumberedObservable(1);
Observable<Integer> two = getNumberedObservable(2);
Observable<In
浏览 2提问于2014-01-18得票数 15
回答已采纳
2回答
我想用ngrx做一个语言管道。
component.html：
<p>{{1 | language: languageId | async }}</p>
语言管道：
constructor(private store:Store){}
transform(resourceId: number, languageId:number): Observable<string> {
return this.store.select(selectResource, { resourceId, languageId });
}
我的问题是，如果我更改了
浏览 5提问于2020-08-06得票数 2
回答已采纳
所以，基本上，rxjs是新的，想知道，
我是否需要从Observable.of(数据)或更新的rxjs版本中取消订阅(数据)？
即
import {of} from 'rxjs';
const sub = of(data).subscribe();
这有必要吗？
sub.unsubscribe();
浏览 2提问于2019-04-28得票数 6
我确信问题是我是个菜鸟，并不完全理解异步/等待的基本原理。
我有两个函数:一个返回对象，另一个返回数组(如下所示)。
返回对象的对象按预期返回。
返回数组的返回undefined。
造成挂断的原因是什么？
userRole.service.ts
async getUserRolesEnum(): Promise<any> {
var result: any = {};
await this.authHttp
.get<UserRole[]>(this.baseUrl + "UserRoles", { hea
浏览 0提问于2018-07-10得票数 1
回答已采纳
2回答
我有以下代码：
<div *ngIf="users">
<ul>
<li *ngFor="let user of users">{{ user.name }}</li>
</ul>
</div>
TS文件
export class AppComponent implements OnInit {
constructor(private http: HttpClient) {};
users: any;
ngOnInit() {
this.s
浏览 3提问于2020-11-25得票数 0
回答已采纳
1回答
冷热观测-最后一次刷新值
、、、
我有一个场景，我想从服务器获取一些数据，并且用户可以请求刷新这些数据。页面的其余部分需要更新以反映当前加载的数据迭代。
我想象一下，在这里，我有一个可以观察到的热点，可以发布它加载的数据。我不想将数据的所有旧迭代保留为1，我只关心数据的最新迭代，2.如果用户在给定的会话中进行足够的刷新，可能会导致内存不足的异常。
但是，我确实希望保留上一个已发布的值，这样如果我动态地打开一个需要访问相同数据的新组件，它就不会发出不必要的新请求。为此，我需要一个可观察的坐在热可观测的顶部，这将只保留和释放来自热可观测的最后的排放。这里有一个图表说明了这个想法：
dataStream X - - - -
浏览 0提问于2016-03-16得票数 1
回答已采纳
1回答
例如，当我有多个可观察到的订阅者时：
const myInterval = Rx.Observable.interval(500);
const subscriptionOne = myInterval.subscribe(val => doSomething());
const subscriptionTwo = myInterval.subscribe(val => doSomething());
我如何知道仍有多少订阅者注册到可观察到的myInterval？例如，我需要这些信息来防止内存泄漏，，，以防我忘记从其中之一取消订阅？
浏览 2提问于2016-10-20得票数 6
2回答
我想重用可观察到的列表，尝试以下但不起作用：
this.transactions是一个可观察的列表
this.transactions.pipe(
map(actions => actions.map(t => {
if (t.type === 1) {
} else if (t.type === 2) {
}
}
}))
);
对象视图：
什么都没发生，没有循环，没有地图，请帮忙。
浏览 1提问于2019-05-08得票数 1
9回答
我有一个主题，它向客户提供Subscribe(Observer*)和Unsubscribe(Observer*)。Subject在自己的线程中运行(在订阅的观察者上调用Notify() )，互斥对象保护它的内部观察者列表。
我希望客户机代码--我无法控制--能够在未订阅后安全地删除一个观察者。如何才能做到这一点？
保持互斥锁--甚至是递归互斥锁--而我通知观察者并不是一种选择，因为存在死锁风险。
我可以在取消订阅调用中标记一个删除的观察者，并将其从主题线程中删除。然后客户端可以等待一个特殊的“安全删除”通知。这看起来很安全，但对客户来说却很麻烦。
编辑
下面是一些说明性代码。问
浏览 9提问于2009-02-10得票数 11
回答已采纳
https://rxjs-dev.firebaseapp.com/api/ajax/ajax 为什么rxjs ajax操作符返回一个Observable？我认为一个请求返回一个响应，连接就结束了。为什么它是可观察的，而不是单个响应消息？
浏览 13提问于2020-03-30得票数 1
回答已采纳
public testArr: any = [];
getData() {
this.dataS.getSensor().subscribe((data: any) => {
this.testArr= data;
})
}
this.testArr.unsubscribe()
如果我的testArr是数组怎么办？现在是老了吗？
浏览 9提问于2020-02-21得票数 1
回答已采纳
我想确保当我使用RxJava时，我没有创建任何内存泄漏。请告诉我这是否是处理每一件案子的正确方法..。
案例1
如果我在相同的范围内创建一个Observable和一个Subscription，GC会处理它们，对吗？我必须在这里打电话给unsubscribe()吗？
public static void createObservableAndSubscribe() {
Observable<Integer> source = Observable.just(1,6,3,2,562,4,6);
Subscriptio
浏览 0提问于2015-06-24得票数 6
回答已采纳
3回答
角NGXS中的取消订阅
、、、
我对NGXS的角度很陌生，我读过这样的文章:当您使用异步管道时，您不需要取消订阅。不过，我也是从queryParams订阅的，也是订阅dispatches操作的。我是否需要取消订阅这两个代码下面？
this.route.queryParamMap
.pipe(map(params => params.get('page')))
.subscribe((page: any) => {
this.page = page;
console.log(page);
});
this.store.dispatch(new AddEmployee(form.
浏览 0提问于2019-05-16得票数 4
回答已采纳
public ukmdetail: Detail = null
constructor(
private ukmserv: UkmService,
public activatedRoute: ActivatedRoute
) { }
ngOnInit() {
this.activatedRoute.params.subscribe(params => {
this.ukmdetail = this.ukmserv.getUkmByKode(params.kode)
})
} getUkmByKode(kode:
浏览 54提问于2019-12-03得票数 0
回答已采纳
3回答
我创造了这样一个可以观察到的：
public Observable<FileObjectModel> getAllFiles() {
return Observable.create(new Observable.OnSubscribe<FileObjectModel>() {
@Override
public void call(Subscriber<? super FileObjectModel> subscriber) {
//fileList is a huge list.
浏览 3提问于2016-11-24得票数 1
米格尔·拉维涅在 @中说：
“请记住，如果您使用的是片段或活动中的可观测值，您应该始终确保取消订阅可观察到的内容，以消除内存泄漏的可能性。”
我很清楚它是如何工作的，只要我在活动、片段或视图中使用一个可观察的。但是如果我在没有上下文的地方使用它呢？
我的情况:我有一个包含对象模型的外部库。每个对象都有一个.save()函数，它是从UI调用的。在保存中，API端点调用由可观察的异步执行。
示例：
public Overlay save() {
Observable.create(new Observable.OnSubscribe<Overlay>() {
浏览 3提问于2014-10-05得票数 3
回答已采纳
我一直在做一个有棱角的项目。但我的项目不像它应该做的那样。我得到了错误" Error :无法找到“object”类型的不同的支持对象‘对象’。NgFor只支持绑定到诸如数组之类的Iterable。“在我页面的控制台里。
在我的页面上，我得到了“这件事”，但仅此而已。同时，我也应该看到我的'dier‘的'soort’。
在我的html中：
<p>This works</p>
<div
class="dier"
*ngFor="let dier of dieren$">
浏览 2提问于2020-05-19得票数 1
回答已采纳
1回答
我一直在尝试学习rxjs中的声明式模式/方法，据我理解，这种模式/方法不是在类型记录本身中直接使用.subscribe()，而是使用async管道。
我有一个类，它保存有关图像的数据，其中一些数据是一个tags属性，它是一个字符串数组。通过UI，您可以向此属性添加/删除标记。当您保存一个新项目时，值通过websocket传递给服务器，套接字将返回所有项目标记的列表(包括新添加的标记)。
因此，我创建了一个侦听器，用于侦听websocket何时使用与图像标记相关的数据进行响应。当它看到这条消息时，它应该更新该图像对象中的所有标记。
如下所示的伪代码：
interface FileInfo {
浏览 2提问于2022-04-07得票数 1
回答已采纳
1回答
使用可观测值自动更新视图
、、、
我使用可观察和HTTP请求在服务器上添加数据，然后更新其他路由。
我希望这些数据能立刻更新。实际上，我应该刷新页面以获得新的数据。
在我的服务中，我使用AddProj()和getAllProj()函数来获取和发送数据
service.ts
import { Injectable } from "@angular/core";
import { NouveauProjet } from "./models/nouveau-projet";
import { HttpClient, HttpResponse } from "@angular/common/h
浏览 3提问于2017-12-22得票数 0
1回答
我想异步地处置一个observable的unsubscribe函数中的资源。例如：
// rxjs 6
let observable = Observable.create(sub => {
let resource = new Resource();
return {
async unsubscribe() {
await resource.dispose();
}
}
};
问题是，因为unsubscribe函数不应该返回Promise，所以不会有任何东西等待它，所以unsubscribe函数将在资源完
浏览 0提问于2018-09-17得票数 5
1回答
我的应用程序中有一个聊天部分，scrollBottomOnInit()函数可以工作，但只适用于发送方。
问题1：当valueChanges()如何修复时，我想要scrollBottomOnInit()函数工作？
问题2：当用户退出此页面时，valueChanges()继续工作吗？
import { Component, OnInit, ViewChild } from '@angular/core';
import { NavController } from '@ionic/angular';
import { ActivatedRoute } from &#
浏览 4提问于2020-11-03得票数 1
回答已采纳
我正在考虑是否在我的新Angular 2应用程序中使用可观察性或承诺。有人告诉我，可观察对象可以做任何承诺能做的事情，甚至更多，但我很好奇，与承诺相比，可观察对象需要多少开销。有没有人运行基准测试？还有什么理由可以使用promises吗？
浏览 4提问于2016-07-28得票数 2
3回答
我在服务中有以下地图：
private slotlist: Map<number, SlotItem>;
SlotItem是一个类。我把服务中的时隙列表还给你，包括：
getSlotItems(): Observable<ObservedValueOf<Map<number, SlotItem>>>
有两件事还不清楚：
我如何订阅这些书名呢？
this.slotitems = this.BService.getSlotItems()；
this.slotitems.subscribe(val => console.log，val)
浏览 2提问于2019-07-25得票数 0
我正在使用一个可观察的间隔，每5秒在某个组件内执行某个函数，这与我的路由配置中的路径相关。
Observable.interval(5000).subscribe(res => {
// Something happens here
});
但是，当路径更改时，我希望终止间隔。现在它继续执行任务..。
做这件事最好的方法是什么？
浏览 3提问于2016-04-30得票数 7
回答已采纳
我已经看到数百个论坛在搜索这个错误，但我还没有找到合适的答案，我在Angular上相对较新，仍然不能理解生命周期钩子的事情。 我有一个父窗口，它有一个组件，在这个组件中我设置了窗口的值 <app-acciones [window]="selectedWindow"></app-acciones> 在子窗口中，我有这个窗口的输入，还有一个数组，我想在其中计算我想要订阅的函数值。 @Input() window:Window;
Actions:Action[];
totalActions:number; //this work prope
浏览 7提问于2020-03-30得票数 1
虽然在我看来，冷热观测的一般概念似乎相当清楚，但我在处理某些具体案例时感到困惑。
有一个带有客户端库的特性标志API，提供内部缓存并公开基于回调的访问。我想通过创建一个提供特征标志可观察的服务来使用这个客户端。由于我需要对客户端进行一些额外的配置，并确保按需刷新，所以我想出了以下创建可观察性的方法：
public flag$(key: string) {
if (this.flagCache[key]) {
return this.flagCache[key];
}
const observableKeyFlag$ = this.commonConfig$
浏览 2提问于2019-10-03得票数 0
我使用AngularFireDatabase获取数据库的一部分，如db.object('/accounts/'+this.cid);，其中this.cid是一个可以更改的BehaviorSubject。我是不是走错路了？
cid: BehaviorSubject<string>;
account: FirebaseObjectObservable<any>;
constructor(private db: AngularFireDatabase) {
this.cid = new BehaviorSubject<string>('
浏览 3提问于2017-09-09得票数 1
回答已采纳
使用角，我有一个服务是在一个组件中提供的。该服务具有可观测性，并且该组件被订阅到此可观测项。我原以为我不需要取消订阅/可观察的订阅，因为应该用组件销毁服务，从而也可以观察到服务。然而，一个快速的测试显示，可以观察到的人是活着的。
在我的视线之外发生了什么？会在服务之外运行吗？或者当提供服务的组件被销毁时，服务实际上没有被销毁吗？
浏览 6提问于2019-12-12得票数 4
回答已采纳
当有新的变化时，订阅是否更新数据？？我看到了这个代码(用于角度材质表)： this.nameFilter.valueChanges
.subscribe(
name => {
this.filterValues.name = name;
this.dataSource.filter = JSON.stringify(this.filterValues);
}
) 我从这段代码中了解到，每次nameFilter变量发生变化，其他变量/对象中的信息都会更新，对吗？ 也许，我可以解释一下，它就像
浏览 64提问于2020-12-06得票数 0
回答已采纳
我的Angular2应用程序中有对象数组。当新对象到达时，我使用SignalR填充数组。关键是，当新对象到达时，我出错了。
无法读取未定义的属性
我认为这可能是错误，因为它的工作异步，在html中，我经常在对象中接受对象。
所以现在代码看起来是：
<div *ngFor="let event of events">
<div class="card overview">
<div class="overview-content clearfix ">
浏览 4提问于2017-03-10得票数 2
我正在考虑，它使用Subject来增加搜索的去抖动时间。
但是，该代码不包含任何类型的取消订阅组件销毁。这里不需要取消订阅吗？为什么？如果需要，执行此操作的适当形式是什么？
谢谢。
浏览 0提问于2018-04-02得票数 0
在附带的样本代码中，对于不确定的刻度数，Subject.HasObservers不会立即为真。如果去掉SubscribeOn()，HasObservers总是真的，所以我知道这与IScheduler初始化有关。
这在我们的生产软件中造成了一个问题，尽管保证在允许调用OnNext()的线程继续之前，IDisposable订阅变量已经被初始化，但对OnNext()的前几个调用仍然没有结果。这是RX中的一个bug吗？
使用System.Reactive类来保证在没有轮询的情况下使用调度程序设置订阅的其他方法有哪些？
我尝试过Subject.Synchronize()，但这并没有什么不同。
stati
浏览 0提问于2019-02-16得票数 1
我开始和RxJava和ReactFX一起玩，我对它非常着迷。但是当我在做实验的时候，我有很多问题，我一直在寻找答案。
我观察到的一件事(没有双关意)当然是懒惰的执行。使用下面的探索性代码，我注意到在调用merge.subscribe(pet -> System.out.println(pet))之前不会执行任何操作。但令我着迷的是，当我订阅第二个订阅者merge.subscribe(pet -> System.out.println("Feed " + pet))时，它再次启动了“迭代”。
我想了解的是迭代的行为。它的行为似乎不像一个只能使用一次的Java8 str
浏览 1提问于2015-04-18得票数 10
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
腾讯会议活动推荐
腾讯云开发者
