如何等待外部可观察对象发出一个值，然后在订阅另一个可观察对象之前检查条件？
在云计算领域中，等待外部可观察对象发出一个值，然后在订阅另一个可观察对象之前检查条件的常用方法是使用异步编程和观察者模式。
异步编程是一种处理非阻塞操作的方式，它允许程序在等待某个操作完成时继续执行其他任务，而不会阻塞线程。在等待外部可观察对象发出一个值的情况下，可以使用异步编程来实现。
观察者模式是一种软件设计模式，它定义了一种一对多的依赖关系，使得多个观察者对象同时监听某一个可观察对象。当可观察对象发生变化时，它会自动通知所有观察者对象，观察者对象可以根据自身的需求进行相应的处理。
具体实现上述需求的方法可以是：
- 创建一个可观察对象（Observable）和一个观察者对象（Observer）。
- 在可观察对象中定义一个方法，用于等待外部可观察对象发出一个值，并在满足条件时通知观察者对象。
- 在观察者对象中定义一个方法，用于检查条件，并在满足条件时订阅另一个可观察对象。
- 当外部可观察对象发出一个值时，可观察对象调用通知方法，观察者对象接收到通知后进行条件检查，并订阅另一个可观察对象。
在腾讯云的产品中，可以使用腾讯云函数（Tencent Cloud Function）来实现上述需求。腾讯云函数是一种无服务器的计算服务，可以让您无需管理服务器即可运行代码。您可以在腾讯云函数中编写异步代码，并使用事件触发器来触发函数执行。通过定义适当的事件触发器和函数逻辑，可以实现等待外部可观察对象发出一个值，并在订阅另一个可观察对象之前检查条件的功能。
更多关于腾讯云函数的信息，请参考腾讯云函数产品介绍页面：腾讯云函数
请注意，以上答案仅供参考，具体实现方法可能因具体业务需求和技术选型而有所不同。
相关·内容
1回答
我正在开发一个angular 7应用程序，我知道嵌套的订阅函数是一种反模式，但正确地使用了转换操作符(如mergeMap，switchMap ...)在管道函数中，我总是可以避免它。我正面临着这样一种情况:我不能理解内心的可观察性是如何工作的。我有一个过滤器的形式，它是完全初始化事件后，由一个可观察的信号，在这个事件之后，我必须通过formGroup上的.valueChanges侦听表单更改，格式化过滤器，并最终过滤结果。
this.filters.categoriesReady.asObservable()
.pipe(
tap((categories) =>
浏览 12提问于2019-08-03得票数 0
1回答
我使用选择器从ngrx获取数据。
schedules$ = this.store.pipe(select(selectSchedulingsTimes));
然后在奥尼尼特的烟斗上观察到
ngOnInit() {
this.store.dispatch(new GetSelectedItem());
this.store.dispatch(new GetSchedules());
let data = this.schedules$.pipe(
map((elm: ISchedule[]) => {
return elm.map((elm: ISche
浏览 1提问于2019-07-23得票数 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
为什么subscribe从不在这里打印任何东西？只是出于好奇。无论如何，这是一种糟糕的做法:我通常会使用observeOn。然而，我不明白为什么subscribe从来没有到达.
val subject: PublishSubject<Int> = PublishSubject.create()
val countDownLatch = CountDownLatch(1)
subject
.map { it + 1 }
.subscribeOn(Schedulers.computation())
.subscribe {
println(Th
浏览 2提问于2020-08-09得票数 1
回答已采纳
似乎他们返回相同的结果，为什么使用一个而另一个呢？
var computed = ko.computed(function(){return 'foo';});
var observable = ko.observable();
var observableArray = ko.observableArray();
console.log('computed isObservable', ko.isObservable(computed));
console.log('observable isObservable', ko.isObser
浏览 5提问于2015-04-28得票数 9
回答已采纳
我有4个函数，类似于下面的函数。现在我在ngOnInit()上一次调用一个函数，但我正在寻找一种更简洁的方式来调用所有4个函数(GET HTTP Requests)，以便它们显示旋转...都是并行的..。然后关闭微调器并处理任何错误。这是一个使用angular 7的项目。 getCustomers() {
return this.apiService.getCustomers()
.subscribe(
(data: any) => {
this.partners = data;
this
浏览 28提问于2021-07-20得票数 0
回答已采纳
我有一组看起来相当笨重的代码，其中来自一个可观察对象的数据被馈送到另一个对象中，如下所示：
let source = this.myService.getFoo()
.subscribe(result => {
let source2 = this.myService.getMoo(result)
.subscribe(result2 => { // do stuff });
});
我知道有合并和链接的方法，但我需要来自源的数据馈送到source2中。订阅的嵌套看起来很糟糕，我非常确定有一种更好的方法可以做到这一点。
谢谢!
浏览 0提问于2017-06-17得票数 49
回答已采纳
我正在使用angular 2教程中的英雄应用程序，现在我有了这个组件
import { Component, OnInit } from '@angular/core'
import { Subject } from 'rxjs/Subject';
import { Hero } from "./hero";
import { Router } from "@angular/router";
import { HeroService } from "./hero.service";
import { Behavio
浏览 2提问于2016-08-31得票数 7
回答已采纳
2回答
我正在用下面一个简化的测试用例复制我的Rx问题。下面的测试挂起了。我确信这是一个小的，但基本的，我缺少的东西，但不能把我的手指放在它上。
public class Service
{
private ISubject<double> _subject = new Subject<double>();
public void Reset()
{
_subject.OnNext(0.0);
}
public IObservable<double>
浏览 1提问于2019-12-05得票数 2
回答已采纳
1回答
下面是我的相关代码： private searchClickSubject:Subject<void>; // Submit form
private searchClick$:Observable<any>;
private metrics$:Observable<MetricGroup>;
constructor() {
// Prepare observers
this.searchClickSubject = new Subject<void>();
this.searchClick$ = this.sear
浏览 27提问于2019-05-28得票数 1
我只是想知道，在每个管道中使用takeUntil是最佳实践，还是只有一个管道？
search = (text$: Observable<string>) =>
text$.pipe(
debounceTime(200),
distinctUntilChanged(),
filter((term) => term.length >= 2),
tap(() => (this.searching = true)),
switchMap((term) =>
this.searchService.search(term).pipe(
浏览 1提问于2020-12-05得票数 1
我在我的websocket中使用了connectableObserver，我需要操纵这个对象来将它转换成另一个对象，但是我似乎不能用flatMap()来做这件事。代码如下：
@Override
public ConnectableObservable<Object> getWebSocketObservable() {
return getDataManager().getWebSocketObservable();
}
getWebSocketObservable返回一个ConnectableObservable<Pair<Boolean,String>
浏览 0提问于2017-12-19得票数 0
我希望在RxJava中实现以下目标，因为我在这方面可能没有足够的知识，因此希望得到一些帮助:)
我需要创建一个PublishSubject，它将发出具有以下顺序的事件：
发射1，2，3
如果某个条件不满足(例如，网络连接或其他条件)，则在订阅完成中的缓冲器4。
5，6.如果条件尚不满足，则在4之后缓冲。
当条件满足后，重复发出4。
如果试图发出5,6并满足条件，那么不要缓冲5，6.在4之后，只发出4，然后5，6，7，8.
最后两点是有需要的，因为发射的次序是非常重要的，这使我很难做到这一点。
我希望我能描述一下我想要达到的目标:)
发现：在提出这个问题之后，做了一些
浏览 1提问于2017-07-13得票数 3
1回答
我有这样的动作：
message$ = new Subject();
method() {
return this.message$.pipe(scan((acc, val) => [...acc, val] []))
}
method.subscribe()
我想得到一个间隔为1秒的值。这样我就可以控制从服务器获取值了。
如果有人能展示如何做到这一点，我会很高兴。谢谢。
浏览 0提问于2021-03-10得票数 0
1回答
我有一个返回这样一个可观察到的方法：
open fun get(): Observable<Response> {
return if (condition)
getDataFromApi()
else
getDataFromDb()
}
并签署如下：
get()
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
浏览 0提问于2018-07-11得票数 0
回答已采纳
1回答
我正在使用大理石图来显示两个不同的可观测数据的输出。第一种是使用开关映射，它将管道连接到另一个开关映射中。第二个可观测到的装置在同一个管道中有两个开关图。
这是两个大理石流：
第一种方法是在内部管道内部使用开关映射。
第二种方法是使用单管内部的开关映射。
他们为什么会有不同的结果？
浏览 0提问于2019-09-12得票数 1
回答已采纳
当一个可观察到的返回多个值时，我得到了concatMap和switchMap之间的区别。然而，当所有可观测值只返回一个值时，使用一个值比另一个值有什么好处吗？下面是一个在构造函数中使用完全相同调用的示例，一个使用concatMap，另一个使用switchMap。在这种情况下是优先于另一种的吗？
import { Component } from '@angular/core';
import { concatMap, forkJoin, Observable, of, switchMap } from 'rxjs';
@Component({
select
浏览 6提问于2022-10-14得票数 0
回答已采纳
我有两个观察值，它们都可以解析为一个简单的字符串。我正在寻找一种非废弃的方法来获取两个可观察对象的结果，创建一个对象，并将该对象传递到另一个返回可观察对象的方法中。
假设我有以下内容：
// both are Observable<string>
name$
age$
// I want this
let body = {
name: (string result of name$),
age: (string result of age$)
}
this.httpClient.post<any>("some endpoint", { bo
浏览 0提问于2021-03-13得票数 1
1回答
我有一系列的对象。我必须通过一个API调用来检查每个对象，以确定该对象是否有资格获得某个特定的宣传。在调用最后一个对象时，可观察到的对象应该返回false，或者其中一个对象从API中获得一个真正的状态，什么是最好的方法来继续用对象调用API？
目前，我已经将它作为代码使用，但感觉应该有一个更好的方法来处理RxJS操作符。
checkProductForPromo(items: []) {
const promoChecker$ = new EventEmitter<boolean>();
items.forEach((item, key, arr) => {
浏览 0提问于2019-09-09得票数 1
回答已采纳
我在片段中使用了一个。
我试图以一种方式使用ReplaySubject，我希望主题在完成之前执行一个进程(可能超过片段的生命周期)。
在这个过程完成后，我想释放我理解的-as的资源--在注册观察者时取消订阅(在我的例子中，这就是主题本身)。
@benjchristensen说：
如果它是一个可观测的，那么它应该发出一个onCompleted并完成。
如果它是一个观察者，那么当它调用Observable.subscribe时，它应该从它收到的订阅中取消订阅，它将给观察到的用户一个关闭和清理的机会。
如果它是一个主题，-which既是观察者又是可观察的--行为是什么？如果我在这个主题上调
浏览 0提问于2014-09-02得票数 46
回答已采纳
考虑在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
我创建了以下代码。我认为它会工作，但它不工作。等待无限期地挂在那里(退出事件从不被调用)。
我在没有任何参数的情况下调用"ping“，所以它几乎会立即结束。
using System;
using System.Diagnostics;
using System.Reactive.Linq;
using System.Threading.Tasks;
namespace ConsoleApp3
{
class Program
{
static async Task Main(string[] args)
{
va
浏览 0提问于2018-07-04得票数 2
我有几个异步API，它们使用回调或事件而不是async。我成功地使用TaskCompletionSource对它们进行了as described here包装。 现在，我想使用一个返回IObservable<T>并产生多个对象的接口。我读到了关于.NET的Rx，这似乎是一条可行的道路。然而，我在犹豫是否要包含另一个依赖项和另一个新的范式，因为我已经在这个应用程序中使用了很多对我来说都很新的东西(比如XAML、MVVM、C#的async/await)。 有没有类似于包装单个回调IObservable<T>的方法来包装API？我想这样调用API： foreach (var
浏览 8提问于2019-12-29得票数 1
1回答
我需要订阅两个http调用，并确保之后不会失败，我想对const array中获得的数组应用一个过滤器。
const result =[]
this.fncservice.obs.subscribe((response)=>this.fncservice.maptofncbyetat(response,this.fnc,"en cours"));
this.analysefncservice.obs.subscribe((response)=>this.analysefncservice.maptoplanactionbyetat(
浏览 2提问于2021-01-25得票数 1
1回答
我有一个带有子对象的数组，并且需要递归地在每个对象中设置一个字段(隐藏)。每个值都是在订阅中设置的。我想等到数组中的每一项都递归地更新后才能完成订阅。
隐藏字段将基于从另一个可观察到的角色和权限设置。在这个例子中，我添加了一个延迟来模拟这个过程。
这是我第一次通过它。我肯定有一种更干净的方法来解决这件事。
// Array structure. Note children.
const navigation = [
{
id: "applications",
title: "Applications",
children: [
浏览 3提问于2019-10-15得票数 1
回答已采纳
3回答
我正在尝试获取给定Observable的最新值，并在它被调用后立即发出。以下面的代码为例：
return Observable.just(myObservable.last())
.flatMap(myObservable1 -> {
return myObservable1;
})
.map(o -> o.x) // Here I want to end up with a T object instead of Observable<T> object
这是行不通的，因为这样做，flatMap将发出myObservable1，
浏览 0提问于2016-05-04得票数 28
回答已采纳
2回答
我正试图找到一种更有效的/rxjs方式来完成这一任务。下面的代码可以工作，但必须有更好的方法。
ngOnInit() {
this.activatedRoute.params.subscribe(({ bookId }) => {
this.characters$ && this.characters$.unsubscribe();
this.characters$ = this.fetchCharactersByBook(bookId)
.subscribe(characters => this.characters = char
浏览 0提问于2020-01-14得票数 1
回答已采纳
我正在收集由JSON中的API提供的数据。
使用下面的代码，我可以看到数据是在Subscribe中收集的。
但是在它之外，在.TS文件内部，我不能操作这些数据。
我试图使用promise，但我认为我没有正确使用它，因为我也没有得到积极的结果。
在将数据显示在屏幕上之前，我如何处理这些数据？
getHour() {
this.hourService.getData()
.subscribe(
posts => this.posts = posts,
error => this.errorMessage = <any>error,
() =>
浏览 2提问于2018-04-18得票数 0
1回答
我有一个API调用，我想用可观察到的方式包装它：
private Observable<RealmResults<Account>> getAccounts() {
final Observable<RealmResults<Account>> realmAccounts =
Observable.defer(new Func0<Observable<RealmResults<Account>>>() {
@Override
浏览 2提问于2015-03-26得票数 2
回答已采纳
1回答
我读过RxSwift/ShareReplayScope.Swive文件，但有点难以理解。
public func share(replay: Int = 0, scope: SubjectLifetimeScope = .whileConnected)
-> Observable<E> {
switch scope {
case .forever:
switch replay {
case 0: return self.multicast(PublishSubject()).ref
浏览 7提问于2018-01-08得票数 5
1回答
这是一个非常低级的问题，很抱歉，但是我在任何地方都找不到答案，包括我工作单位的高级人员。 我有以下的Angular代码： function getID(): string{
var varitem = '';
this.someApi.getSomeObject().subscribe((item: Item) => {
varitem = item.id;
});
return varitem;
} 令人惊讶的是，这段代码可以正常工作。当我调用他时，我收
浏览 82提问于2020-08-28得票数 0
回答已采纳
我在组件中定义了一个可观察的(结果$)，并通过异步管道在其模板上显示它。可观测性是通过combineLatest进行的其他两个可观测数据的组合(第一个$，第二个$)。如果其中一个可观测到的，或者两者都发布得太早(在我发现ngAfterContentInit之前)，那么可观察到的结果就不会发出一个值。
组件:不工作
@Component({
selector: 'my-app',
templateUrl: './app.component.html',
styleUrls: [ './app.component.css' ]
})
ex
浏览 0提问于2019-02-07得票数 7
回答已采纳
我试图从angular2中的url中提取查询参数，例如：
this.activatedRoute.queryParams.subscribe((params: Params) => {
this.video0 = params['video0'];
this.video1 = params['video1'];
this.video2 = params['video2'];
this.video3 = params['video3'];
// alert("param
浏览 0提问于2018-05-07得票数 0
有人能解释一下可观察对象和ConnectableObservable之间的区别吗？Rx扩展文档非常稀疏，我不明白ConnectableObservable在什么情况下是有用的。
这个类在Replay/Prune方法中使用。
浏览 2提问于2010-05-14得票数 40
回答已采纳
2回答
我正在测试一个视图模型，它的定义如下：
class PostViewModel(private val postApi: PostApi): ViewModel() {
private val _post: PublishSubject<Post> = PublishSubject.create()
val postAuthor: Observable<String> = _post.map { it.author }
fun refresh(): Completable {
return postApi.getPost()
浏览 0提问于2019-03-29得票数 0
在我的主页上，当我加载它时，我必须在10秒间隔内进行10次刷新。我是用这个代码做的：
refresh$ = createEffect(() => {
return this.actions$.pipe(
ofType(HomepageActions.RefreshSuccessAction),
delayWhen(() => interval(10000)),
switchMap(() => {console.log(this.retriesLeft, Date().toLocaleString())
if (
浏览 0提问于2021-08-30得票数 0
回答已采纳
我是Rxjs的新手，正在尝试确定这是否是一种知道Rxjs对象的所有观察者是否都完成了对.next的响应的方法。
例如，假设我有一个Auth类，如下所示：
import { Subject } from "rxjs";
interface AuthEvent {
eventName : string;
}
class Auth {
static getInstance() : Auth {
//return a singleton of Auth
}
private constructor() {}
au
浏览 0提问于2021-01-17得票数 0
1回答
我有这个函数：
getData(): Observable<ServerResponse> {
const data = {} as ServerResponse;
data.client = this.getClientData().pipe(
map(response =>
response.map(x => {
return x.data.client;
}),
),
);
data.otherData = this.otherData().pipe
浏览 3提问于2019-01-15得票数 8
回答已采纳
2回答
我正在学习Ionic，我有以下功能：
loadPaper(paper){
this.testFunc();
console.log('questions', this.questions);
console.log('paper', paper);
this.navCtrl.push(this.loadPaperPage, {
paper: paper,
questions: this.questions
});
}
testFunc(){
this.papersData.getPa
浏览 0提问于2018-04-12得票数 0
核心问题：
我希望将以下响应放入字符串中，而不是可观察对象中。
getFacebookPhoto(uid: string): Observable<any> {
let results = this.http.get('https://graph.facebook.com/' + uid + '/picture?height=200&redirect=false')
.map(response => response.json().data.url.)
return results
}
其他信息：
我需要填充一个
浏览 4提问于2017-02-17得票数 1
回答已采纳
3回答
假设我有一个事件发射数据源，我想将其转换为反应性流。数据源被资源绑定(例如，定期发送更新状态的套接字)，因此我希望共享该资源的单个订阅。使用replay (对于新订阅者立即获得当前值)和refCount操作符似乎非常适合于此。例如，这是他的MyDataProvider单例的样子：
private final Observable<MyData> myDataObservable = Observable.<MyData>create(emitter -> {
// Open my resource here and emit data into obser
浏览 0提问于2018-05-18得票数 7
回答已采纳
1回答
我用Rxjs是为了得到我的账单计划。我希望将它们设置为select输入。
目前，我正在使用来显示这些计划。
首先，我需要从服务器获取计划：
this.serverService
.list()
.subscribe(
(result: any) => {
for (let plan of result)
this.plans.push({id: plan.id, text: plan.name});
},
(err
浏览 2提问于2017-02-01得票数 1
我有以下的HTML检查块，它检查对象configService.config$.footerLinks是否存在，如果存在，则创建一个UL元素。在这里面，还有对对象内部字符串的进一步检查，这些字符串对应于它各自的LI元素。 <ul id="footer-links" *ngIf="(configService.config$ | async)?.footerLinks">
<li id="footer-link-manual" *ngIf="(configService.config$ | async
浏览 18提问于2019-12-18得票数 1
回答已采纳
1回答
冷热观测-最后一次刷新值
、、、
我有一个场景，我想从服务器获取一些数据，并且用户可以请求刷新这些数据。页面的其余部分需要更新以反映当前加载的数据迭代。
我想象一下，在这里，我有一个可以观察到的热点，可以发布它加载的数据。我不想将数据的所有旧迭代保留为1，我只关心数据的最新迭代，2.如果用户在给定的会话中进行足够的刷新，可能会导致内存不足的异常。
但是，我确实希望保留上一个已发布的值，这样如果我动态地打开一个需要访问相同数据的新组件，它就不会发出不必要的新请求。为此，我需要一个可观察的坐在热可观测的顶部，这将只保留和释放来自热可观测的最后的排放。这里有一个图表说明了这个想法：
dataStream X - - - -
浏览 0提问于2016-03-16得票数 1
回答已采纳
$app是可观察的，
当我使用：
email::::: {{ app$ | async }}
我上了荧幕：
email::::: [object Object]
但如果我用：
email::::: {{ app$.email | async }}
我上了荧幕：
email:::::
连同控制台上的错误：
MyComponent.html:3 ERROR Error: InvalidPipeArgument: 'true' for pipe 'AsyncPipe'
at invalidPipeArgumentError (common.js:4232)
浏览 3提问于2018-05-30得票数 0
回答已采纳
2回答
等待上次订阅结束
、、、
我有以下设置：
let result = service.getResults();
result.data.forEach((row:any) => {
this.myService
.getObject(row.id)
.subscribe((object:any) => {
//...
})
);
}
我想做点什么，在所有的getObject(row.id)订阅完成之后。我知道有add()函数，但它对每个订阅都会
浏览 1提问于2019-03-13得票数 0
1回答
我精心设计了这个解决方案，作为combineLatest操作符的替代，换句话说，我想将我的原始流切换到另一个流，但仍然可以访问原始流中的值
switchMap(sourceValue => combineLatest([of(sourceValue), anotherObservable]))
你们能帮我找到比这个更简单/更优雅的解决方案吗？
浏览 32提问于2020-02-11得票数 0
1回答
内核代码可以显式地让进程在等待某个任务发生时进入休眠状态。现在，如果任务处于TASK_INTERRUPTIBLE状态，则可以通过显式唤醒呼叫或接收信号来唤醒任务。
，假设另一个进程向处于等待队列和TASK_INTERRUPTIBLE状态的进程发出了一个信号，它将将该进程放入TASK_RUNNING，并在进程下一次调度时处理该信号。这是正确的吗？--其他进程的显式唤醒调用--也可以用来唤醒已睡的进程。我在想，另一个过程如何知道睡眠过程何时才会醒来呢？假设要完成磁盘i/o，因此进程处于休眠状态。另一个进程如何知道i/o已经完成？或者它是由内核线程完成的？我少了什么？
浏览 8提问于2020-07-31得票数 0
我正在写一个小应用程序，我需要维护一些令牌系统，以便验证当前登录的用户。因此，我借助了setInterval()，在其中我编写了一个方法，可以从某个服务器获取更新的令牌。为了获取更新的令牌，我使用了Angular内置的HttpClient observable。但我的问题是“在setInterval方法中订阅一个可观察的HTTP客户端可以吗？”
setInterval(() => {
if (this.isLoggedIn) {
this.someService.getUpdatedToken().subscribe();
}
}, 300
浏览 13提问于2019-07-19得票数 1
回答已采纳
1回答
下面的代码按预期工作，但当我取消注释行'o.OnCompleted();‘时，我对它的行为方式感到困惑。
该代码将所有订阅者加入到单个长操作的结果中，并将结果缓存2秒以供更多订阅者使用。此时间之后的任何订阅都会再次启动该过程。
订阅将来自其他线程(用线程池模拟)。
var obs = Observable.Create((IObserver<Guid> o) =>
{
Console.WriteLine("Start");
Thread.Sleep(1000); // pr
浏览 0提问于2018-09-26得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
