在相同的值上未调用可观察订阅
是指在使用可观察对象（Observable）进行编程时，如果没有调用订阅（subscribe）方法来订阅该可观察对象，那么该可观察对象将不会执行任何操作或发出任何事件。
可观察对象是一种用于处理异步数据流的编程概念，它可以用于前端开发、后端开发以及其他领域的应用程序中。通过订阅可观察对象，我们可以监听并处理该对象发出的事件或数据，从而实现对异步操作的控制和处理。
在未调用可观察订阅的情况下，可观察对象不会执行任何操作，因为没有订阅者来监听它发出的事件。这意味着，如果我们没有调用订阅方法，就无法获取到可观察对象发出的数据或事件，也无法对其进行进一步的处理。
在实际开发中，未调用可观察订阅可能是由于开发人员的疏忽或者意外造成的。为了避免这种情况，我们通常需要在使用可观察对象时，及时调用订阅方法来订阅该对象，以确保能够获取到所需的数据或事件，并进行相应的处理。
腾讯云提供了一系列与云计算相关的产品和服务，其中包括云服务器、云数据库、云存储等。这些产品可以帮助开发者快速构建和部署各种应用程序，并提供高可用性、可扩展性和安全性。
以下是腾讯云相关产品和产品介绍链接地址：
- 云服务器（ECS）：提供弹性计算能力，支持多种操作系统和应用场景。了解更多：云服务器产品介绍
- 云数据库（CDB）：提供高性能、可扩展的数据库服务，支持多种数据库引擎。了解更多：云数据库产品介绍
- 云存储（COS）：提供安全可靠的对象存储服务，适用于存储和处理各种类型的数据。了解更多：云存储产品介绍
通过使用腾讯云的产品和服务，开发者可以更加专注于应用程序的开发和业务逻辑，而无需过多关注底层的基础设施和运维工作。
相关·内容
有人能解释一下可观察对象和ConnectableObservable之间的区别吗？Rx扩展文档非常稀疏，我不明白ConnectableObservable在什么情况下是有用的。
这个类在Replay/Prune方法中使用。
浏览 2提问于2010-05-14得票数 40
回答已采纳
在Hello示例中，有一个订阅者
public static void main(String[] args) {
Flowable.just("Hello world").subscribe(System.out::println);
}
怎么做两个或更多？
浏览 1提问于2017-01-24得票数 1
回答已采纳
所以，基本上，rxjs是新的，想知道，
我是否需要从Observable.of(数据)或更新的rxjs版本中取消订阅(数据)？
即
import {of} from 'rxjs';
const sub = of(data).subscribe();
这有必要吗？
sub.unsubscribe();
浏览 2提问于2019-04-28得票数 6
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
回答已采纳
3回答
假设我有一个事件发射数据源，我想将其转换为反应性流。数据源被资源绑定(例如，定期发送更新状态的套接字)，因此我希望共享该资源的单个订阅。使用replay (对于新订阅者立即获得当前值)和refCount操作符似乎非常适合于此。例如，这是他的MyDataProvider单例的样子：
private final Observable<MyData> myDataObservable = Observable.<MyData>create(emitter -> {
// Open my resource here and emit data into obser
浏览 0提问于2018-05-18得票数 7
回答已采纳
2回答
我正在用下面一个简化的测试用例复制我的Rx问题。下面的测试挂起了。我确信这是一个小的，但基本的，我缺少的东西，但不能把我的手指放在它上。
public class Service
{
private ISubject<double> _subject = new Subject<double>();
public void Reset()
{
_subject.OnNext(0.0);
}
public IObservable<double>
浏览 1提问于2019-12-05得票数 2
回答已采纳
我有个折页代码：
this.http.post('http://localhost:8080/api/login',
JSON.stringify({ username, password }),
{ headers }
)
这不起作用，我甚至没有在浏览器控制台中看到一个错误。当只使用‘api/登录’时，它可以工作，但当然是在错误的域上。文档只想要一个url，这里是否有CORS问题或其他限制，谢谢您的帮助？
浏览 1提问于2016-12-09得票数 0
回答已采纳
1回答
当我需要在角度分量中访问数据时，从可观测流中访问数据的最佳方法是什么？我知道我可以在模板中使用异步管道，但是我需要访问实际组件中的数据。
到目前为止，我已经通过点击或订阅将数据提取到一个新变量中，但我只是好奇是否缺少一种更简单或更简洁的方法。如果没有，在tap和订阅之间是否有首选的方法？
//assume db.getBook() returns an observable with a book object
this.subscription = db.getBook("153").pipe(
tap(book => this.book = book).s
浏览 3提问于2019-09-29得票数 1
回答已采纳
1回答
我使用角度行为受制于发射的两个子components.Those组件之间的值是在无限页面(父组件)滚动的一部分。
Emiiter服务：
export class emitDataService {
private productColorUpdate = new BehaviorSubject<any>(null);
private productVariantUpate = new BehaviorSubject<any>(null);
getCurrentProductColor = this.productColorUpdate.asObservabl
浏览 3提问于2021-08-07得票数 0
我有服务。它包含以下功能(简化)：
private _eventListener$: BehaviorSubject<boolean> = new BehaviorSubject<boolean>(false);
push(field?: FormField): void {
this.isAlive = true;
this._eventListener$.pipe(
debounceTime(3500),
takeWhile(() => this.isAlive)
).subscribe(() => {
浏览 14提问于2022-11-23得票数 0
回答已采纳
我可以在html中使用{status_async | async}显示一个可观察到的值。
然而，我如何测试这个可观察到的东西是否等于某物呢？
具体来说，我想使用它来分配一个类：
<div [ngClass]="{'has-danger': status_async == 'created before'}">
<input type="text">
</div>
我发现我可以用：
<div [ngClass]="{'has-danger': (status_
浏览 3提问于2016-02-21得票数 2
回答已采纳
Angular2 2.0.0-beta.15，Rxjs 5.0.0-beta.2
我有两个简单的rxjs可观测值，一个是共享的，一个不是(.share()调用的)
我有一个angular2组件，它订阅两个可观测值，并在其模板中显示值，该模板还使用异步管道订阅可观测数据。
我单击一个按钮，用一些垃圾在两个可观察到的位置上设置.next()。
模板更新并显示每个值的最新值。组件中的订阅函数不会为不可见的非共享对象触发。为什么？
柱塞：
@Component({
selector: 'my-app',
template: `
<div>
浏览 1提问于2016-04-14得票数 1
回答已采纳
在学习Rx的过程中，我遇到了一个经常重复的关于可观察性的规则，这个规则在中得到了阐述。
在发出OnCompleted或OnError通知时，此后不得再发出任何通知。
这对我来说很有意义，因为让一个可观察的人在它完成后继续生成值会让人困惑，但是当我用Observable.Range方法在.NET中测试时，我注意到它没有表现出这种行为，事实上许多可观察到的都违反了这个规则。
var rangeObservable = Observable.Range(0, 5);
rangeObservable.Subscribe(Console.WriteLine, () => Console.
浏览 5提问于2016-12-30得票数 2
回答已采纳
1回答
冷热观测-最后一次刷新值
、、、
我有一个场景，我想从服务器获取一些数据，并且用户可以请求刷新这些数据。页面的其余部分需要更新以反映当前加载的数据迭代。
我想象一下，在这里，我有一个可以观察到的热点，可以发布它加载的数据。我不想将数据的所有旧迭代保留为1，我只关心数据的最新迭代，2.如果用户在给定的会话中进行足够的刷新，可能会导致内存不足的异常。
但是，我确实希望保留上一个已发布的值，这样如果我动态地打开一个需要访问相同数据的新组件，它就不会发出不必要的新请求。为此，我需要一个可观察的坐在热可观测的顶部，这将只保留和释放来自热可观测的最后的排放。这里有一个图表说明了这个想法：
dataStream X - - - -
浏览 0提问于2016-03-16得票数 1
回答已采纳
我想知道这两个函数之间是否有什么区别：
function testObservable(message: string) : Observable<string>{
return new BehaviorSubject(message);
}
function testObservable(message: string) : Observable<string>{
return of(message);
}
我在AsyncValidatorFn中返回一个AsyncValidatorFn，我得到了不同的行为，如果我返回of(T)
更新-验证代
浏览 3提问于2019-10-24得票数 0
回答已采纳
我不太清楚可观察和订阅是如何工作的。特别是一个可观察的和它的订阅是如何交换信息的。
因此，要提出明确的问题：
可观察到的用户是否保留对其订阅的引用？
订阅是否保留对创建它的可观察性的引用？
可观察的“将”数据放入订阅中还是订阅“轮询”可观察到的数据？
信息交换是如何发生的？
浏览 0提问于2018-08-24得票数 0
回答已采纳
function signInWithGoogle(){
//console.log("clicked signInWithGoogle");
firebase.auth().onAuthStateChanged(function(user){
if(user){
alert("Already logged in");
}
else{
// var info=document.getElementById("info");
var provider=new firebase.
浏览 1提问于2017-09-12得票数 0
我有4个函数，类似于下面的函数。现在我在ngOnInit()上一次调用一个函数，但我正在寻找一种更简洁的方式来调用所有4个函数(GET HTTP Requests)，以便它们显示旋转...都是并行的..。然后关闭微调器并处理任何错误。这是一个使用angular 7的项目。 getCustomers() {
return this.apiService.getCustomers()
.subscribe(
(data: any) => {
this.partners = data;
this
浏览 28提问于2021-07-20得票数 0
回答已采纳
1回答
我有一个API调用，我想用可观察到的方式包装它：
private Observable<RealmResults<Account>> getAccounts() {
final Observable<RealmResults<Account>> realmAccounts =
Observable.defer(new Func0<Observable<RealmResults<Account>>>() {
@Override
浏览 2提问于2015-03-26得票数 2
回答已采纳
1回答
我有一个多页的网站(使用路由器)，并希望携带一个可变的价值从一个网页到另一个。
在我的联系人表单页面上，我有以下代码：
testName:string = "hello";
ngOnInit()
{
this.dataService.Stream
.subscribe(
(city:City) => this.processData(city),
(err) => console.log('Error at processing data'),
浏览 0提问于2018-10-24得票数 1
回答已采纳
1回答
我有两个子组件，我希望在它们之间传递数据，为此我使用服务。
我在服役
headerObject = new Subject<HeaderObject>();
在第一个组件中，我有一个方法
onClick() {
this.listImage = this.imageService.getImages();
let headers = new HeaderObject();
headers.file = this.listImage[0].data;
this.documentService.getOcrDocument(headers).sub
浏览 2提问于2017-08-30得票数 0
回答已采纳
3回答
反应式扩展和并行处理
、、、、
我计划在某个时候在我的项目中使用Rx，并且我一直在研究我可以用Rx做些什么。
我的项目使用TPL来并行处理状态机转换(利用所有可用的处理器内核)。但是，为了提高性能，我想用Rx push机制取代当前的IList<> pull机制。
由于我对这项技术了解不多，所以我想确定Rx是否与将令牌推送到并行状态转换兼容。我将要求所有并行状态转换订阅Rx subject并检索下一个令牌。每个状态转换都需要来自主体的相同令牌。从我自己的研究中我所理解的是，一旦一个令牌被推送给观察者(在这种情况下是状态转换)，这个令牌就永远消失了。如果是这种情况，其他转换(对于相同的状态)将永远不会收到这个令牌，并
浏览 1提问于2012-11-21得票数 1
2回答
我怎样才能将可观测到的MainEngine转换为寒冷呢？在这个例子中：
public IObservable<int> MainEngine
{
get
{
Random rnd = new Random();
int maxValue = rnd.Next(20);
System.Diagnostics.Trace.TraceInformation("Max value is: " + maxValue.ToString());
浏览 5提问于2012-08-14得票数 1
回答已采纳
我有以下组件：
@Component({...})
export class AppComponent implements OnInit, OnDestroy {
destroy$ = new Subject();
update$ = new Subject();
result: Result;
constructor(service: Service) {
}
ngOnInit() {
update$.pipe(
takeUntil(this.destroy$),
switchMap(() => this.service
浏览 4提问于2019-10-23得票数 5
回答已采纳
我是RxJS的新手，我正在尝试在两个不同的文件中订阅一个可观察的函数，我想知道是否有一种方法可以从其中一个函数触发调用也可以改变第二个文件中的结果。
我有一个动作创建器和authGuard订阅我的loginService，我正在尝试一旦我从身份验证守卫调用登录函数，动作创建器就会触发。
action.js
this.loginService.handleLogin(userId)
.subscribe((data) => {
console.log("response in action.js", response);
}
浏览 0提问于2018-03-18得票数 1
1回答
我正在做一个自定义的观察点，以更新一个按钮点击图像网址。触发图像更改的按钮和要更改的元素位于不同的组件中。
我正在使用一个服务来更新被单击的按钮和要显示的图像。我当前正在使用一个可观察对象来更新单击其中一个按钮时的图像。我是一个全新的观察者，我试图理解为什么我的观察者每次都运行错误函数？我的Observable运行next()函数，但也总是运行error()，再也不会运行了。我是不是漏掉了什么？
data.service.ts：
`import { Injectable } from '@angular/core';
import { Observable } from &#
浏览 5提问于2018-02-21得票数 0
1回答
当活动开始时，我需要用数据列表填充RecylcerView。我通过订阅实现了这一点，在onSuccess方法中，我显示了我的列表。但是当活动onResume时，我如何再次显示更新的列表。我的意思是，在切换到另一个活动，然后返回到以前，我需要再次显示更新的RecylcerView。我如何实现这一点，或我需要每次订阅显示。也许在活动的onResume中多订阅同一个可观察到的内容是一种糟糕的做法？
演示者
@Override
public void setCitiesList() {
disposables.add(getCitiesListObservable()
浏览 1提问于2018-10-16得票数 0
回答已采纳
我有一个服务运行并扫描BLE设备，通过该服务，我通过知道mac地址为特定设备读取，现在问题来了，当我读取帧时，在设备流式传输的那些帧上，我必须运行一些进程几分钟，并且当设备发送另一个流，说它不再需要该进程运行时，我必须关闭它。
我正在使用RxJava，但我对此非常陌生，所以我有一个正在执行该进程的可观察对象，所以每当我打开该进程时，我都想订阅该进程并开始执行它，当我收到关闭该进程的信号时，取消订阅该可观察对象。
我的问题是，我必须多次运行此过程，我可以多次订阅和取消订阅该可观察对象吗？
浏览 1提问于2019-10-29得票数 0
2回答
在我的项目中有许多使用异步/等待的代码。但是我想把所有的代码都转到rxjs代码上。
但我不习惯用rxjs。请告诉我将异步/等待代码转换为rxjs的模式或方法。或者请推荐一个例子。
这是我的原始代码(使用异步/等待)
this.userHistory$ = new Subject();
async getUserStatue(userId, query){
const userData = await this.UserApi.getUserInfo(userId, query);
this.userHistory$.next(userData);
}
下面的代码是我试图使用rxjs
浏览 7提问于2022-05-16得票数 0
4回答
反应性扩展应该有多少次来评估它的各种操作符？
我有以下测试代码：
var seconds = Observable
.Interval(TimeSpan.FromSeconds(5))
.Do(_ => Console.WriteLine("{0} Generated Data", DateTime.Now.ToLongTimeString()));
var split = seconds
.Do(_ => Console.WriteLine("{0} Split/Branch received Data", DateTi
浏览 2提问于2012-09-07得票数 1
回答已采纳
2回答
我创造了这支笔：
const Ob = Rx.Observable
const button = document.querySelector('#click')
const count$ = Ob.fromEvent(button, 'click')
.scan(acc=>++acc,0)
.share()
setTimeout(()=>{
count$.subscribe(x=>console.log('sub1:',x))
},5000)
setTim
浏览 1提问于2016-06-22得票数 2
回答已采纳
1回答
我的职能如下：
从我的商店=>获取一个值，将它转换为csv =>创建一个下载链接
downloadCSV() {
let href;
this.store$.select(MissionsStoreSelectors.selectedRoute).pipe(take(1)).subscribe((route) => {
if (route) {
const csv = this.csvManipulatorService.generateCSVFromJSON({filename: route.routeId, data: ro
浏览 1提问于2019-06-21得票数 0
2回答
在我们的应用程序中，我们有相当多的地方可以使用：
someObservable.take(1).subscribe(onSuccessHandler, onFailureHandler);
但是对于订阅，您需要担心在某个时候取消订阅，这并不总是简单明了的。
我正在考虑简化这个程序，并将其改写为：
someObservable.toPromise().then(onSuccessHandler).catch(onFailureHandler);
但是，看看toPromise() ()的实现，我似乎不明白为什么它不关心取消订阅。
代码中的注释说，不可以取消，但是我们如何让它这样泄漏内存(如果我们确
浏览 5提问于2016-10-06得票数 8
1回答
我有以下代码片段：
const source$ = Rx.Observable.from([1,2,3,4])
.filter(x => x % 2)
.map(x => x * x)
.share();
source$.subscribe(x => console.log(`Stream 1 ${x}`));
source$.subscribe(x => console.log(`Stream 2 ${x}`));
结果是我
但我不想分享这样的结果：
"Stream 1 1"
"Stream 2 1"
"St
浏览 2提问于2017-01-16得票数 0
回答已采纳
2回答
我有一个关于在Angular 2服务中使用观察值与变量的问题。前者似乎是首选的方式，但我找不到确切的原因。
给定一个示例服务，例如：
@Injectable()
export class TestService {
// Method 1
public data = {x: Math.random(), y: Math.random()};
// Method 2
private _data$:BehaviorSubject<any> = new BehaviorSubject({x: Math.random(), y: Math.random()
浏览 13提问于2017-01-26得票数 9
4回答
问题
我订阅了一个可观察到的httpClient.get两次。但是，这意味着我的调用被执行了两次。为什么会这样呢？
证明
对于我所做的每一个订阅()，我都会在登录页面中得到另一行。
代码(onSubmit()来自登录页按钮)
var httpHeaders = new HttpHeaders()
.append("Authorization", 'Basic ' + btoa(this.username + ':' + this.password));
var observable = this.httpClient.get('ap
浏览 1提问于2018-03-10得票数 31
回答已采纳
在Angular2+中是否可以获取或注入实现某些特定接口的所有组件的列表？具体地说，我需要在某些事件上重置所有UI组件的状态。我的想法是创建一个接口OnRest，当我需要重置它们时，为所有实现它的组件调用reset()。但是我找不到如何让Angular DI向我注入一个组件列表。
浏览 13提问于2020-05-02得票数 0
回答已采纳
似乎他们返回相同的结果，为什么使用一个而另一个呢？
var computed = ko.computed(function(){return 'foo';});
var observable = ko.observable();
var observableArray = ko.observableArray();
console.log('computed isObservable', ko.isObservable(computed));
console.log('observable isObservable', ko.isObser
浏览 5提问于2015-04-28得票数 9
回答已采纳
我在同一页上有两个组件。第一个显示项目列表，而第二个则显示显示项目的精细化器。我希望在服务中使用Observables，以便在两个组件之间建立“通信”。
所以，在我看来，应该是这样的：
第一个组件订阅可观察到的项，同时检索未经过滤的项列表。
当用户单击第二个组件中的精炼条件时，将调用一个服务函数在Observable上发出某些内容，因此，第一个组件接收一个新的项列表并更新其视图。
这看起来很简单，但我无法理解不同的类(Subscription、Subscriber、Subject和Observable)。最近的是通过使用Subject，但我不知道如何发送初始的项目列表时，有一个
浏览 7提问于2017-03-01得票数 2
回答已采纳
1回答
我在Angular2中使用的是可观察的。据我所知，每个可观察的实例都带有一个观察者(1:1)，当我们发出带有observer.next( value )的值时，我们可以使用observable.subscribe((value) => {})获得该值。
var observable = Observable.create(observer => {
observer.next(value);
}
.map(value=>{})
.catch(...)
observable.subscribe(value => {
console.log(value);
})
浏览 2提问于2016-10-21得票数 4
回答已采纳
2回答
我有这个装订，这是部分工作。
<audio controls="controls">
<source data-bind="attr: { src: selectedItem().audioUrl}" type="video/mp4" />
</audio>
它可以工作，但是当播放音频时，它只播放它绑定到的第一个url。所以当应该播放不同的音频时，也会播放相同的音频。
尝试过:设置Preload=“无”
我可以在调试器中看到值的变化，所以并不是绑定没有被更新。
我认为问题是网址
浏览 4提问于2015-05-01得票数 2
回答已采纳
2回答
对可观察服务的不需要的订阅
、、、、
按照缓存的服务模式，我使用订阅的BehaviourSubject，方法是在各种组件中使用从它创建的只读Observable
// credential.service.ts
private _credentialList$: BehaviorSubject<Credential[]>
readonly credentialListObv$: Observable<Credential[]>
...
this. credentialListObv$ = this.credentialList$.asObservable()
...
getCredentialList(
浏览 4提问于2021-09-07得票数 2
回答已采纳
我不清楚如何在RXJava中实现任务取消。
我对移植使用番石榴的ListenableFuture构建的现有API很感兴趣。我的用例如下：
我有一个单一的操作，由Futures.transform()加入的一系列期货组成
多个订阅者观察操作的最终未来。
每个观察者都可以取消最终的未来，所有的观察员都可以见证取消事件。
最终未来的取消将导致其依赖项的取消，例如，在序列中，3的3取消被传播到2，等等。
RxJava wiki中几乎没有这方面的信息；我可以找到的唯一可以取消的引用都提到了Subscription相当于.NET的Disposable，但据我所见，订阅只提供了从序列
浏览 4提问于2014-08-16得票数 14
回答已采纳
2回答
下面的repro代码演示了一个更复杂的流程中的问题：
static void Main(string[] args)
{
var r = Observable.Range(1, 10).Finally(() => Console.WriteLine("Disposed"));
var x = Observable.Create<int>(o =>
{
for (int i = 1; i < 11; i++)
{
浏览 6提问于2014-03-25得票数 1
回答已采纳
1回答
我有一个返回这样一个可观察到的方法：
open fun get(): Observable<Response> {
return if (condition)
getDataFromApi()
else
getDataFromDb()
}
并签署如下：
get()
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
浏览 0提问于2018-07-11得票数 0
回答已采纳
1回答
我仍然在计算反应性编程，所以我很确定这是非常基本的，但是对于初学者来说，流转换的数量是相当巨大的。
我正在从DOM事件中创建一个可观察到的。这个事件应该触发REST调用，所有其他DOM事件都将被忽略，直到该事件得到解决。
const stream = Observable.fromEvent(document, 'some-event')
stream
.flatMap(() => httpRestService())
.subscribe(() => {
})
在最后一个HTTP承诺解决之前，我如何忽略流中的事件？
DOM event
A - - -
浏览 2提问于2016-05-11得票数 3
回答已采纳
我发现了许多例子，在这些例子中，ActivatedRoute可以观察到，比如params或url是订阅的，而不是未订阅的。
constructor(private route: ActivatedRoute) {}
ngOnInit() {
this.route.params
// (+) converts string 'id' to a number
.switchMap((params: Params) => this.service.getHero(+params['id']))
.subscribe((hero: H
浏览 2提问于2016-12-14得票数 112
回答已采纳
2回答
我正在测试一个视图模型，它的定义如下：
class PostViewModel(private val postApi: PostApi): ViewModel() {
private val _post: PublishSubject<Post> = PublishSubject.create()
val postAuthor: Observable<String> = _post.map { it.author }
fun refresh(): Completable {
return postApi.getPost()
浏览 0提问于2019-03-29得票数 0
10回答
我读了这个，读到了一些可观察到的东西，却找不出可观察的和被观察的对象之间的区别。
浏览 12提问于2017-11-28得票数 136
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
