如何在Angular中重新执行订阅的Observable
在Angular中重新执行订阅的Observable可以通过以下步骤实现：
- 首先，确保你已经导入了
rxjs库中的Observable类和其他相关操作符。 - 创建一个
Subject对象，它可以作为一个可观察的数据源，并且可以被多个订阅者订阅。
import { Subject } from 'rxjs';
// 创建一个Subject对象
const dataSubject = new Subject<any>();- 在需要重新执行订阅的地方，调用
next()方法来发送新的数据。
// 发送新的数据
dataSubject.next(newData);- 在订阅Observable的地方，使用
subscribe()方法来订阅dataSubject。
// 订阅dataSubject
dataSubject.subscribe((data) => {
// 处理接收到的数据
});这样，每当调用next()方法发送新的数据时，订阅者就会收到更新后的数据。
对于Angular中的具体应用场景，可以根据具体需求来决定何时重新执行订阅的Observable。例如，在组件的生命周期钩子函数中，可以在ngOnInit()中进行初始订阅，然后在ngOnChanges()中重新执行订阅以响应输入属性的变化。
推荐的腾讯云相关产品和产品介绍链接地址：
- 腾讯云云服务器（CVM）：提供弹性计算能力，满足各种业务需求。产品介绍链接
- 腾讯云云数据库MySQL版：可扩展的关系型数据库服务，提供高性能、高可用的数据库解决方案。产品介绍链接
- 腾讯云对象存储（COS）：安全、稳定、低成本的云端存储服务，适用于图片、音视频、文档等各种类型的数据存储。产品介绍链接
请注意，以上推荐的腾讯云产品仅供参考，具体选择应根据实际需求和项目要求进行评估。
相关·内容
我在一个服务中有以下函数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
回答已采纳
1回答
我正在致力于一个角2应用程序，并需要一些指导如何处理身份验证错误干净。
我的最终目标是能够集中处理每个Http请求的身份验证错误(特别是401和403)。
我发现问题对我的开始非常有帮助，但是我仍然坚持用正确的方式为我的自定义Http实现返回的每个可观察到的错误处理程序注册。
下面是我目前正在处理的一个示例：
import { Injectable } from 'angular2/core';
import { Http, ConnectionBackend, Request, RequestOptions, RequestOptionsArgs, Response } fr
浏览 0提问于2016-01-28得票数 28
回答已采纳
我想创建一个可以在Angular 6中传递一些参数的observale。下面是在Angular site 中创建observable的示例代码，但它没有解释如何传递任何参数。
// Create an Observable that will start listening to geolocation updates
// when a consumer subscribes.
const locations = new Observable((observer) => {
// Get the next and error callbacks. These will be pas
浏览 0提问于2018-09-20得票数 6
回答已采纳
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
4回答
如何从包含使用html的数组的可观察到的值中获取单个值。我正在运行Angular2 w/类型记录
打字脚本
private observable = Observable.of([1,2,3,4,5])
html
<p>{{observable[2]}}</p>
，即得到可观察到的索引2中的数组元素。
浏览 3提问于2017-04-21得票数 1
回答已采纳
我正在用Angular 5编写一个应用程序，我想在他们自己的服务中保留原始的http调用，这样其他服务就可以根据需要处理响应。例如，我将拥有一个组件、组件服务和组件数据服务。
如何将我的观察值与此模式链接起来？以下是我尝试过的方法：
licenseData.service.ts
import { Injectable } from '@angular/core';
import { HttpClient, HttpParams, HttpErrorResponse } from '@angular/common/http';
import { CONSTANT
浏览 16提问于2018-07-31得票数 0
我试图在组件模板中显示http调用响应数据。
我试图从从服务返回到组件的可观察到的对象数据中提取对象数据。我使用了.subscribe方法，我得到了“类型‘订阅’不可分配到键入DataModel。属性‘权利’在订阅类型中缺失”。
不知道我哪里出了问题。请告知-
我的模型文件：-
export class DataModel {
public entitlement: string;
public serviceId: string;
public techType: string;
public avcId: string;
浏览 0提问于2018-01-18得票数 0
回答已采纳
2回答
我正在开发我的第一个Angular 2产品。我创建了这个Observable.timer，然后订阅了它。它轮询服务器上的数据。
如何暂停和取消暂停？
ngOnInit(): void {
this.poll = Observable.timer(500,500).subscribe((t: any) => {
this.request.getRackList(+this.global.zoneId).subscribe(
incoming => this.import(incoming),
err => { this.g
浏览 2提问于2017-02-08得票数 3
回答已采纳
2回答
亲爱的，
我被困住了，我遵循了关于http.get和可观察的简单http.get教程，但是我无法在视图中呈现数据。
我的服务：
import { Injectable } from "@angular/core";
import { HttpClient } from "@angular/common/http";
import { Observable } from "rxjs";
import { map } from "rxjs/operators";
const baseUrl = "http://localho
浏览 5提问于2020-05-17得票数 0
回答已采纳
在一个angular http客户端observable进行网络调用之前，但在实际的函数被调用之后，如何编写一些代码？下面是angular http服务调用
this.geocodeApi.getAddressSuggestions(address).subscribe(resp => {..});
但是我们该怎么做呢？
this.geocodeApi.getAddressSuggestions(address).before({CODE HERE}).subscribe(resp => {..});
浏览 2提问于2018-03-13得票数 2
我有getNewToken和hasTheUserTokenOrPermission方法。第一个返回token并设置用户数据，第二个在我们设置用户数据后进行检查-如果他有权限查看守卫中的某些内容。 所以我需要等待第一个结果，然后检查是否有权限。我需要从canActivateGuard返回true或false。 所以这个问题可以用promise pattern这样来解决 import { Injectable } from '@angular/core';
import { ActivatedRouteSnapshot, CanActivate, RouterStateSnaps
浏览 25提问于2021-04-13得票数 0
1回答
你知道解决我的问题的办法吗？我需要一个灵活的订阅序列封装在一个可以观察到的，这里：
saveData() {
return new Observable((observer) => {
let success = true;
if(example === true) {
this.saveCallbarrings().subscribe((response) => {
// this response was ignored from angular
success = (response =
浏览 6提问于2017-05-03得票数 1
回答已采纳
我是Angular的新手，但我会做一件非常简单的事情(我不能做)...I想要创建一个‘基础服务’，它与我的api后端通信，但在设置一些东西(头部，变量...所以)……所有其他服务都必须调用此“基本服务”才能与我的代码api...here通信：
import { Injectable } from '@angular/core';
import { HttpClient, HttpRequest, HttpHeaders, HttpParams, HttpResponse } from '@angular/common/http';
import { Observ
浏览 0提问于2017-11-23得票数 0
2回答
下面是可以在上运行的Angular组件的代码
@Component({
selector: 'my-app',
template: `
<div *ngIf="currentNumber$ | async as currentNumber">
<b>{{currentNumber}}</b>
</div>
<form [formGroup]="simpleForm">
<input type="number" formContr
浏览 0提问于2018-02-06得票数 1
1回答
角2解析只工作一次
、、、、
我试图做出一个简单的决定，返回一个用户。但是，在我的应用程序中，我需要用我自己的类包装http组件，它返回一个可观察的主题。My Resolver在第一个用户链接上按预期工作，但在解析后单击UserProfileComponent中的任何用户链接时，解析永远不会第二次完成。UserProfileComponent我可以看到浏览器URL随新ID的变化，以及UserResolve打印的console.log，但什么也没有发生。
我的路由器：
import { Routes, RouterModule } from '@angular/router';
import { Dashbo
浏览 4提问于2017-02-07得票数 7
回答已采纳
我是新的angular2，所以请忽略如果你发现它的基本问题。
我有一个Observable类型的变量
users: Observable<User[]>;
在构造函数中，我正在填充它
constructor(private roleService: RoleService, private userService: UserService) {
this.users = this.userService.getAllUsers();
}
现在我想操作/迭代this.users的数据。我该怎么做呢？
浏览 4提问于2017-02-20得票数 0
回答已采纳
3回答
最初，我有一个函数，它简单地检查令牌的存在，如果它不存在，就将用户发送到登录头。现在，我需要在令牌到期时在刷新令牌的帮助下实现刷新令牌的逻辑。但我得到了一个错误401。刷新函数没有时间工作，拦截器中的工作进一步出错。如何修正代码，使我可以等待刷新完成，获得一个新的令牌，而不是重定向到登录页面？
TokenInterceptor
import {HttpErrorResponse, HttpEvent, HttpHandler, HttpInterceptor, HttpRequest} from "@angular/common/http";
import {Injectabl
浏览 1提问于2018-10-24得票数 4
调用不工作，因为升级在RXjs版本6是合并在角version8。有关完整的源代码，请参阅：-
import { Component } from '@angular/core';
import {ServicexampleService} from './servicexample.service';
@Component({
selector: 'app-root',
templateUrl: './app.component.html',
styleUrls: ['./app.component.cs
浏览 0提问于2019-08-01得票数 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
回答已采纳
1回答
我使用的是角4+，并且我注意到在可观察到的解析立即(同步地？)调用Observable.subscribe()之前，角没有更新绑定的值。在其他地方，这很好，因为网络调用将可观察到的完成延迟足够长时间，使初始绑定变化以角形式生效。
//our root app component
import {Component, VERSION} from '@angular/core';
import {Observable} from 'rxjs/Observable';
import 'rxjs/add/observable/of';
import &
浏览 1提问于2018-04-18得票数 2
回答已采纳
我正在用angular2开发应用程序，这里我使用消息广播将数据从一个组件更新到另一个组件。
这是代码，message_event.ts
import {Injectable} from '@angular/core';
import {Observable} from 'rxjs/Observable';
import {Broadcaster} from './broadcaster';
@Injectable()
export class MessageEvent {
constructor(private broadcaster: B
浏览 4提问于2017-09-05得票数 1
5回答
在我的角5应用程序中，需要在应用程序的不同位置多次使用特定的数据集(而不是经常更改)。调用API之后，结果将使用可观察的do操作符存储。通过这种方式，我在服务中实现了HTTP请求的缓存。
我用的是角5.1.3和RxJS 5.5.6。
这是个很好的练习吗？有没有更好的选择？
import { Injectable } from '@angular/core';
import { HttpClient } from '@angular/common/http';
import { Observable } from 'rxjs/Observable'
浏览 8提问于2018-04-12得票数 22
回答已采纳
2回答
这里有组件代码，当我订阅可观察到的服务时，这个服务会被调用两次，但是如果我订阅了行为主题，它只被触发一次，
我可以在我的日志中看到这些结果，请查看我的组件下面的代码--在ngOninit上调用方法ngOninit()方法。
import { Component, OnInit } from '@angular/core';
import { Router } from '@angular/router';
import { Observable } from 'rxjs/Observable';
import
浏览 0提问于2017-08-16得票数 5
回答已采纳
在这件事上我一直在绞尽脑汁。有没有人知道下面Angular 2 typescript代码块中的订阅者是什么类型？
let obs: Observable<string> = Observable.create((subscriber) => { ... })
浏览 0提问于2015-11-18得票数 2
回答已采纳
我在我的平台中实现了一个WebSockets连接。我在前端使用Angular 10，在SockJS Client 1.5.0上使用StompJS 2.3.3来建立到后端的连接。
我创建了一个WebSockets服务来管理连接，它正在连接，并且工作正常。
这是我创建的服务：
export class WebSocketsService implements OnDestroy {
/**
* The authentication service to get the token from.
*/
private authenticationService: Aut
浏览 0提问于2021-02-18得票数 4
为什么ActivatedRoute in @angular\router params is observable？
我想知道我为什么要订阅Params？为什么params是异步的，是否会创建路由的组件集，但是params仍然没有被填充？
有没有一种不用observable就能得到值的方法？
浏览 1提问于2016-11-13得票数 15
回答已采纳
我知道如何使用模拟后端以及promises来测试http。尽管我正在努力寻找一个解决方案来测试promise中的http方法。任何建议都将不胜感激。下面是包含promise中带有http方法的函数的函数：
import { Injectable } from '@angular/core';
import { AbstractControl, FormGroup, FormControl, ValidatorFn, AsyncValidatorFn } from '@angular/forms';
import { Headers, RequestOptions
浏览 0提问于2018-01-31得票数 0
1回答
我有一个关于Angular2+ Observable如何处理Http错误的问题。当我们使用Angular2+ Http进行请求时，如果返回的响应有错误状态码，就会抛出错误。
在Angular2官方启动器项目中，需要调用的错误处理函数：
someObs.catch(handler)
在处理程序中，它实际上返回：
Observable.throw(...)
我的问题是，这不会抛出新的错误，可能会导致web应用程序崩溃吗？因为在Javascript中，如果你抛出一些错误，web应用程序可能会出现意想不到的行为。
我对Observable.catch的理解是，当一些错误发生时，我们捕获它，然后做一些其
浏览 2提问于2017-07-12得票数 1
我正在尝试检查单选按钮，但它不工作，下面是我的代码我的模板，
<form [formGroup]="form" (ngSubmit)="onSubmit(form.value)">
<label class="control-label">ACCESS SETTINGS</label>
<input id="radio-2" [formControl]="form.controls['status']" value = 1
浏览 6提问于2016-09-21得票数 0
我试图让这个组件从返回可观察到的服务中获取字符串数据。
import { Component, OnInit, OnDestroy } from '@angular/core';
import { TabFourService } from "./tabfour.service";
import { Subscription } from "rxjs";
@Component({
selector: 'tab-four',
template: `
{{title}}
浏览 3提问于2016-10-20得票数 3
3回答
我在我的Angular 7应用程序中包含了一个功能模块的路由。属于此功能的组件需要获取路由参数。我该怎么做呢？ 我尝试使用文档中显示的方法，如下面的代码所示。我已经评论了哪种方法有效，哪种方法不起作用。我想使用第二种方法，它不起作用，因为它将结果映射到我将在模板中使用的products$可观察对象。可能的问题是什么？ import { Component, OnInit } from "@angular/core";
import { ActivatedRoute, ParamMap } from "@angular/router";
import { Obs
浏览 26提问于2019-03-23得票数 0
回答已采纳
2回答
在角应用程序中，从服务器获取数据有不同的方法：
从服务中获得可观察性，并在组件上订阅它
在服务中创建主题，在组件上订阅主题
这两种方法都适用于我，但我不知道该用哪种方法。
First method.从服务中获得可观察性，并在组件上订阅它
article.service.ts
import { Injectable } from '@angular/core';
import { Article } from '../models/article';
import { AngularFirestore } from '@angular/fi
浏览 0提问于2019-08-24得票数 3
回答已采纳
我为我的angular应用程序创建了一个帐户服务，它处理登录和注销。这个很好用。但是我有一个问题，我使用BehaviourSubject观察值来渲染变量。
我正在尝试检索loginstatus值和使用该服务的组件上的用户名字符串，但observable返回了一个对象，而我在从对象中提取字符串时遇到了问题。如何从Behavioursubject可观测数据中提取变量类型？
帐户服务...
import { Injectable } from '@angular/core';
import { HttpClient } from '@angular/common/http&#
浏览 70提问于2019-07-17得票数 0
可观察到的getHero服务在NgOnInIt中没有在HeroDetail组件中被调用。
我可以使用HTTP获取和显示数据表，并在单击行时将其路由到详细信息页。然后，我使用url的" id“参数来获取id，但这与getHero函数无法获得特定的行详细信息是相同的。
ID显示在控制台中，而英雄则是未定义的。我试过很多东西，但到目前为止都没有用。任何帮助都将不胜感激。
下面是我的代码供参考。
hero.service.ts
import { Injectable } from '@angular/core';
import { Http, Resp
浏览 3提问于2017-04-13得票数 4
回答已采纳
当我使用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回答
我正试着打http电话，如果会有任何错误，做我的事情。
这是我的代码：
import { Injectable } from '@angular/core';
import { Http, Response } from '@angular/http';
import { Observable } from 'rxjs/Observable';
import 'rxjs/add/observable/throw';
// Operators
import 'rxjs/add/operator/catch';
浏览 0提问于2016-12-05得票数 0
回答已采纳
角6应用程序，我尝试使用一些GET请求，同时注入一些Header：
My service如下所示：
@Injectable()
export class MyService {
constructor(public httpClient: HttpClient) {
}
getUserInfos(cuid): Observable<any> {
const headers = new HttpHeaders({'login': login});
return this.httpClient.get(environment.urls.UserHabil
浏览 0提问于2018-07-19得票数 1
io.reactivex.rxjava2:rxjava:2.1.13
kotlin_version = '1.2.30'
我有以下可观察到的，并且我试图抛出一个异常来测试OnError中异常的捕获。但是，当我将以下内容传递给onExceptionResumeNext(Observable.just(10))时，会得到以下输出：
1
2
10
onComplete
fun main(args: Array<String>) {
Observable.fromArray(1, 2, 0, 4, 5, 6)
.doOnNext {
浏览 1提问于2018-05-29得票数 3
回答已采纳
当我从这个页面导航到另一个页面时，我需要停止Observable.timer。下面是我在我的项目中使用的代码。
import { Component, ChangeDetectorRef, OnDestroy } from '@angular/core';
import { NavController, MenuController } from 'ionic-angular';
import {Observable, Subject}from 'RxJs/Rx';
export class SettingsPage extends BaseP
浏览 4提问于2017-03-06得票数 0
在文件auth-guard-service.ts，中，为什么在打印警报消息时调用this.router.navigateByUrl(‘/登录’)不工作？另一个文件(auth.service.ts)中的另一个调用工作正常。
auth-guard-service.ts
import { Injectable } from '@angular/core';
import { CanActivate, Router } from '@angular/router';
import { Observable } from 'rx
浏览 5提问于2017-08-17得票数 3
回答已采纳
我跟随英雄的角度巡回演出，并以相同的方式构造了(我认为)我的代码版本，但没有收到我期望的行为。
我的服务
import { Injectable } from '@angular/core';
import { PORTS } from './mock-ports'
import { Port } from './port'
import { Observable, of } from 'rxjs';
import { HttpClient, HttpHeaders } from '@angular/common/http
浏览 0提问于2020-04-30得票数 0
回答已采纳
3回答
角2搜索
、
我试图使用一个搜索框来过滤一个使用角2的项目列表，但是当我在搜索框中输入一些内容时，它不会在服务上触发搜索方法。我知道我可能错过了一些简单的东西，但任何帮助都会很感激。
company.service.ts:
import { Injectable } from '@angular/core';
import { Headers, Http, Response } from '@angular/http';
import { Observable } from 'rxjs/Observable';
import 'rxjs/add
浏览 1提问于2016-10-24得票数 0
回答已采纳
2回答
我希望创建一个服务方法，该方法在第一次执行时将从URL中获取数据集，缓存数据集，然后与随后调用服务方法的组件共享数据集的同一个实例。
我已经开始创造两种解决方案。这两种解决方案的问题是，在加载角应用程序后的第一毫秒内，它们多次从URL中获取数据集，并/或向控制台抛出一些错误消息，但在两个组件之间进行第一次或第二次导航之后，数据似乎被正确地共享，并且不再有返回URL的往返。
方法1
import { Injectable } from '@angular/core';
import { HttpClient } from '@angular/common/http'
浏览 7提问于2020-06-21得票数 0
回答已采纳
下面的代码创建每秒钟传递当前Date的Date。从下面的代码中，我看到Observable<Date>是从ObservableService返回的&在AppComponent中立即订阅。虽然Observable<Date>没有作为类内部变量保存在AppComponent中，但是应用程序继续接收通知，并且GC没有收集返回的Observable<Date>。
我的问题是，为什么是这样，为什么当没有对象引用或捕获Observable<Date>时，没有收集/删除它？这里我的主要假设是AppComponent：data => this.cu
浏览 2提问于2019-12-01得票数 2
2回答
我用的是棱镜和火药库。我在检查我的路线守卫里面的消防站的价值。
我发现在页面刷新时，它返回为未定义的。然而，如果我只是硬编码返回的真或假，它是有效的。
if语句中的任何日志总是正确返回，但由于某种原因似乎没有更新全局变量。
如果我使用我的网站导航回到根目录，并浏览我的网站，它是正确的工作。但是，当我刷新页面时，它会以未定义的形式返回。
这会是一个范围界定的问题吗？
路由保护
import { Injectable } from '@angular/core';
import { ActivatedRouteSnapshot, RouterStateSnapshot, CanAc
浏览 0提问于2018-01-12得票数 1
回答已采纳
3回答
管道和Tap与使用ngxs的订阅
、、、、
我在玩弄管道和订阅。如果我使用带水龙头的管道，则不会在控制台中登录任何内容。如果我使用的是subscribe，它就能正常工作。那么我做错了什么呢？
import { Observable } from 'rxjs';
import { tap, take } from 'rxjs/operators';
this.store.select(state => state.auth.authUser).pipe(
take(1),
tap((data) => {
//Not Working - no console output
浏览 8提问于2018-05-19得票数 13
回答已采纳
4回答
如何只订阅一次可观察数据
、、、
我尝试订阅两个observable并获取要存储在数组对象中的值。它工作得很好，但我的问题是它迭代了三次，我不明白。我在一个服务中这样做是为了创建一个新服务。下面是示例代码。我还想知道在angular中是否可以使用promise而不是observable？或者，我可以在获得值后将观察值转换为promise和resolve吗？感谢您的帮助 addEmployeeData() {
const employeeObservable = this.apiService.getEmployeeDataObservable();
employeeObservable.subscribe({
浏览 67提问于2021-03-01得票数 1
我正在使用Observable.zip并行处理几个可观察到的数据。
Observable.zip(observable1, observable2).subscribe(([res1, res2]) => doStuff())
这里observable1和observable2是http请求，我有一个拦截器捕获错误。
import { Injectable } from '@angular/core';
import {
HttpInterceptor,
HttpHandler,
HttpRequest,
HttpErrorResponse
浏览 0提问于2018-06-29得票数 1
回答已采纳
1回答
我有一个问题，当使用最新版本的rxjs与角6。代码；
import { Observable, throwError } from "rxjs";
import { map, filter, catchError, mergeMap } from 'rxjs/operators';
isValidUser(user, password) : Observable<any> {
let urlString = "http://localhost....=" + user + "&password=" + pa
浏览 0提问于2018-06-14得票数 2
回答已采纳
我正在用angular 10做一个登录应用程序，现在我需要以某种方式访问数据，但我不确定如何访问。
这就是我获取数据的地方。"getUsers“方法获取所有数据。
import { Injectable } from '@angular/core';
import { BehaviorSubject, Observable } from 'rxjs';
import { HttpClient } from '@angular/common/http';
import { LoginModel } from '../models/l
浏览 0提问于2020-12-07得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
