观察者函数中的异步等待
是指在观察者模式中，观察者函数在接收到被观察者的通知后，可以选择进行异步等待操作。异步等待可以通过使用异步编程的方式来实现，例如使用异步函数、Promise、async/await等。
异步等待的优势在于可以提高系统的响应速度和并发处理能力。通过将耗时的操作放在异步任务中进行，可以避免阻塞主线程，提高系统的并发处理能力。同时，异步等待还可以提高用户体验，避免界面的卡顿和无响应。
观察者函数中的异步等待可以应用于各种场景，例如：
- 异步数据更新：当被观察者的数据发生变化时，观察者函数可以通过异步等待来更新相关的数据或界面。
- 异步通知处理：当被观察者需要通知观察者进行某些操作时，观察者函数可以通过异步等待来处理通知，并执行相应的操作。
- 异步事件处理：当被观察者触发某个事件时，观察者函数可以通过异步等待来处理事件，并执行相应的逻辑。
腾讯云提供了一系列与观察者模式相关的产品和服务，例如：
- 云函数（SCF）：腾讯云云函数是一种事件驱动的无服务器计算服务，可以用于观察者函数的实现。您可以使用云函数来处理观察者函数中的异步等待操作。
- 弹性消息队列（CMQ）：腾讯云弹性消息队列是一种高可靠、高可用的消息队列服务，可以用于观察者模式中的消息通信。您可以使用CMQ来实现观察者函数之间的消息传递。
- 弹性缓存Redis（TencentDB for Redis）：腾讯云弹性缓存Redis是一种高性能的分布式缓存数据库，可以用于观察者函数中的数据缓存和更新。
以上是腾讯云相关产品的简介，您可以通过以下链接了解更多详细信息：
- 云函数（SCF）：https://cloud.tencent.com/product/scf
- 弹性消息队列（CMQ）：https://cloud.tencent.com/product/cmq
- 弹性缓存Redis（TencentDB for Redis）：https://cloud.tencent.com/product/redis
请注意，以上答案仅供参考，具体的实现方式和产品选择应根据实际需求和情况进行评估和决策。
相关·内容
等待verifyUser，等待verifyUserSignInSuccess，等待userSnapshot，等待user
在这两个函数中，ReactNative应用程序的正确性、内存和时间将更加有效：
export function verifyUser() {
return async dispatch => {
dispatch(verifyUserSignInRequest());
try {
const user = await firebase.auth().onAuthStateChanged();
if (user) {
浏览 4提问于2017-12-11得票数 7
回答已采纳
5回答
观察者模式的替代方案
、、、、
有没有人知道观察者号的替代品。侦听器模式？我感兴趣的是可以在异步环境中很好地工作的东西。
我面临的问题是，我有一个应用程序经常使用这种模式，这本身并不是一件坏事，但随着侦听器数量的增加，它成为了一个瓶颈。与线程原语(互斥、临界区-当然在我的特定环境中)相结合，对性能的影响是非常糟糕的。
浏览 1提问于2011-03-02得票数 8
回答已采纳
我正在使用CefSharp winform，我试着登录到网站。
但是这个站点使用了ajax，这意味着站点页面不会重新加载来获取源代码。
那么，我如何知道AJAX是否完成了呢？
我需要类似的东西或者其他的解决方案
var cvbar = chrom.EvaluateScriptAsync("Is AJAX completed ??")
var response = cvbar.Result;
if (response.Success == true && response.Result.ToStrin
浏览 0提问于2018-11-03得票数 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
我需要当前位置作为源，搜索位置作为目的地，但我获得了当前位置，但在这里我无法将坐标(纬度和经度)从搜索位置带到目的地。这里我的目的地显示为空，为什么？以下是代码，请帮助我。
import UIKit
import MapKit
import CoreLocation
class MapSampViewController: UIViewController, CLLocationManagerDelegate, MKMapViewDelegate, UISearchBarDelegate {
//Privacy - Location When In Use Usage Descri
浏览 7提问于2017-12-03得票数 1
在我的应用程序中，我想从特定的album.so获取图像和视频，我使用ALAssetsLibraryGroupsEnumerationResultsBlock函数从特定的Album.here获取图像和视频，我将资产值存储在nsmutablearray中，我在viewdidLoad上获取数组值，但在viewdidload中，当ALAssetsLibraryGroupsEnumerationResultsBlock被触发时，数组值为null.So。下面是我的代码帮助我..
- (void)viewDidLoad {
[super viewDidLoad];
if (self.assetLib
浏览 8提问于2015-02-13得票数 0
我有以下变量：Image avatar;和URL url;
在构造函数中，我设置了：
this.url = new URL("http://www.robottiger.com/user.PNG");
和
this.avatar = ImageIO.read(url);
然后在..。
public void paint (Graphics g)
..is它是正确的使用以下内容？
g.drawImage(avatar, 20, 410, null);
或者应该将null改为this？
浏览 0提问于2012-05-12得票数 1
3回答
我需要设置某种循环，该循环一直运行到数组中有数据为止。一点背景信息:应用程序与服务器通信，获取一些信息，并将这些信息填充到一个数组中。只有当该信息被填充到数组中时，视图才能更改为下一个视图(因为视图是用数组中的信息填充的)。
我该如何创建这个循环？我目前使用的是NSTimer，但它不适合我的需求。
提前感谢！
浏览 0提问于2011-08-17得票数 0
回答已采纳
我使用Firebase 3.x和auth状态更改事件来分配服务中的当前用户-
.service('FireService'，函数($q，$http，$state) ){
var accessToken;
var user;
firebase.auth().onAuthStateChanged(function (usr) {
if (usr) {
// User signed in!
user = usr;
} else {
user = null;
$state.go('login');
}
});
return
浏览 2提问于2016-06-27得票数 0
回答已采纳
我正在.vue文件的.vue部分中创建一个动态数组。这个数组有一组我想调用的urls (在一个重复的组件中)，以获取文章。这些文章各不相同，因此在页面上呈现计算数组时，当完成时，我想在创建组件时调用urls。
computed: {
calcTheArray() {
// make the actual array
// basically, I grab a (computed! so can't use that in async either)
// array with months that have passed b
浏览 3提问于2019-12-03得票数 0
我正在尝试通知从另一个可观察对象订阅Subject _sub的侦听器，然后在Do处理程序中记录一些消息。我正在调用OnNext，如果_sub不是异步的，一切都会正常工作。这里的问题是，没有我会在第一个观察值中等待的OnNextAsync函数。做这件事最好的方法是什么？
class Program
{
private static Subject<int> _sub = new Subject<int>();
static void Main(string[] args)
{
浏览 2提问于2018-10-10得票数 0
因此，我已经准备好了我可爱的测试系统，但是在我的CI服务器中运行它时遇到了一个问题:出于某种原因，Ember测试正在抱怨运行循环，但只在PhantomJS中运行。
这是业力输出：
Waiting for previous execution...
PhantomJS 1.9.7 (Linux) DEBUG: 'DEBUG: -------------------------------'
PhantomJS 1.9.7 (Linux) DEBUG: 'DEBUG: Ember : 1.4.0'
PhantomJS 1.9.7 (Linux) DEBUG
浏览 0提问于2014-02-27得票数 1
回答已采纳
2回答
我试图从防火墙中获取数据，并将其设置为一个全局变量，但我的定义不明确。这是我所拥有的；
let myScore;
auth.onAuthStateChanged((user) => {
let docRef = db.collection("players");
let user_email = user.email;
docRef.onSnapshot((players) => {
players.forEach((doc) => {
data = d
浏览 0提问于2021-07-14得票数 0
回答已采纳
我在C#中看到和阅读了很多关于异步等待的页面，但是仍然不清楚。使用像Controller -业务层-数据层这样的3层体系结构，如果数据层执行异步方法(因为它的调用数据库或RestAPI)，那么您的业务层和控制器也需要异步和等待。这是设计意图吗？
我知道异步等待对于服务器CPU不处理的调用是有用的，比如数据库调用或http调用，然后您可以将当前线程分配给另一个任务，并在异步操作完成后返回到这个任务。但是，使用我解释过的体系结构，如果您在最低层中有异步方法，那么您就可以在任何地方冒出异步等待模式，而且在这些情况下它似乎没有用。
我一定是遗漏了什么或什么解释。因此，您知道，我在堆栈溢出和一些Micr
浏览 2提问于2022-02-09得票数 2
回答已采纳
我为另一个类创建了一个扩展。我调用了扩展方法，它引发异常。不幸的是，我的观察者无法抓住这一例外。
有人知道为什么吗？
public static class MyExtensions {
public static async void myextfunc(this SomeClass some, dynamic data) {
throw new Exception("Atrápame si puedes.");
} // fin myextfunc()
} // fin class
SomeClass some = new SomeCl
浏览 2提问于2019-11-01得票数 0
回答已采纳
5回答
我有一个独立于MainActivity的AsyncTask类。
protected void onPostExecute(ArrayList<String> result) {
System.out.println("flag1");
MainActivity.myLst=new ArrayList<String>();
MainActivity.myLst=result;
}
然后在我的MainActivity中有以下代码。
public void onCreate(Bundle savedI
浏览 1提问于2013-08-01得票数 0
2回答
考虑到以下代码：
public delegate Task AsyncEventHandler<in TEventArgs>(object sender, TEventArgs eventArgs);
public static Task InvokeAsync(this AsyncEventHandler eventHandler, object sender, EventArgs eventArgs)
{
if (eventHandler == null) return Task.CompletedTask;
var delegates = eventHan
浏览 15提问于2022-05-28得票数 1
回答已采纳
对数据库的所有查询都是用CouroutineScope编写的。但是这行代码就在ViewModel类的内部。而且它不会阻塞UI线程。我不明白它是怎么执行的 private val nights = database.getAllNights() 您可以在此link中查看整个存储库
浏览 6提问于2019-08-25得票数 1
回答已采纳
我是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回答
我有一个表单，它将计算两个值，然后显示结果卡。在填充和提交所有值之前，将不会显示结果卡(使用v-if)。
我正在为UI框架使用Vuetify。
以下是我尝试过的：
<template>
<v-container>
<v-row class="mt-2" justify="center">
<v-col cols="12" sm="8" md="6">
<v-form ref="form" @submit.p
浏览 1提问于2021-08-06得票数 0
回答已采纳
我正在尝试用我在taxParentId函数中的API调用检索的新id更新getTaxParentId，但是我无法更改它。我可以在方法中console.log值，但是它不会更新它。这似乎是一个范围问题，但是我已经设置了$this = this来处理这个问题，但是它不起作用。
getPostType方法工作正常，并正确地更新数据值。
var newVue = new Vue({
el: '#app',
data() {
return{
posts: [],
taxonomy: '',
postType: '
浏览 0提问于2018-08-29得票数 0
回答已采纳
我试图通过一个观察者从火场中获取数据。但是，当我试图将值附加到我之前创建的数组中时，它会失败。这是密码，有人能帮帮我吗？
class ProductTableViewController: UITableViewController{
var productName:[String] = []
override func viewDidLoad() {
super.viewDidLoad()
fetchProduct()
print(self.productName.count)
}
func fetchPro
浏览 7提问于2017-04-04得票数 1
回答已采纳
1回答
我试图为我的应用程序设置一个viewCount，当我设置断点并遍历代码时，它总是跳过queryOrdered，我不知道为什么
func increaseViewCount(username: String, time: NSNumber){
guard let uid = Auth.auth().currentUser?.uid else{
return
}
let refOfUserName = Database.database().reference().child("Users").child(uid)
refOfUser
浏览 2提问于2017-06-27得票数 0
回答已采纳
3回答
在给定同步观察者的情况下，是否有办法这样做：
observable.SubscribeAsync(observer);
observer上的所有方法都是异步调用的，还是在创建观察者时必须处理的问题？
浏览 4提问于2013-09-15得票数 2
回答已采纳
2回答
目前，我正在尝试理解可观察性。我用的是禅宗的可观测性。下面的代码并不是我所期望的。
import Observable from "zen-observable";
const foobar = [];
Observable.from(foobar).subscribe(x => console.log(x));
foobar.push("test");
foobar.push("foobar");
setTimeout(() => {
foobar.push("123");
}, 500);
"1
浏览 1提问于2019-08-16得票数 0
3回答
订阅角2
、
我有一个文件，我用REST服务编码我的整个连接，而且它可以工作。
在另一个文件中，我正在执行以下行(everything works)
this.baseService.getCars(ID)
.subscribe(cars=> this.cars= cars);
为了访问响应的值，我使用了HTML。例如：*ngIf="cars"
现在，我想通过Javascript访问执行以下操作的变量：
this.baseService.getCars(ID)
.subscribe(cars=> this.cars= cars);
console.log
浏览 7提问于2018-01-08得票数 1
回答已采纳
1回答
根据，当一个组件被卸载时，watchEffect将停止。
当在组件的安装()函数或生命周期挂钩期间调用watchEffect时，监视程序将链接到组件的生命周期，并在组件卸载时自动停止。
watch在自动停止方面是否有相同的行为？谢谢!
浏览 2提问于2021-04-12得票数 6
回答已采纳
我不能理解当我以{"id":40,"gid":1000,"group":"test","builtin":false,"sudo":false,"users":[47,44]}形式获取查询group.query的值时，为什么会出现Cannot read property错误
checkbox_confirm_show(id: any){
let user: any
user = _.find(this.usr_lst[0], {id});
浏览 4提问于2018-04-27得票数 0
async法在聚合物中的用途是什么？我什么时候该用它？
现在我正像hm-this-bug-is-kinda-weird-maybe-async-will-fix-it-yep-id-did-yey.一样使用它它没有给我任何的信心，我的代码，因为我是洒async时，只是一些计时错误出现。
浏览 2提问于2015-05-06得票数 9
回答已采纳
1回答
我试图将JSON解析为一个类对象，但它总是返回一个错误。
JSON string -这就是我在allResourceString中得到的
[
{
"resourceName":"12 strong",
"resourceType":"Movie",
"summary":"12 Strong tells the story of the first Special Forces team deployed to Afghanistan after 9/11; under t
浏览 0提问于2018-04-22得票数 0
3回答
我正在尝试编写一个节点模块，以处理各种db调用。我想在任何可能的地方使用异步/等待，但是我对它有一些问题。
我已经使用了一些承诺，并导出这些功能很好。示例：
function GetUsernames() {
return new Promise(function (resolve, reject) {
sql.connect(config).then(function () {
new sql.Request()
.query("SELECT [UserName] FROM [Users] ORDER B
浏览 2提问于2017-04-02得票数 9
回答已采纳
1回答
具有异步用户功能的可观测RxJS
、、、、
我试着做一些让人觉得应该直截了当的事情，但事实证明，这是令人惊讶的困难。
我有一个函数可以订阅一个RabbitMQ队列。具体来说，这里是Channel.consume函数：
它返回一个使用订阅id解析的承诺(稍后需要取消订阅)，并且在消息从队列中取出时也有一个回调参数要调用。
当我想从队列中取消订阅时，我需要在这里使用Channel.cancel函数取消使用者：。这将获取先前返回的订阅id。
我想将所有这些内容封装在一个可观察的包中，当可观测对象被订阅时，它将订阅队列，而当可观测对象未被订阅时，我将取消订阅。然而，由于调用的“双异步”性质(我的意思是说它们同时具有回调和返回承诺)，这有点困难。
浏览 11提问于2017-04-05得票数 3
回答已采纳
我的代码使用的是从RxJava中可以观察到的代码，它正在观察C驱动器中的变化，
File file = new File("C:\\");
Observable
.interval(1, TimeUnit.SECONDS)
.concatMapIterable(x -> files(file))
.distinct()
.toBlocking()
.subscribe(System.out::pri
浏览 0提问于2016-10-25得票数 1
回答已采纳
1回答
我尝试基于AngularJS的$watch函数为我的表单实现一个自动保存功能。我初始化了观看，如下所述：
var unbindWatcher = $scope.$watch('selectedElement', function(newValue, oldValue) {
(...)
});
使用$resource对象及其查询方法加载选定的元素。然后使用列表中的一个元素设置selectedElement。模型的字段使用ng- selectedElement属性与表单元素相链接。
问题在于，在完成任何更新之前，$watch方法中指定的回调被调用一次。
这是$watch方法
浏览 2提问于2013-06-29得票数 0
回答已采纳
我正在寻找类似于Firebase 的东西，以确认在切换到下一个ViewController之前，我已经删除了所有的Firebase回调
ref.removeAllObservers()
let resultController = self.storyboard!.instantiateViewControllerWithIdentifier("Home") as! UIViewController
self.presentViewController(resultController, animated: true, completion: nil)
浏览 4提问于2015-07-07得票数 2
回答已采纳
1回答
我正在尝试使用一个名为“下面”的库中的函数
convertString(input, options, callback)
具有如下简单模板
<template>
<textarea v-model="inputText"></textarea>
{{ convertedText() }}
</template>
我尝试了以下方法
export default {
data () {
return {
inputText: ''
}
},
methods: {
c
浏览 0提问于2018-04-23得票数 0
回答已采纳
我创建了一个函数，它返回一个布尔值，但是观察者需要时间来连接，这导致代码跳过它，它打印print语句，说明flag为nil，然后在观察者中输入print。有没有办法解决这个问题？
func HidingHim(idlabel:String) -> Bool{
var flag:Bool?
var d = Database.database().reference().child("Users").child(idlabel).child("hidingUser")
var h = d.observeSingleEvent(
浏览 10提问于2020-02-12得票数 0
1回答
我在从火场得到数据有问题..。这是我的社交课。
class Networking {
static var instance = Networking()
var shopArray : [Shop] = []
func getShops() {
Database.database().reference().child("eeb3215fgsfnuvj").child("shops").observe(.value) { snapshot in
let shopsDictionary = snapshot.value as!
浏览 0提问于2018-08-13得票数 1
回答已采纳
我正在创建一个带有typescript类的菜单来实现我的菜单项操作。我正在尝试为需要一些时间的菜单操作添加一个加载器，但我面临着一个我不理解的问题。
下面是我在菜单项单击时调用的泛型方法。
public item: Item = { name: 'Execute Menu item 1', command: new FirstMenuItem() };
/** method called on every item click */
executeToolbarAction(item: Item) {
this.menuService.setLoading(true)
浏览 0提问于2019-02-21得票数 1
我正在使用Javascipt扫描AWS dynamodb。我希望我的代码保持执行，直到从扫描中得到结果。我做错了什么。
async function scanDb() {
var docClient = new AWS.DynamoDB.DocumentClient();
params = {
TableName: 'testdriveenvs',
FilterExpression : 'EnvStatus = :a',
ExpressionAttributeValues : {':a' : 'Inuse&
浏览 0提问于2019-05-05得票数 0
2回答
总的来说，我对React和Ionic以及JS都是新手，所以我遵循了，并尝试将其调整到我的用例中。
我想取得的成果如下：
当应用程序加载时，从本地存储读取JSON字符串
当应用程序退出时，将(较新的) JSON写回存储
我现在得到的是(严重截断)：
ExploreContainer.tsx
import { useStore } from '../hooks/useFilesystem';
var vars = { intervaltime : 50000 /* ... */ };
const ExploreContainer: React.FC<Con
浏览 0提问于2020-10-11得票数 0
回答已采纳
1回答
我对node.js非常熟悉，两年来一直与JS合作。但我仍然混淆了节点中的异步性质。看看下面的代码
// Synchronous Code:
function foo() {
const result1 = bar();
console.log(result1);
const result2 = see();
console.log(result2);
}
function bar() {
return 'bar';
}
function see() {
return 'see'
}
foo();
// Resu
浏览 5提问于2020-05-24得票数 0
我是一个Node.js程序员。在Node.js 7.6发布之前，我使用了模块'‘让我的代码以异步等待的方式出现。编码风格如下所示：
var async = require('asyncawait/async');
var await = require('asyncawait/await');
var getData = async(function(finder){
return await(db.collection.findOne(finder));
});
var f = function(finder){
return aw
浏览 1提问于2017-03-28得票数 1
回答已采纳
1回答
我想编写一个类来处理我所有的网络交互，称为NetworkManager。因此，使用这个类的实例，我可以得到如下内容：
NetworkManager nm = new NetworkManager();
...
nm.login(username, password);
...
然而，什么是最好的方法，这样这个网络管理器可以在UI线程上做一些事情，一旦收到一些响应？onClick样式事件的建模--我认为这应该是这样的：
nm.getPicture(new NetworkListener() {
@Override
public void run(Picture p){
浏览 0提问于2013-11-29得票数 0
回答已采纳
2回答
鉴于Python的背景，我一直试图学习JS并发模型。
在Python中运行以下代码：
async def myFunction():
print("abc")
myFunction()
什么都不会打印出来。在JavaScript中运行以下代码：
async function myFunction() {
console.log("abc")
}
myFunction()
将打印"abc"。在这两种情况下，我都没有await myFunction，但是评估是不同的。
我理解为什么Python程序什么也不打印。myFunction
浏览 4提问于2021-01-06得票数 4
回答已采纳
我很难从一个小型的fetch()应用程序中调用React。
我的想法是
有一个class (这样我就可以重用它)，调用fetch，通过从服务器获取数据从json-data中获取json-data。
class看起来像：
import React from 'react';
class GetJsonData extends React.Component {
constructor(props) {
super(props);
this.state = {
id: this.props.id,
content: this.props.content
浏览 4提问于2022-08-07得票数 0
1回答
我有异步方法，它在button_click中被调用。异步方法运行3种不同的void，并且每个void都有自己的错误处理。如果这3种方法中有任何错误，我想在button_click中显示特定的错误消息和停止代码，这也会运行更多的非异步方法，并具有它的错误处理。我所做的就是这个(例子)：
private void button1_Click(object sender, EventArgs e)
{
try
{
//calling non-async method, if It fails It should show error
//inside t
浏览 0提问于2018-04-19得票数 0
3回答
让我说我有这个功能
function sendMessage(message, content) {
return message.send(content);
}
消息返回一个承诺，但是我实际上不需要解析这个承诺，因为我不关心返回的值。
在另一个异步函数中，我按如下方式调用sendMessage：
await sendMessage(message, 'Hello')
vs
return sendMessage(message, 'Hello')
我正在调用的异步函数正在顶层等待。
我的问题是，等待和返回之间有什么区别，因为sendMessage函数不是异
浏览 7提问于2022-07-18得票数 0
1回答
我正在做一个Net core 2.0 Application。
我正在测试nested async Task Await方法。我理解异步方法的含义，但在嵌套方法中，当它变得难以理解时，我会达到一个点。
我做了这个简单的例子，我得到了一个不想要的结果。
static void Main(string[] args)
{
Testexample();
}
public static void Testexample()
{
try
{
Console.WriteLine("-------Main thread starting-------
浏览 0提问于2018-02-21得票数 0
1回答
返回promise的值
、、、
有没有一种方法可以让我们从promise中返回值？我有一个异步/等待函数，用于从另一个异步/等待函数getToken()检索令牌，但它只向我返回一个promise字符串。但是，它会在控制台日志中返回预期的值。对于我来说，访问值本身而不是下面图片中的promise字符串的最佳解决方法是什么？
const retToken = async(): Promise<any> => {
const value = await getToken();
console.log('value: ', value);
return value;
}
console
浏览 4提问于2021-04-03得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
