在执行更多代码之前，如何等待可观察对象的更新？
在执行更多代码之前，可以使用异步编程的方式等待可观察对象的更新。异步编程是一种编程模式，可以在等待某个操作完成时，继续执行其他代码，而不会阻塞程序的执行。
在前端开发中，可以使用Promise对象或async/await语法来实现异步编程。通过将可观察对象包装在Promise中，可以使用then方法或await关键字来等待其更新。
在后端开发中，可以使用回调函数、事件监听器或异步函数来实现异步编程。通过注册回调函数或事件监听器，可以在可观察对象更新时执行相应的操作。
以下是一些常见的等待可观察对象更新的方法：
- 使用Promise对象：
- 使用Promise对象：
- 使用async/await语法：
- 使用async/await语法：
- 使用回调函数：
- 使用回调函数：
- 使用事件监听器：
- 使用事件监听器：
这些方法可以根据具体的开发需求选择使用。在等待可观察对象更新时，可以执行其他代码，提高程序的并发性和响应性。
相关·内容
1回答
这可能是个蹩脚的问题，但我对角度并不熟悉，对那些可观测到的东西我也不太了解。
我得到了一些代码，其中第二个选择的选项取决于第一个选择值。有一个refreshPeople()方法，它在第一个选择变更时调用，该方法尝试将加载设置为true，然后对数据进行异步调用，然后将加载设置为false。
但是refreshPeople()中的最后一个命令不是等待异步调用结束。:(
在angular2+中制作这类东西的正确方法是什么？
因此，模板是：
Gender: {{gender}}
<ng-select
[items]="genders"
(change)="r
浏览 3提问于2020-08-21得票数 0
回答已采纳
我有以下代码： repo.getObservable()
.timeout(1, TimeUnit.MINUTES)
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.doOnSubscribe {
_isInProgress.value = true
}
.doFinally {
_isI
浏览 41提问于2019-12-19得票数 2
回答已采纳
我有一个观察点，在某些时候必须将内容写入缓存-我们希望在完成对观察点的整个操作之前等待写入完成(出于报告目的)。
出于测试目的，可完成的缓存写入如下所示：
Completable.create(
emitter ->
new Thread(
() -> {
try {
Thread.sleep(2000);
浏览 2提问于2020-02-06得票数 2
我试图在.subscribe中赋值一个变量，但无法使它返回正确的值。下面发布了代码，让我知道如何才能正确地返回变量成功。
createIndexes(environmentName, csvReindexCommands){
let success = false;
this.swaggerApi.createOrUpdateElasticSearchIndexSchema(environmentName, csvReindexCommands).subscribe(
x => {success = x.success},
err =&g
浏览 1提问于2018-06-15得票数 0
回答已采纳
2回答
在最近选择使用LiveData之后，我在初始化变量时遇到了一个问题。我有两个活动(我不使用导航，但这不是重点)：
，一个是带有API获取项的列表，另一个是上一个列表中所选项的详细活动。
问题是，我需要能够在创建模式下查询细节活动，即在我的ViewModel中，不能通过Retrofit检索对象，而必须通过一个新的实例化来创建对象。
目前是这样做的：
详细活动:
override fun onCreate(savedInstanceState: Bundle?) {
super.onCreate(savedInstanceState)
setContentView(
浏览 0提问于2020-05-28得票数 2
回答已采纳
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
回答已采纳
我正在编写一个托管在IIS上的ASP.NET ApiController。在一个操作中，我需要调用一个名为A的Web服务，该Web服务由一个名为Tencent的公司提供。该服务要求我使用密钥进行身份验证。密钥是通过调用来自腾讯的另一个名为B的web接口生成的，密钥有效期为3小时。服务B对每天的呼叫量有限制。因此，当我想使用A时，我不能调用B。我只能调用B一次，并将密钥存储在数据库中以备将来使用。
这意味着每次我想使用服务A时，我需要检查数据库中密钥的有效性，如果它过期了，调用B并获得一个新的密钥。
现在，当我需要通过调用B来续费密钥时，如果在返回新密钥之前，再次调用ApiController操
浏览 2提问于2015-09-15得票数 2
3回答
如何等待派单完成后再从商店中进行选择。在谷歌上没有任何运气吗？在这种情况下，如何等待调度完成后再从存储中进行选择？
我的代码，感谢支持的帮助。
**team-list.component.ts**
teamsState: Observable<{teams: Team[]}>;
constructor(private store: Store<fromApp.AppState>) { }
ngOnInit() {
this.store.dispatch(new TeamActions.GetTeams({
search: this.s
浏览 5提问于2019-03-26得票数 6
回答已采纳
1回答
我是第一次接触knockout js。我需要有一个日期验证器，用户将在文本框中键入。为此，编写如下代码
ko.validation.rules['date'] = {
validator: function (value, validate) {
//Custom logic
},
message: 'Please type proper date'
};
self.userDate = ko.observable(new Date()).extend({date: true });
这在tab out上运行良好。但是我需要
浏览 0提问于2012-09-25得票数 2
回答已采纳
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
回答已采纳
我正在使用CanLoad保护一个带有Guard的惰性模块。
我正在恢复我的ngrx存储的状态，并检查用户是否已通过身份验证。
下面是我的auth-Guard.service.ts中的代码：
canLoad() {
return this.store.pipe(
select('auth'),
take(1),
map(
(authState: fromAuth.State) => {
if (authState.authenticated) {
浏览 3提问于2018-12-04得票数 2
1回答
我在amazon上有一个sqs队列，有几个消费者在轮询它。
最近我发现numberofEmptyReceives是在1000万，这意味着我是收费的这些请求。
下面是我是如何使用消息的
while True:
for message in queue.receive_messages(AttributeNames=['All'], MaxNumberOfMessages=10):
我知道有WaitTimeSeconds选项，但文档似乎表明它不会进行长时间轮询
呼叫在返回前等待消息到达队列的持续时间(秒)。如果有消息可用，调用将比WaitTimeSeconds更早返回。如果
浏览 34提问于2018-05-28得票数 4
回答已采纳
我不认为这个问题是的重复。
假设我的类实现了IAsynsDisposable，因为它有一个长期运行的后台任务，而DisposeAsync终止了该任务。熟悉的模式可能是Completion属性，例如 (尽管ChannelReader没有实现IAsynsDisposable)。
在Completion之外传播DisposeAsync任务的异常是否被认为是一个很好的实践
下面是一个可以复制/粘贴到dotnet new console项目中的完整示例。注：await this.Completion在DisposeAsync中
try
{
await using var service = ne
浏览 11提问于2022-01-15得票数 3
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
我陷入了一个非常令人惊讶的问题，here.The代码如下。
class A
{
public:
A(){
m_event = CreateEvent(NULL, false, false, NULL); // create an event with initial value as non-signalled
m_thread = _beginthread(StaticThreadEntry, 0, this); // create a thread
}
static void StaticTh
浏览 0提问于2009-06-08得票数 3
回答已采纳
当我尝试在多线程中打开单独的txt文件时遇到了一个问题，即每个线程打开一个txt文件并读取内容，代码如下。
#include<stdlib.h>
#include<windows.h>
#include<process.h>
DWORD WINAPI lookup1(LPVOID lpParamter){
char x[10];
int y;
FILE* fin1 = fopen("D:\\1.txt", "r");
fscanf(fin1, "%s %d", x, &y);
printf(
浏览 0提问于2012-04-24得票数 1
回答已采纳
1回答
我试图在加载文档后使用Prototype操作一些锚点，以更改它们的href属性。基于锚点的类，它的href必须被重写以供跟踪软件使用。
我把一些东西拼凑在一起，但不太明白为什么它不能工作。它总是返回undefined，不管我搜索什么。
<script type="text/javascript">
var elements = $$(".replace");
for (el in elements) {
el.href = "other_href.html";
}
</script>
<a href=
浏览 0提问于2010-09-14得票数 0
回答已采纳
我正在学习如何使用RxJava (io.reactivex.rxjava2:rxandroid:2.0.1) + retrofit2 + kotlin。
一般情况下，如何观察到这一点，甚至学会了如何在Observable.zip的帮助下结合基于所有人的性能的2-3个并行查询的结果，但是如何执行类似的3次以上的并行查询，我无法理解。
可观察类的源代码有一个方法
static <T1, T2, T3, T4, R> Observable <R> zip (),
但它的工作方式不像
static <T1, T2, T3, R> Observable <R&g
浏览 0提问于2018-08-18得票数 2
回答已采纳
2回答
我想了解观察者模式与生产者/消费者最常见的问题之间的区别，因为两者都需要同步，以便可以使用更改，以及如何实现两者(如果它们不同)。
浏览 2提问于2016-11-06得票数 6
回答已采纳
1回答
假设这是一个执行DB查询并返回结果的方法，如果使用默认值()替换null，则返回结果。
public ResultObj Get()
{
var result = dbContext.GetSomeResult();
return result ?? ResultObj.NullValue;
}
假设这个DB查询是一个长期运行的进程，所以我将使用异步/等待在一个单独的线程中执行该进程。假设dbContext.GetSomeResultAsync()方法是可用的。
如何在异步方法中转换此方法，以便编写类似的内容？
var resultTask = GetAsync();
var
浏览 0提问于2018-03-22得票数 0
在以下代码中，
class MainX {
static void run(int i) {
try {
System.out.println(i + " called");
Thread.sleep(1000);
String s = "";
for (int j = 0; j < 20000; j++) {
s = s + j;
}
System.out
浏览 1提问于2021-07-10得票数 2
回答已采纳
我希望下面的程序不会挂起。
如果(2)和(3)按(1)的相反顺序观察，它可能因通知丢失而挂起：
#include <atomic>
#include <chrono>
#include <thread>
int main()
{
std::atomic<bool> go{ false };
std::thread thd([&go] {
go.wait(false, std::memory_order_relaxed); // (1)
});
std::this_thread::sl
浏览 3提问于2020-06-10得票数 4
回答已采纳
1回答
用户交互中的动态角度形式
、、、
我有一个下拉列表，用户用它在不同的角度形式之间切换。
HTML
<form [formGroup]="evalForm">
<mat-form-field appearance="fill">
<mat-label>Select Analysis Group</mat-label>
<mat-select (selectionChange)="groupSelected($event)">
<m
浏览 2提问于2022-05-13得票数 0
假设我有以下代码
Injectable()
export class MyStore {
store = new BehaviorSubject(true);
updateStore(value) {
this.store.next(value);
return this.store.asObservable();
}
selectValue() {
return this.store.asObservable();
}
}
从updateStore返回的可观察到的值是否可能没有在next()之前更新的值
浏览 0提问于2019-06-07得票数 1
回答已采纳
我有一个服务，从我们的后端返回过滤器。该服务有一个返回promise的方法getForPage和一个返回observable的getForPage$。
在服务上还有onEvent方法，它是一个可观察的对象，在过滤器上发生变化时发出。
现在，我希望在onEvent发出事件时更新getForPage$可观察性。这是通过以下代码完成的。
getForPage(page: string): Promise<DashboardPageFilter[]> {
return this.service.call(
'dashboard.page.filter.get
浏览 4提问于2017-11-14得票数 0
1回答
下面是我的应用程序中一个组件的代码片段，其中我订阅了多个可观察对象，并在分别获得值后通过api调用加载数据。
ngOnInit() {
this.combinedObservable$ = combineLatest(
this.service1.getStudentId(),
this.service2.getTeacherId(),
this.service3.getResultId(),
this.service4.getReportId(),
this.service5.getYearId(),
).sub
浏览 11提问于2020-03-02得票数 1
回答已采纳
我只是一个android程序的初学者。最近，我正在阅读有关当对数据库进行更改时，空间数据库如何返回实时数据以进行自动更新。我使用viewmodel类实例来保存我的Livedata，如下所示
public class LogVM extends AndroidViewModel{
MasterDatabase roomDatabase;
LiveData<List<Log>> logData;
LogVM(Application application){
super(application);
浏览 0提问于2018-09-14得票数 2
回答已采纳
1回答
我一直在使用retryWhen()方法，我注意到如果在retryWhen()中使用filter()，如果filter()失败，就不会执行回调，甚至不会执行你能给我解释一下为什么会发生这种事吗？提前谢谢。
工作案例：
Observable.error(new RuntimeException())
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.retryWhen(errors -> errors
浏览 3提问于2017-09-08得票数 2
回答已采纳
3回答
在Java中，当一个特定类的方法被调用时，我们会收到警报吗？我是否可以在某个地方注册，以便在调用该特定方法时得到通知。例如，我们希望在调用方法时需要执行某些活动。由于该方法已经可用，因此我们不想触及现有的逻辑，而是只需要向该方法添加一个钩子，并在调用该方法时执行一些其他任务。
如果问题含糊，请告诉我。
浏览 0提问于2013-05-15得票数 1
回答已采纳
6回答
如何使用NestJ在HttpService上使用异步/等待？以下代码不起作用：
async create(data) {
return await this.httpService.post(url, data);
}
浏览 0提问于2018-08-18得票数 23
回答已采纳
2回答
我在asp.net页面中有下面的代码：
protected void LoadFile(object sender, EventArgs e)
{
try
{
Timer myTimer = new Timer();
myTimer.Elapsed += new ElapsedEventHandler( RemoveFile );
myTimer.Interval = 60000;
myTimer.Start();
浏览 2提问于2016-03-07得票数 0
我想要发布密钥列表，但仅当密钥被修改时。
使用下面的代码，它会在一个无限的循环中发布值，即使没有任何更改
RedisReactiveCommands<String, String> commands = connection.reactive();
return commands
.keys(String.format(AWAITING_USER_KEY_FORMAT, "*")) // returns Flux<String>
.collectList() // returns Mono&
浏览 0提问于2020-05-28得票数 0
我有一组看起来相当笨重的代码，其中来自一个可观察对象的数据被馈送到另一个对象中，如下所示：
let source = this.myService.getFoo()
.subscribe(result => {
let source2 = this.myService.getMoo(result)
.subscribe(result2 => { // do stuff });
});
我知道有合并和链接的方法，但我需要来自源的数据馈送到source2中。订阅的嵌套看起来很糟糕，我非常确定有一种更好的方法可以做到这一点。
谢谢!
浏览 0提问于2017-06-17得票数 49
回答已采纳
1回答
使用mobx反应可排序的JS
、、、、
我正在构建一个功能组件，它应该使用计算数组(层数组)呈现一个可排序组件(ReactSortable)，该组件来自使用react-sortablejs的mobx store。组件在应用程序加载时呈现，但当通过拖放元素重新排列数组时，我得到以下错误： mobx.module.js:89未捕获错误: mobx由于启用了严格模式，因此不允许在操作之外更改观察到的值。如果要进行此更改，请将代码包装在action中。已尝试修改: LayerStore@23.layersRegistry.9f332395-6bfe-4c3f-a496-8804e1dec490.chosen？实际上，layers数组是从商
浏览 26提问于2020-08-18得票数 2
3回答
这是语言律师的问题。
首先，下面代码中的a.wait()总是返回吗？
std::atomic_int a{ 0 };
void f()
{
a.store(1, std::memory_order_relaxed);
a.notify_one();
}
int main()
{
std::thread thread(f);
a.wait(0, std::memory_order_relaxed);//always return?
thread.join();
}
我相信标准的意图是a.wait()总是能回来。(否则atomic::wait/noti
浏览 4提问于2021-12-04得票数 13
我使用watchman来设置Git的core.fsmonitor。我正在运行一个不同的工具，该工具使用fsnotify来检测文件更改并运行构建。watchman正在做的事情是让fsnotify认为文件正在发生变化，而实际上文件并没有发生变化( fsnotify工具不断运行构建)。我如何才能发现到底发生了什么，这样我才能调整工具以忽略这些更改？
浏览 2提问于2019-09-19得票数 0
1回答
如何多次运行函数？
我想重新运行循环，以便程序再执行几次函数。我明白这是不正确的做法。但肯定有解决办法吗？
我的代码：
from asyncio import get_event_loop, gather, sleep
async def main(k):
print(k)
await sleep(1)
if __name__ == '__main__':
count_run = 3
count_group = 3
list_objects = list()
for i in range(
浏览 3提问于2022-02-01得票数 -1
回答已采纳
由于运行时向NSNull对象发送isEqualToString：，我的程序崩溃了。我找不到这个NSNull的来源；我从来没有显式创建过一个。我也根本找不到谁或者什么在叫isEqualToString。
我的理解是，NSNull是一个对象，它只用于绕过不能将nil添加到集合这一事实。我的程序确实创建了几个自动释放数组；所以我猜测其中一个数组以某种方式以NSNull结尾。奇怪的是，这些数组都不应该包含任何NSString对象，这意味着如果isEqualToString:被发送到我的数组中的一个对象，它将导致崩溃。
我使用CoreData fetch请求和谓词创建这些数组：
NSFetchRequ
浏览 0提问于2010-10-14得票数 1
回答已采纳
在angular 4中，我们有一个泛型方法，它基本上将URI扁平化：
return Observable.forkJoin(fullUri, requestOptions)
.flatMap((results: [string, RequestOptions]) => this.http.get(results[0], results[1]))
.map(this.extractData)
.catch(this.errorMapperService.handleError);
现在在Angular 9中，Reque
浏览 28提问于2020-03-10得票数 0
为什么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
回答已采纳
我有以下代码
function exibirDialog(div) {
$("#divDialogo").ready(function() {
$("#divDialogo").dialog({
open: function() { },
close: function() { $(this).dialog("destroy"); },
buttons: {
"Print": function() {
var popUp
浏览 3提问于2011-05-20得票数 1
回答已采纳
我需要每隔x秒执行一次任务，我可以使用下面的代码来完成这个目标： var task: ITask;
begin
task := TTask.Create(
procedure()
begin
//infinite loop
while 1 = 1 do
begin
//time interval
sleep(15000);
//do something every x seconds
end;
end);
task.Start; 但是，当使用sle
浏览 11提问于2020-11-02得票数 2
我有一些等级的课程。我希望从这个层次结构实现对任何实例的延迟更新。换句话说，在使用对象的任何公共方法的唯一情况下，我们应该更新对象。什么是允许实现这种行为的最佳设计模式？
以下是这种情况的一个简单例子：
我有一个复杂的模型，它不能更新视图(在性能方面)。因此，视图应该在访问它的任何公共方法时自动更新自己。
浏览 8提问于2016-10-17得票数 0
回答已采纳
3回答
我有一个方法(让我们称之为method1)，它向服务器(POST)发出异步请求，以创建具有给定ID的CommunicationLink对象。在发送请求之前，该方法检查服务器上是否已经存在CommunicationLink。
我有第二个方法(让我们称之为method2)，它获取与给定的CommunicationLink ID相关联的“主题”对象的列表。与method1一样，method2检查服务器上是否已经存在CommunicationLink，如果没有，则创建CommunicationLink(同样，通过向服务器发送异步请求)。
我遇到的问题是，当我启动我的应用程序时，method1和meth
浏览 2提问于2013-02-27得票数 4
回答已采纳
我尝试使用FileDialog对象在标签(ecran)上显示我刚刚选取的文件和路径。
但它不起作用。我的代码返回一个空值，我不知道为什么。
你能帮帮我吗？
import java.awt.*;
import java.awt.event.*;
import java.io.*;
class FerPrinc extends Frame implements ActionListener{
Label ecran;
public String path = null;
public FerPrinc(String titlu){
super(titlu)
浏览 0提问于2019-02-13得票数 0
2回答
我的商店和产品实体有一对多的关系，请看我的模型
public class Product
{
public int ID { get; set; }
public string Name { get; set; }
public string Tag { get; set; }
public string Brand { get; set; }
public string Place { get; set; }
public int ShopID { get; set; }
public Shop Shop { get; set; }
}
publ
浏览 1提问于2018-06-16得票数 1
回答已采纳
我的应用程序在从ViewController导航到以前的ViewController时崩溃了。我已向观察员登记为：
[tblViewActvityCalender addObserver:self
forKeyPath:@"contentSize"
options:0
context:NULL];
在delloc()方法中，我移除观察者如下：
[tblViewActvityCalender removeO
浏览 6提问于2015-02-27得票数 1
1回答
我正在尝试将OpenCL与OpenGL互操作结合使用。在GPU上计算路径跟踪算法，然后绘制GL纹理到四象素。在Intel CPU上工作，但当我尝试在GTX 970上运行时，在解锁GL纹理时会出现分段错误。不知道这是原因还是运行内核。我会让代码自己说出来。我正在使用OpenCL C++包装器。
GL纹理创建
glGenTextures(1, &texture);
glBindTexture(GL_TEXTURE_2D, texture);
glTexParameteri(GL_TEXTURE_2D, GL_TEXTURE_WRAP_S, GL_REPEAT);
glTexParamete
浏览 1提问于2016-04-24得票数 2
回答已采纳
我试图使用Java中的ucanaccess更新多行I(一个Microsoft数据库)。问题是，在更新第一行之后，其他任何事情都不会发生，就好像游标被关闭了一样。这是我的代码：
Connection con = DriverManager.getConnection("jdbc:ucanaccess://"+ filepath);
String qry = "SELECT * FROM Elenco_Aziende";
Statement stmtautisti = on.createStatement(ResultSet.TYPE_SC
浏览 1提问于2015-10-02得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
