import app from "../src/app";
import request from "supertest";
import { createConnection, getConnection, getRepository } from "typeorm";
import { Group } from "../src/entity";
beforeEach(() => {
return createConnection({
type: "sqlite",
浏览 13提问于2021-02-12得票数 6
我正在尝试全局设置一个值，但无法求解。以下是我的代码 声明的变量- allViewounters: any[] = []; viewgraph() {
let formData: FormData = new FormData();
this.profileService.lineChartData(formData).subscribe((response) => {
this.allViewounters = response.allViewounters;
console.log(this.al
浏览 49提问于2020-08-31得票数 0
AWS的实现使我感到困惑。在代码中，有一个函数定义：
def on_message_received(topic, payload, **kwargs):
print("Received message from topic '{}': {}".format(topic, payload))
global received_count
received_count += 1
if received_count == args.count:
received_all_event.set()
然后这个函数被调用如下：
浏览 15提问于2022-10-29得票数 0
回答已采纳
这是我的第一个堆栈溢出的帖子，如果我格式化不正确的话，我会非常赤裸裸的。
这是我的第一个角度项目，我无法分配从http.get().subscribe(.)检索的数据。方法添加到组件类变量。
我的组成部分：
...
export class LeafletMapComponent implements OnInit, AfterViewInit {
data
constructor(private ps: PeopleService, private NgZone: NgZone) {}
ngAfterViewInit(): void {
console.
浏览 1提问于2021-04-14得票数 0
1回答
因此，我正在尝试等待订阅来自本地存储服务的数据，但我从本地存储获得的数据有时会延迟，并且未定义.Uid
constructor(private route: ActivatedRoute,
private cp: CommerceProvider,
protected localStorage: LocalStorage) {
this.localStorage.getItem('castra').subscribe((data) => {
this.uid = data.uid;
console.log
浏览 31提问于2018-09-10得票数 0
我有一个流星发布函数，我在这个发布函数中抛出一个错误，以便被订阅者捕获。我使用的是铁路由器，在“waitOn”函数中，我订阅了该出版物。由于某些原因，当我从发布中抛出错误时，错误函数没有被调用，我也不知道为什么。帮助是非常感谢的！
下面是我的订阅( 'assignmentsByGroup')和on函数(onErrorfunction)的路由：
this.route('assignmentsList',
{path: '/groups/:groupId',
waitOn: function() {
var onErrorfunction =
浏览 2提问于2014-02-17得票数 1
回答已采纳
1回答
我对角7还不熟悉，从组件函数返回数据有一个问题。这可能不是问问题的方式，因为我对角7的理解较少。
以下是我的组件功能：
getUserStatus
getUserStatus(){
this.chatService.newUserJoined().subscribe(data=>{
this.statuses = data;
});
return this.statues;
}
chatService从服务中获取数据，现在我只想从这个函数返回状态，状态可以是true，也可以是false。我需要从我尝试过的函数返回数据，但它给了我未定义的数据。
浏览 0提问于2019-05-13得票数 0
回答已采纳
3回答
我想在第六角实现以下目标：
同时(真){
调用API
处理响应
等1秒
}
我尝试了TimerObservable，但由于请求是异步的，所以在请求完成后1秒未能完成等待。其目的不是在请求需要很长时间时调用api，而是在请求完成时间较短时使最近的响应快速。
我的守则是：
TimerObservable.create(0, 1000)
.subscribe(() => {
this.api.getData().subscribe(
response => {
console.log(response);
}
浏览 0提问于2018-08-30得票数 1
回答已采纳
我正在学习如何使用store.subscribe()方法创建取消订阅()。下面是密码。我不明白逻辑:为什么我们使用store.subscribe方法将取消订阅常量声明为存储的取消订阅函数。(从字面上讲，订阅者应该为商店订阅“某样东西”，对吗？)
import store from './store';
const unsubscribe = store.subscribe(
() => console.log("Store changed!", store.getState())
);
store.dispatch({
type: &#
浏览 2提问于2020-10-30得票数 0
1回答
我正在尝试使用.subscribe将数据从api获取到数组，但数组将保持为空。
dataService.ts
getData(): Observable<Data[]> {
return this.http.get<Data[]>(this.dataUrl);
}
data.ts
data: Data[] = [];
ngOnInit(): void {
this.getData();
console.log(this.data[0].dataId);
}
getData(): voi
浏览 4提问于2021-06-14得票数 0
2回答
无法在订阅中分配数据
、、、、
我对post方法有一些问题。我总是在我的temporarySegment中得到空的segmentdata对象。我对number也是这样做的，那就是工作。subscribe中的变量结果是SegmentData，而在console.log中我收到了预期的响应。这怎么可能呢？我的方法是：
onGetSegmentsClick(size: number) {
debugger;
if (size > 0) {
let counter = 0;
let temporarySegment = new SegmentData();
w
浏览 1提问于2017-11-11得票数 0
1回答
我正在尝试从服务器获取优惠券对象(REST API + Angular)，
当我使用' subscribe‘-在'subscribe’内，对象来自类型'Coupon'，但在subscribe之外，它变成了'undefined‘。
我要怎么做才能将他的类型保留在另一个组件的订阅之外？
log - 1 :
company-coupons.component.ts:24 **undefined**
log - 2 :
company.service.ts:32
**Coupon {id: 44, title: "Test", startDa
浏览 6提问于2021-03-07得票数 0
2回答
我正在构建一个使用基于令牌的认证的Ionic应用程序。当用户创建访问令牌时，将存储在本地存储中。
然后，我的代码调用提供程序来获取它需要的任何数据(在这种情况下，它是从API中提取“培训程序”)。
反过来，该提供程序调用另一个提供程序，它处理我的API的HTTP请求。它有效地设置了所需的头并启动了HTTP请求，然后将响应返回给请求提供程序。
这一切都很好，直到我需要在发出HTTP请求之前从存储中获取访问令牌。从存储中访问数据似乎不是即时的，而是使用then语法。
似乎当我从代码中调用提供者时，它会传递给培训程序提供程序，然后传递给API提供程序。这里的代码然后运行并传回，但是这发生在我的应用程
浏览 4提问于2017-07-13得票数 7
service.ts
get_update(id:any): Observable<any[]>{
let headers = new Headers({ 'Content-Type': 'application/json'});
let options = new RequestOptions({ headers: headers });
return this.http.get('http://localhost:8000/vendor/'+id,options)
浏览 0提问于2018-04-08得票数 0
我们有一个ASP.NET MVC应用程序，它有一个表单供访问者订阅他们的通讯的详细信息。
下面定义了负责订阅用户的方法。我们也有一个自定义的web，我们通过这个方法来联系它。
public async Task<string> Subscribe(User user)
{
if (user== null) throw new ArgumentNullException("user");
var request = new RestRequest("subscribe", Method.POST)
{
Requ
浏览 6提问于2015-02-11得票数 0
回答已采纳
4回答
可观察到的是稍后返回数据。
、、、、
ngOnInit() {
this.getTypeList();
this.buildTemplate();
}
private getTypeList(): void {
this.searchService.getViewTypeList(this.org)
.subscribe(viewTypeList => {
this.viewTypeList = viewTypeList;
});
}
this.buildTemplate() : void {
co
浏览 7提问于2020-07-16得票数 0
回答已采纳
我需要推迟几秒钟的通话。我有有效的解决方案，但足够好。
public recieveNewContact() {
this.allData();
setTimeout(() => {
this.lastAddedItem()
}, 100)
}
public ngOnInit() {
this.allData()
}
allData() {
this.accountsService.getContactPerson().subscribe(
(data) =>
浏览 5提问于2021-08-20得票数 1
1回答
我有一个HTTP请求，希望共享多个组件的结果。当然，HTTP请求返回一个Observable。我希望多个组件能够在不触发额外HTTP请求的情况下订阅。
我在组件中使用Subject完成了这一任务，该组件按需发出HTTP请求，并有另一种订阅主题的方法。虽然这是可行的-这似乎是过火，当然有一个更好的方法来做到这一点。
学科服务
@Injectable()
export class EventService {
subject: BehaviorSubject<any> = new BehaviorSubject<any>(Observable.create());
浏览 1提问于2019-01-15得票数 2
回答已采纳
1回答
我试图将值推入数组，但是值被推入了错误的顺序。 //Returns ongoing stream of the decibels in the room
async getNoise() {
let subscription = this.dbMeter.start().subscribe(data => {
this.noiseDb = data;
return data;
});
} //Returns your current location
getPosition() {
return new Promise((res, rej) =>
浏览 8提问于2020-01-08得票数 0
2回答
我试图在订阅之外的函数中使用从角可观测服务返回的数据。我可以成功地访问视图组件(.html)中的数据，但是当我无法从component.ts文件中的另一个函数访问数据时。当试图从下面的'drawChart‘函数访问时，该值将以“未定义”的形式返回。
如何从specialistCount函数访问drawChart数据？
我的组件代码如下：dashboard.component.ts
ngOnInit() {
this.getUserCounts();
this.drawCharts();
}
getUserCounts() {
浏览 0提问于2018-08-20得票数 0
2回答
我想用axios从项目外部获取数据。我是在类的一侧这样做的，但是由于某种原因，我以承诺的方式检索数据，我使用的是等待和承诺，但最终我收到了对象承诺中的数据。
const Online_Visitors_System = class OnlineVisitors {
constructor() {
// get VisitorIP
this.IP = this.fetchIP();
// config redis for key space notification
this.redis = Redis.createClient();
this.red
浏览 0提问于2019-06-05得票数 0
回答已采纳
2回答
我正在尝试用NestJS实现NestJS，并使用RxJS可观察来处理服务器流。
在下面的代码中，我尝试将值从observable放到results数组。函数findAllRepos 返回空列表，而subscribe 中的console.log(value)正确地打印所有结果。
findAllRepos(): Repository[] {
const results: Repository[] = [];
const observable = this.mainService.findAllRepos({});
observable.subscribe({
浏览 5提问于2021-09-23得票数 0
回答已采纳
3回答
我希望从api中获取数据并将其分配给我的变量。
在订阅中，我将数据分配给subscribe和控制台日志变量中的变量。好了，变量现在有数据了，但是在subscribe结束后，busDepotLocality仍然是未定义的。试着让超时等待，但什么也没有
app.component.ts：
busDepotLocality: BusDepotLocality;
ngOnInit() {
this.mapService
.getBusDepotLocality()
.subscribe((data: BusDepotLocality) => {
浏览 0提问于2019-07-19得票数 0
回答已采纳
2回答
我试图从多个http请求中检索数据，所以我决定避免嵌套的subscribe()。我只想写异步等待风格的代码。
const diagnostics = this.http.get(url, {params: params}).toPromise()
console.log(diagnostics);
但我得到的是：
// ZoneAwarePromise {__zone_symbol__state: null, __zone_symbol__value: Array(0)}
我不知道如何处理它来提取数据。
有没有办法避免像这样的回调？
.then(res => {}).catch()
浏览 2提问于2018-07-15得票数 5
回答已采纳
我正在尝试构建应用程序，在那里我发送一个get请求来从组件获取数据。此请求将被调用，数据将用于执行下一步。但是，在我从服务获得响应之前，它正在执行下一步。
这是我的服务文件：
getSabhaListDetailsName(sabhaMandalName: string): Observable<any> {
const sabhaListDetailsNameURL = this.rooturl + 'sabhatypebysabhaname';
return this.http
.post(sabhaListDetailsNameURL,{}, { pa
浏览 0提问于2019-02-06得票数 2
我是从C#开始的，用Java语言编写了很多代码，但在这里遇到了一些麻烦。我正在尝试学习如何在我正在开发的应用程序中使用。我无法让实际的侦听器触发事件。下面是我的监听器代码：
using System;
using System.Windows.Forms;
using Gma.System.MouseKeyHook;
namespace ChromaHeatmap
{
class keyListener
{
private IKeyboardMouseEvents m_GlobalHook;
public void Subscribe()
浏览 8提问于2015-06-06得票数 0
我已经找到了解决办法，但都没有用。
单击按钮“编辑”后，它将我重定向到“编辑-事件”，我将得到：
ERROR TypeError:无法读取未定义的属性“类别”
ngOnInit() {
this.eventService
.getEventById(this.route.snapshot.params.id)
.subscribe((ev) => this.event = ev);
在订阅之后，如果我这样做: console.log(this.event)，它会返回未定义的。如果.subscribe(console.log(ev));返回给我一个对象。不知
浏览 0提问于2020-03-21得票数 0
回答已采纳
2回答
我有一个服务用作本地数据存储，以便在应用程序中共享数据。该服务在开始时进行一些rest调用来初始化一些数据。它看起来像这样：
Injectable()
export class DataStoreService {
leadList: LeadModel[]
optyList: ContactModel[]
constructor(public dataService:DataService){
this.initializeData()
}
initializeData() {
this.dataSe
浏览 0提问于2018-01-26得票数 7
如果标题没有写好，我很抱歉。在我的角度代码库中，我可以看到两个不同的put请求：
public Save() {
const types: string[] = this.getTypes.getCurrentTypes();
this.userTypeService
.updateTypes(this.userID, groups)
.subscribe(() => {
showToast("success", "User types Updated.");
});
}
其中up
浏览 3提问于2020-09-19得票数 0
回答已采纳
4回答
在ngOint事件中设置变量值后，访问变量值时出现问题，val的值在函数GetApps中可用，但在process函数下不可用。
TS
export class SomeComponent implements OnInit {
val:any;
ngOnInit() {
this.GetApps();
this.process()
}
GetApps() {
this._srvc.getApps()
.subscribe(
data => {
this.val = data;
浏览 0提问于2019-03-14得票数 0
2回答
使用角和RxJS库。
我有一个简单的方法：
method(){
const data = this.data;
const moreData = this.moreData;
this.anotherMethodOne(data)
this.anotherMethodTwo(moreData)
}
如您所见，我正在调用另外两种方法。anotherMethodOne()应该在anotherMethodTwo()之前执行--而且确实如此。
在anotherMethodOne()中，我有一个.subscribe
anotherMethodOne(data) {
<!-- at th
浏览 1提问于2022-01-27得票数 0
当在Javascript中使用stomp.js和sockjs时，我可以很好地连接Spring后端。
在使用Angular5中的stompjs和sockjs时，我一直在获取以下错误：
InvalidStateError:连接尚未建立
有解决办法吗？仅仅添加sockjs.min.js，，是没有帮助的。
详细记录如下：
设置连接/1 main.3388a5e3a20e64e3bdb8.bundle.js:1设置连接/2 main.3388a5e3a20e64e3bdb8.bundle.js:1将订阅.main.3388a5e3a20e64e3bdb8.bundle.js:1打开网络套接字。main
浏览 0提问于2018-10-19得票数 3
回答已采纳
我正在用Node.js和创建我的第一个机器人，并且我试图弄清楚如何在对话框中将控制从一个方法传递到另一个方法。
在用于C#的中，非常简单：
context.Wait(NextMethodName);
其中，NextMethodName是在bot接收到下一个用户消息之后运行的方法的名称。
我试图在Node.js中做一件类似的事情。我有两个功能。第一个提示用户输入某项内容或单击一个按钮，第二个应该处理用户的输入。我正努力把控制权传递给第二个功能。
bot.dialog('subscribe', [
function (session) {
var card = new bu
浏览 4提问于2017-05-25得票数 0
回答已采纳
我有一个非常通用的连接记录来连接nats服务器，并且只是盲目地将消息打印到命令行。
package main
import (
"github.com/nats-io/go-nats"
"fmt"
)
func main(){
servers := "nats://URL:30401, nats://URL:30402, nats://URL:30403"
nc, _ := nats.Connect(servers, nats.Token("TOKEN_KEY"))
// Subsc
浏览 1提问于2018-05-09得票数 2
回答已采纳
2回答
我在我的角度应用程序中有一个对象数组，我试图用"for循环“读取对象中的数据，而我在控制台中什么也没有。下面是我如何创建数组对象的模型和其他细节。
file_info.model.ts
import { MSGraphService } from './../ms-graph.service';
export interface file_info {
ms_graph: MSGraphService;
file: any;
sessionUrl: string;
}
upload.component.ts
import { file_inf
浏览 8提问于2022-05-05得票数 0
回答已采纳
1回答
我有下面的场景
如果尚未加载数据，则加载数据
this.mailFacade.mailLoaded$
.pipe(
filter(res => !res),
takeUntil(this.unsubscribe$)
)
.subscribe(_ => this.mailFacade.get());
this.userFacade.friendsLoaded$
.pipe(
filter(res => !res),
takeUntil(this.unsubscribe$)
浏览 1提问于2020-12-30得票数 0
在这种情况下，我对代码流感到有点困惑。请参考下面的代码。
import { fromEvent } from 'rxjs';
import { mapTo } from 'rxjs/operators';
let btn = document.getElementById("btnclick");
let btn_clicks = fromEvent(btn, 'click');
let positions = btn_clicks.pipe(mapTo ("Testing MapTo"));
positions
浏览 3提问于2020-06-06得票数 1
回答已采纳
1回答
角:不改变订阅函数的全局变量
、、、、
我在用TypeScript改变角7中的全局变量时遇到了问题。
我正在使用一个服务，它通过Restful从数据库收集JSON数据
服务:
export class myService {
constructor(private client : HttpClient) { }
dossierSubject = new Subject();
private dossiers : any[];
getExtract(){
this.client.get<any[]>('http://localhost:9090/dossiers')
.
浏览 1提问于2019-04-26得票数 3
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
回答已采纳
3回答
我正在使用displayWith指令在我的垫-自动完成.当我手动选择值时，它工作得很好，但是当我重新加载页面时，我没有得到翻译。转换所需的参数是从ngOnInit中的查询参数异步加载的。所以我依赖于异步参数，但是我的displayFunction()是同步函数。如何解决这个问题？
没有displayWith函数，一切都正常，但是没有翻译(它只是显示我不想要的纯值)。所以我确信剩下的代码是正确的。
我的垫子-自动完成：
<mat-form-field [formGroup]="cityForm"
appearance="outline
浏览 1提问于2019-03-07得票数 5
回答已采纳
1回答
我正在努力做一个订阅工作，但没有任何结果。
这样做的目的是让一个简单的RoutingService订阅一个AuthService，因为我希望路由/导航发生在AuthService之外。当AuthService中发生更改(登录/注销)时，我希望向RoutingService发送一个事件，并根据结果导航到某个组件。
在添加代码之前，我一直在对其他帖子进行一些研究。以下是你现在想到的一些问题的答案：
我的所有服务只在根模块中声明一次，因此它们是一个单例。我没有任何其他带有提供者元素的服务/模块
我试着用主语，ReplaySubject和BheaviourSubject，同样的结果.
浏览 0提问于2018-03-14得票数 0
我有以下代码(来自演示应用程序)：
stompClient.connect({}, function(frame) {
setConnected(true);
console.log('Connected: ' + frame);
stompClient.subscribe('/user/queue/greeting', function(greeting) {
displayQueueMessage(greeting);
});
fun
浏览 6提问于2014-07-09得票数 5
我有以下代码： repo.getObservable()
.timeout(1, TimeUnit.MINUTES)
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.doOnSubscribe {
_isInProgress.value = true
}
.doFinally {
_isI
浏览 41提问于2019-12-19得票数 2
回答已采纳
1回答
我正在开发一个使用蓝牙的应用程序(离子)。
我有几个页面可以连接到我的设备。所以我创建了一个服务来管理连接。
这是我的服务：
public async bleConnexion(device) {
this.loader = await this.loadCtrl.create({
message: "Connexion ..."
})
this.loader.present();
setTimeout(async () => {
if (this.isConnected == false) {
this.displayError();
浏览 1提问于2020-10-30得票数 0
1回答
我有一个定义如下的函数：
public function subscribe($someQueue)
{
$callback = function($msg){
return $msg->body;
};
$this->channel->basic_consume( $someQueue, '', FALSE, TRUE, FALSE, FALSE, $callback);
while(count($this->channel->callbacks)) {
$this->cha
浏览 1提问于2015-12-29得票数 1
回答已采纳
2回答
困惑于在峡谷中延迟
、、、
我看到了下面的代码片段，它演示了sync.Cond中的“广播”功能。代码片段如下：
package main
import (
"fmt"
"sync"
)
func main() {
type Button struct {
Clicked *sync.Cond
}
button := Button{Clicked: sync.NewCond(&sync.Mutex{})}
subscribe := func(c *sync.Cond, fn func()) {
va
浏览 1提问于2020-02-04得票数 1
回答已采纳
// I试图从订阅外部获取值，但它不能将值赋值给任何变量。在我的项目中，使用http.post()方法获取json内容，并将其分配给一个变量。我想在构造函数..How之外访问这些变量值，我能让它成为可能吗？
ngOnInit(): void {
this.getSubscription();
}
// here is my subscription function
getSubscription() {
interval(5000)
.pipe(
startWith(0),
switchMap(() => this
浏览 1提问于2018-06-22得票数 3
回答已采纳
3回答
角度可观测性首先需要完成
、、、、
@Input() list: string[];
ngOnInit() : void {
this.valueMap = new Map<any, any>();
this.getDataFromService();
this.buildContainer();
}
private getDataFromService(): void {
this.list.forEach(value-> {
this.fetchService(value).subscribe(data ->{
this.valueMap.se
浏览 6提问于2020-07-16得票数 2
回答已采纳
2回答
订阅后返回json中的数据
、、、、
我使用的是角5，并希望在订阅服务后以json格式从函数getDionaeaResults返回数据。
getDionaeaResults(sql) : any {
this.dionaeaService.getDionaeaConnectionLogs(sql).subscribe(res => {
this.data = res;
}),
(error: any) => {
console.log(error);
});
return this.data
浏览 0提问于2018-04-10得票数 0
回答已采纳
2回答
在我的角度UI中，我从API网关调用端点，如：
this.http.post(`/order`).subscribe(order => addNewOrderToList(order));
根据微服务中的最佳实践，/order处理程序应该发布一个由一个或多个微服务使用的事件，而不是使用同步REST相互调用。因此，我编写了以下处理程序：
@RequestMapping
public Future<Order> addOrder() {
CompletableFuture<Order> future = new CompletableFuture<>(
浏览 2提问于2017-12-12得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
