英文:
Parse Angular Http Reponse And Handle Json
问题
显示 = 响应 => {console.log(响应);};
导入 { Component, OnInit, OnDestroy } 自 '@angular/core';导入 { HttpClient } 自 '@angular/common/http';导入 { of, Subject } 自 'rxjs';导入 { delay, tap, mergeMap, repeat, takeUntil } 自 'rxjs/operators';
export class AppComponent 实现 OnInit, OnDestroy {私有 ngUnsubscribe = 新 主体<void>(); // 用于取消订阅的主体构造函数(private http: HttpClient) { }callOmni = () => of(this.pollOmni()).pipe();显示 = 响应 => {console.log(响应);};轮询 = of({}).pipe(mergeMap(_ => this.callOmni()),tap(this.display),延迟(10),重复(),takeUntil(this.ngUnsubscribe) // 当 ngUnsubscribe 发出时取消订阅);pollOmni() {返回 this.http.post<any>('http://127.0.0.1:8044/api', { call: 'getInfo' });}ngOnInit() {this.poll.subscribe();}ngOnDestroy() {this.ngUnsubscribe.next(); // 发出值以取消进行中的订阅this.ngUnsubscribe.complete(); // 完成主体}}
英文:
I have a code that calls http post and recieves the observable notification when data is recieved .
I wish to know how to get the json respose from the server in the following function since when I try to print it it only shows the observable and not the actual json returned from the server:
display = response => {console.log(response);};
The complete code is :
import { Component, OnInit, OnDestroy } from '@angular/core';import { HttpClient } from '@angular/common/http';import { of, Subject } from 'rxjs';import { delay, tap, mergeMap, repeat, takeUntil } from 'rxjs/operators';@Component({selector: 'app-root',templateUrl: './app.component.html',styleUrls: ['./app.component.css']})export class AppComponent implements OnInit, OnDestroy {private ngUnsubscribe = new Subject<void>(); // Subject for unsubscribingconstructor(private http: HttpClient) { }callOmni = () => of(this.pollOmni()).pipe();display = response => {console.log(response);};poll = of({}).pipe(mergeMap(_ => this.callOmni()),tap(this.display),delay(10),repeat(),takeUntil(this.ngUnsubscribe) // Unsubscribe when ngUnsubscribe emits);pollOmni() {return this.http.post<any>('http://127.0.0.1:8044/api', { call: 'getInfo' });}ngOnInit() {this.poll.subscribe();}ngOnDestroy() {this.ngUnsubscribe.next(); // Emit value to unsubscribe from ongoing subscriptionsthis.ngUnsubscribe.complete(); // Complete the subject}}
答案1
得分: 0
错误在于 callOmni = () => of(this.pollOmni())。
this.poolOmni 已经返回一个可观察对象，而您在其中再次使用 of 包装了一个可观察对象。
如果直接调用 poolOmni，代码应该能正常工作。
英文:
The error is in callOmni = () => of(this.pollOmni()).
this.poolOmni already returns an observable, which you are wrapping in another observable with of.
If you call directly poolOmni the code should work fine
通过集体智慧和协作来改善编程学习和解决问题的方式。致力于成为全球开发者共同参与的知识库，让每个人都能够通过互相帮助和分享经验来进步。
评论