1回答
我正在浏览观察者设计模式，并有一些问题，我没有一个明确的答案，所以会感谢围绕他们的任何想法/想法。这特别涉及多线程场景中的异步观测器回调：
当观察者知道观察者可以在很短的时间间隔内收到来自主题的多个事件通知时，设计它的最佳方法是什么。因此，即使单个回调未完成，也很有可能获得多个通知。怎么处理这个？如何有效地使用锁？
当回调仍在执行时，如何处理取消订阅请求？如何避免这种情况下的死锁？
我认为我们可以先讨论这个问题，我相信我们会有更多的问题，因为答案蜂拥而至。谢谢你的帮助！
浏览 1提问于2013-12-30得票数 1
1回答
我正在尝试将数据从SQL移动到MongoDB。问题与C# Async Await相关。我所做的是首先收集2000个文档，然后插入到MongoDB中。我正在等待我的插入调用。我想在这里做的不是等待，而是希望继续收集下2000个文档，但只在最后一个调用返回时才调用SaveToCollection方法。
int counter = 0, totalCounter = 0;
List<BsonDocument> documentList = new List<BsonDocument>();
while (rdr.Read())
{
Dictionary<stri
浏览 2提问于2018-02-22得票数 0
1回答
这就是问题所在： 我的数据库中有一个用服务器检索的文档列表。我的angular应用程序可以检索整个文档列表。我的文档列表是有偏移量的。例如:我用偏移量0调用我的服务器，检索从0到600的第一个文档，然后用偏移量600调用检索从601到1200的文档，依此类推……直到我的服务器得到404，这意味着结束。 我想用angular做到这一点，我试着像这样使用'while‘： let done = false;
let offset = 0;
const docList = [];
while(!done) {
this.docService.re
浏览 24提问于2021-02-11得票数 0
回答已采纳
1回答
我编写了编译和运行C程序的简单映射。它使我想要的东西，但它返回到vim后，程序完成执行，而不等待我按回车。我怎么才能解决这个问题？
map <leader>b :!clear && gcc % -o %< && ./%<<CR>
浏览 1提问于2017-10-29得票数 1
回答已采纳
3回答
我在我的Angular 7应用程序中包含了一个功能模块的路由。属于此功能的组件需要获取路由参数。我该怎么做呢？ 我尝试使用文档中显示的方法，如下面的代码所示。我已经评论了哪种方法有效，哪种方法不起作用。我想使用第二种方法，它不起作用，因为它将结果映射到我将在模板中使用的products$可观察对象。可能的问题是什么？ import { Component, OnInit } from "@angular/core";
import { ActivatedRoute, ParamMap } from "@angular/router";
import { Obs
浏览 26提问于2019-03-23得票数 0
回答已采纳
我有一个示例代码，其中有一个for循环，其中有一个函数进行ajax调用来获取数据。在这里，我面临一个问题，需要在ajax调用完成后才进行迭代。正在发生的事情是迭代正在完成，甚至循环之后的语句也在执行中，只有这样，ajax调用才会完成。
实际结果-循环1初始化，循环1完成，语句外部循环执行，Ajax调用完成。
预期结果-循环1初始化，Ajax调用完成，循环1完成，语句外部循环执行.
在下面的示例代码的输出中，我们可以看到$scope.finalData的值是空的，因为数据赋值发生在ajax调用完成之前。
<html>
<script src="https
浏览 4提问于2017-11-28得票数 1
我目前有一个数据表，该数据表中填充了来自Firestore的数据。我还使用MatTableDataSource实现分页、排序和筛选。所有3都可以正常工作，但由于某种原因，当页面刷新时，我的数据只加载一次。如果我转到另一个页面，然后返回到表，数据就会消失。我不知道为什么会发生这种事。下面是我的密码。
服务
import { Injectable } from '@angular/core';
import { AngularFirestore, AngularFirestoreCollection, AngularFirestoreDocument } from 'ang
浏览 0提问于2017-11-13得票数 6
回答已采纳
2回答
所以我正在尝试用angular 8中的FormGroup创建一个表单。我正在调用一个异步方法，并等待我正在进行的api调用。即使我这样做了，它似乎仍然试图在api调用的数据出现之前创建表单。我是不是做错了什么？
下面是控制器：
import { Component, OnInit } from '@angular/core';
import { AuthService } from '../../auth.service';
import { Subscription } from 'rxjs';
import { CustomValidator
浏览 17提问于2019-07-27得票数 0
我正在尝试使用RxJS Observable.forkjoin方法来同步我的服务器端创建的假数据，但是如果我尝试将它们与MeteorObservable.Collection<any>.insert方法一起使用，它永远不会触发订阅。
如果我尝试对observableBatchTest.push(Observable.from([i]));这样的“原始”angular Observable使用相同的方法，没有任何问题，订阅也会被正常触发。
以下是现有问题的一个小的最小示例：
function initFakeChats(numberOfChats: number): Observab
浏览 6提问于2018-02-08得票数 1
回答已采纳
4回答
我正在执行一个Range2项目，我有一个名为“MockService”的服务，它的方法名为“getMockData()”，在组件中使用的方法如下：
import { Component, OnInit } from '@angular/core';
import { Mock } from './mock';
//import { MOCK } from './mock-data';
import { MockService } from '../mock.service';
import { Chart } from '
浏览 0提问于2018-05-18得票数 0
回答已采纳
1回答
我有一个Angular 6应用程序，其中我循环遍历一个数组，并在组件中为数组中的每一项创建一个API。在请求数组中的下一项之前，我希望等待数据接收完毕，并且其中的所有逻辑都已运行。现在，它只是对数组中的最后一项发出多个请求。如何让循环在进入下一个请求之前等待响应？ for (var index = 0; index < data.length; index++) {
this.deviceService.getMeasurementData(data[index].id, this.authService.userSession.authToken, this.filterMo
浏览 19提问于2019-03-01得票数 0
我有一个angular组件，其中我定期从服务请求值：
setInterval(() => {
this.updateValues();
}, 1000);
updateValues(): void {
if (this.isValuesUpdateRunning === false) {
this.isValuesUpdateRunning = true;
this.apiService.getCurrentValues().subscribe((data: any) => {
if (data != null) {
浏览 3提问于2020-03-04得票数 2
当前行为
使用我的http服务调用api以获取所有用户
对于每个用户(循环)，使用我的http服务调用api (其他实体)以获取用户的所有位置。
我需要与他的用户关联的位置(根据请求返回)。
显示一个阵列(角质材料垫-标签)
我的数组是空的或缺少每个用户对象中的位置.
预期行为
我需要建立一个数组与用户和他的位置之前打印垫标签。
带指令的问题的最小再现
在我的部分：
public userWithLocations = [];
ngOnInit () {
this.loadData();
}
loadData()
浏览 0提问于2018-08-08得票数 0
是否有必要取消订阅反应性表单控件的valueChanges订阅，或角将取消它为我们？
在路由器中：
根据官方文档，Angular应该为您取消订阅，但显然，有一个。
因此，对于FormControl的valueChanges，我的担忧是相同的。
浏览 3提问于2018-01-04得票数 25
我是Angular 9的新手，我有一个程序，用户在这个程序中输入一个名字-提交后，发送一个POST HTTP请求并存储名字。然后，我有一个子头的不相关组件，它列出了使用ngOnInit()的GET HTTP请求存储的名称。但是，我需要该子标题在每次输入新列表时动态更新该名称列表，而不仅仅是在组件实例化时更新。
我不确定该如何继续。我肯定我可以简单地添加一个按钮来获取和更新上述列表，但尝试更动态的东西。提前感谢！
//SERVICE.TS...
import { Injectable } from '@angular/core';
import { HttpClient } f
浏览 0提问于2020-06-23得票数 0
我在c++中有以下代码片段
int main(){
std::vector<int> numbers(10);
for (int i = 0; i < numbers.size(); i++){
std::cout << "Please enter number " << i << "\n";
std::cin >> numbers[i];
}
}
我希望对于for循环中的每个i值，代码都会等待我的输入输入下一个数字。但是，我只是打印了10次“请输入数字i”，然后循环结
浏览 54提问于2021-05-27得票数 0
我有一个父MatHorizontalStepper组件，它使用subscribe来检查服务中的Observable是否已经从false更新到true。如果可观测值发生了变化，则自动移动到步进器的下一步。
但是，我似乎无法让更新来正确地更改步骤。下面是我创建的两个组件。
父组件
import { Component, OnInit, ViewChild } from '@angular/core';
import { Observable } from 'rxjs/Observable';
import { MatHorizontalStepper } from
浏览 0提问于2018-06-19得票数 0
回答已采纳
我试图用HttpClient提出一个GET请求，我想要一个可以观察到的返回请求。
问题是HttpClient没有向服务器发出请求，如果我使用订阅请求是正确的。我通过检查nginx access.log文件进行检查，没有订阅()，没有向服务器发送请求，而且我得到了一个空的可观察性。
没有错误，没有警告但是没有对服务器的调用..。我哪里做错了？
tns版本：3.4.1
app.modules.ts
import { NgModule, NO_ERRORS_SCHEMA } from "@angular/core";
import { NativeScriptModule } fro
浏览 0提问于2018-01-26得票数 0
回答已采纳
我想要一个运行每个x ms的计时器/间隔，并且我将在间隔期间运行一些进程。
我需要什么？我希望计时器在触发下一个间隔之前等待我的进程完成，怎么做？
我正在做动画，所以如果一些时间间隔稍微长一点的话，就可以了。只想确保所有进程都已完成执行。
浏览 2提问于2021-07-20得票数 3
回答已采纳
我的目的是在命令提示符中捕获TASKKILL事件，并使用此事件。
也许，我认为需要使用kernel32.dll，但我找不到处理程序。
[DllImport("kernel32.dll", SetLastError = true)]
[return: MarshalAs(UnmanagedType.Bool)]
private static extern bool TerminateProcess(IntPtr hProcess, uint uExitCode);
更新
@Ben建议：
_Using WMI:
步骤1:运行命令mgmtclassgen Win32_Process
浏览 7提问于2014-10-31得票数 0
回答已采纳
我写了这样的代码。
import asyncio
import time
import random
async def secondCoro(myId):
waiting_time = random.randint(1,5)
while 1:
print("i am {} ".format(myId))
time.sleep(waiting_time)
async def main():
for i in range (10):
await loop.create_task(secondCoro(i
浏览 1提问于2020-06-19得票数 1
回答已采纳
3回答
我正在尝试使用rxjs在Angular中打印http调用的结果
考虑以下代码
import { Component, Injectable, OnInit } from '@angular/core';
import { Http, HTTP_PROVIDERS } from '@angular/http';
import 'rxjs/Rx';
@Injectable()
class myHTTPService {
constructor(private http: Http) {}
configEndPoint: string =
浏览 75提问于2016-04-04得票数 85
1回答
所以我有一个Channel模型和一个Subscriber模型。
通道具有一个属性，该属性包含与已注册的订阅者对应的ID数组。
我一直坐在这里，用async把我的头骨撞在墙上：
获取一个通道列表，然后在回调的末尾
从该频道获取订阅者ID列表，然后在回调结束时
再次使用async，对于每个订阅者ID，运行一个mongoDB查询以捕获用户配置文件并修改初始通道列表
这似乎是可怕的错误。Subscriber是否应该以嵌入文档的形式存在于通道中？如果是这样的话，当用户需要登录时，我是否必须在所有通道和所有嵌入的文档中进行搜索呢？
如果我想保持它们的分离--就像我想对用户、投标人和其他
浏览 1提问于2015-04-22得票数 0
1回答
我有一个WPF应用程序，我使用Frame来加载Page的is。在Page上，我调用我的自定义控件<Controls:OrderDataGrid x:Name="cntrlOrderDataGrid" />。在这个控件上，当我导航到Frame中的Page时，我有DataGrid填充的数据。有时加载需要一段时间，我需要知道DataGrid何时完成加载，所以我设置了Loaded事件：
private void dgOrders_Loaded(object sender, RoutedEventArgs e)
{ }
但是我想不出我能不能通知MainWindow DataG
浏览 0提问于2012-11-13得票数 1
回答已采纳
我正在与ionic、angular、cordova开发一个混合应用程序，我创建了一个名为piecesservice的服务
import {Injectable} from "@angular/core";
import {HttpClient} from "@angular/common/http";
import {Observable} from "rxjs";
@Injectable()
export class PiecesService {
private donnes: any;
constructor(public http
浏览 0提问于2018-07-27得票数 0
我在一个服务中有以下函数uploadCSV，它应该发送到端点以上传csv -我可以在控制台日志中看到csv文件在那里，但是当检查网络选项卡时，没有显示任何post请求-知道为什么吗？
import { Injectable } from '@angular/core';
import { ApiService } from "../../../services/api.service";
import { Observable } from "rxjs/Observable";
import { HttpClient } from '@a
浏览 12提问于2018-08-16得票数 0
回答已采纳
我在过去的某个地方读到过，angular.foreach是异步的，而不像在数组上循环是同步的。很长一段时间以来，我一直在考虑这一点，并做必要的事情来避免在循环完成所有迭代之前执行循环后的代码(通过将angular.foreach包装在一个匿名JavaScript函数中，该函数调用一个回调，该回调将在循环完成所有迭代后执行)。
(function(callback){
angular.foreach(..)
callback();
})(callback)
但是我和一位同事进行了一次对话，他不同意angular.foreach是异步的，而且我也找不到那个信息了，这让我现在很困惑。
浏览 22提问于2018-01-08得票数 1
2回答
在一个Angular应用程序中，你可能会有相当多的观察值，当你不再需要的时候，你可能会忘记完成它们。因此，它们可能会意外触发，导致难以调试的意外副作用。 有没有办法在调试过程中随时查看所有未完成的观察值？我在考虑一个DevTools工具。
浏览 17提问于2021-11-03得票数 0
1回答
我发现自己经常需要以下代码场景
Subscribe to the event -> wait the event -> Subscribe to the event。
还有比这更好的方法吗：
myEvent += mydelegate;
while (mydelegatewasn't called)
{
// do stuff
}
myEvent -= mydelegate;
还有，什么是最好的方式等待我的委托完成它的工作？
浏览 0提问于2012-04-22得票数 1
1回答
实际上我对角质还不熟悉。我试图在组件文件中循环一个属性，但是我总是收到一个消息，即属性legnth是未定义的。
这是我的组件文件。如果我从我的HTML中循环遍历房间属性，它工作得很完美，但是在组件本身中，我无法访问该属性。需要帮助
import { Component, OnInit, ElementRef } from '@angular/core';
import { FormBuilder, FormGroup, Validators, FormControl } from '@angular/forms';
import { AddRoomServic
浏览 0提问于2018-11-12得票数 0
回答已采纳
我希望Notepad++像对待.css文件一样对待我的.less文件，从而对我打开的任何.less文件进行语法高亮显示。
浏览 56提问于2011-02-06得票数 52
回答已采纳
2回答
我在我的应用编程接口中使用了WebHooks。因此，一旦请求得到处理，我们的REST服务将向请求中发送的回调URL回发一个响应。
Client Server
|(request) |
|----------------->|
|<-----------------| ||
| (response)| ||
| | _||_ Time
| (callback)| \ /
|<-----------------|
浏览 60提问于2017-12-29得票数 2
回答已采纳
我正在做一个网站，使用spring作为我的后端，angular和html作为前端。
我的MySQL数据库中有两个表(services/ offers )(offers表有一个serviceName外键，它同时也是服务表的主键)。
我有一个angular组件，它调用两个数据库表，并将它们放入两个不同的数组中。
我试图在angular中创建一个新的数组，其中包含offers数组中每个serviceName的出现次数，但是当我尝试记录(console.log)这个新列表时，它有时是空的，有时甚至不会出现。
下面是angular组件：
import { Component, OnInit } from
浏览 2提问于2019-05-25得票数 0
当我使用post时，没有错误，但是post方法不工作this.http.post。(它昨天起作用了，但今天不起作用。)不知道)有我的服务：
import { Injectable } from '@angular/core';
import {HttpClient, HttpHeaders, HttpParams} from '@angular/common/http';
import {Observable} from 'rxjs/Observable';
import {GetData} from './data';
impo
浏览 0提问于2018-03-10得票数 1
回答已采纳
1回答
两个组件之间的连接
、、、
我正在实现一个角度的例子。我在navbar组件中有一个搜索输入，我想在另一个组件中显示搜索结果，但是我发现了问题，第二个组件如何知道我在搜索输入文本中的值。这是我的navbar.ts文件：
import { Component, OnInit, Input } from '@angular/core';
import { Router } from '@angular/router';
import { RechercheService } from
'../../services/recherche/recherche.service'
浏览 0提问于2018-04-16得票数 0
回答已采纳
我需要发送一个POST请求，我并不关心它是成功还是失败，=> "fire => forget“。在发送请求之后，立即启动硬重定向。这会导致取消Angular HttpClient POST请求。 // sending POST request
this.httpClient.post('someUrl', {}).subscribe();
// hard redirect causes cancelation of POST request
window.location.replace('someOtherUrl'); 有没有办法在不被取
浏览 21提问于2021-01-07得票数 0
回答已采纳
1回答
我尝试使用这个例子创建。这个例子在离子3，我想让它工作在离子4，在这个例子中，他是使用手势。但问题是我不能引进手势。
例如，导入了这个Ionic v3：
import { Gesture } from 'ionic-angular/gestures/gesture';
因此，当我们导入其他@ionic/angular但显示错误时：
import { Gesture } from '@ionic/angular/gestures/gesture';
错误:找不到模块“@离子型/角型/手势/手势”。
简而言之，我只想在我的离子型4项目中导入手势。请帮帮忙。
浏览 0提问于2019-07-26得票数 1
简单地问一下，我是否需要取消订阅这里包含的订阅，因为它不在构造函数中？
import { Component, OnInit } from '@angular/core';
import { HttpService } from "./services/http.service";
import { Main } from "./interfaces/data-interface";
@Component({
selector: 'app-root',
templateUrl: './app.component.
浏览 7提问于2022-02-14得票数 1
回答已采纳
我对Braintree集成还是个新手。
我正在开发一个Angular应用程序，我想与Braintree集成来管理用户订阅。
如果我理解正确的话，我认为我的Angular应用程序不能直接与Braintree api交互来管理用户订阅。对吗？
看起来我需要一个后端(例如：Node.js express服务器)来促进交互。
我还发现Braintree提供了GraphQL应用程序接口，但我没有看到任何关于订阅的文档。目前还不支持吗？
我还考虑过创建AWS lambda函数来托管Braintree集成的服务器端需求，如果服务器端是必须的话。这样就足够了吗？
感谢您的支持
更新：
我能想出怎么把所有东西都
浏览 21提问于2020-04-01得票数 2
1回答
我可以在GitHub项目angular-10-signup-verification-boilerplate中看到以下片段：
export function appInitializer(accountService: AccountService) {
return () => new Promise(resolve => {
// attempt to refresh token on app start up to auto authenticate
accountService.refreshToken()
.
浏览 2提问于2022-07-17得票数 1
回答已采纳
1回答
我试图推断RxJS中一个订阅者的生命周期。也就是说，我们都知道我们需要取消订阅可观察对象，对吧？但问题是:为什么？
我正在开发一个大型的基于Angular的应用程序，所以我不能真正分享我的代码，但我会试着给你我的思考实验的上下文。假设我们有一个以下组件：
class Comp extends Component {
public o$;
constructor(private store$: Store) {}
ngOnInit() {
this.o$ = this.store$.pipe(select(...), map(...));
浏览 0提问于2018-06-13得票数 0
2回答
轮询史诗行为
、、
我正在写一个史诗，它每隔一定的时间轮询一次服务器，在本例中，3秒的启动延迟，每5秒轮询一次，使用计时器通过管道连接它，但我不确定这种行为背后的原因。
我的史诗没有等待我的内心完成，所以输出真的很奇怪。
我试过更改地图和使用exhaustMap，但不确定我是否找到了正确的方法。
export const testingEpics = action$ => {
// Stop upon a end pending action trigger, for debugging/stopping if needed
const stopPolling$ = action$.pipe(ofT
浏览 0提问于2019-05-15得票数 0
我正在开发angular2应用程序，它类似于最后提供的Plunkr链接。
在HeroService中，我有一个属性clickCount，它将在英雄单击时增加。但是登录后，我想重置这个参数。我不想使用该服务并重置其值(实际上，在我的应用程序中，我使用了许多服务，因此无法使用每个服务并在注销时重置其值)。
是否有任何方法可以在不重新加载整个应用程序的情况下对特定操作重置/重新加载服务。英雄服务如下所示
import { Hero } from './hero';
import { HEROES } from './mock-heroes';
import { Inj
浏览 4提问于2016-12-08得票数 2
回答已采纳
1回答
我的操作系统是win10，当我用运行"npm install -g Ionic cordova“命令安装ionic时，一切正常，但当我运行"ionic start”命令时，正常情况下，它应该要求并等待我输入我的项目名称，但它只是要求我而不是等待我等待，命令很快结束。
"ionic start“命令的执行方式如下：
C:\WINDOWS\system32>ionic start
? What would you like to name your project:
C:\WINDOWS\system32>
"ionic start ionicstud
浏览 0提问于2017-10-09得票数 0
我有以下几点：
public override Task OnConnected() {
HandleConnectionAsync(Context).Wait();
return base.OnConnected();
}
在遵循“不要阻止集线器方法”的指导下，我试图等待我的HandleConnectionAsync调用，但是如果我使用async，我将得到以下结果：
public override async Task OnConnected() {
await HandleConnectionAsync(Context
浏览 5提问于2016-10-26得票数 3
回答已采纳
2回答
我正在使用Angular 6，并使用Django REST Framework的API端点和OAuth2实现。
我是我的角度应用程序，我在localStorage中存储access_token、refresh_token、expires_in、generate_time、user_valid、token_type，同时用户登录使用username和password
由于expires_in很低，最多只有几分钟，所以即使用户在页面上活动，access_token也会过期。因此，我需要使用保存的access_token重新生成refresh_token。
我让auth.interceptor.ts
浏览 1提问于2018-08-04得票数 1
回答已采纳
我是angular2新手，我需要一些帮助。我正在使用下面的服务级别。
import {Injectable} from 'angular2/core';
import {Http} from 'angular2/http';
import 'rxjs/add/operator/map';
@Injectable()
export class UsersService {
private _url = "http://jsonplaceholder.typicode.com/users";
constructo
浏览 1提问于2016-08-27得票数 0
在我读过的一些关于Angular observables的教程和文档中，我看到了很多关于取消订阅订阅会导致内存泄漏的警告(除非在组件的模板中使用异步管道)。 我在我的应用程序中有一些支持类，我在其中创建自定义观察点，但我想知道，如果观察点和所有订阅者都超出范围，取消订阅它们是否重要。例如，我有一个父类，它包含数组中的子对象的映射。父级为每个子级订阅一个observable，以检测" value“属性的变化，并且每当子级更改其值时，父级都会重新计算它的”total“属性。 然后假设父对象超出了作用域，通常只要没有任何子对象的活动引用挂起，父对象和所有子对象就会被垃圾回收。父级是否有必要
浏览 40提问于2020-04-14得票数 0
回答已采纳
在Angular中，每次需要查询端点时，都需要调用以下代码：
this.service.getSomeData()
.pipe(takeUntil(this.onDestroy$))
.subscribe((message: any) => {
some code here;
}
takeUntil是组件中的一个函数，用于在组件被销毁时取消订阅。
如何重构上面的代码，使其不需要在每次使用资源时都键入所有这些内容？所以最后看起来是这样的(或多或少？)：
this.service.getSomeData(
(message: any) => {
som
浏览 2提问于2019-10-08得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储活动推荐
腾讯云开发者
