行为主题取消订阅重构
是指在软件开发中，对于订阅行为的取消进行重新设计和实现的过程。它通常用于处理用户取消对特定主题或事件的订阅，以便及时停止向用户发送相关信息或执行相关操作。
行为主题取消订阅重构的目的是提高系统的可维护性、可扩展性和可测试性，同时确保用户能够方便地取消订阅并停止接收相关信息。以下是行为主题取消订阅重构的一般步骤：
- 识别订阅行为：首先，需要确定系统中存在的订阅行为，包括用户订阅的主题或事件以及相关的处理逻辑。
- 设计取消订阅接口：根据系统需求，设计一个用于取消订阅的接口或方法。该接口应该能够接收用户标识符或订阅标识符等参数，以便准确地取消对应的订阅。
- 重构订阅逻辑：根据设计的取消订阅接口，对订阅逻辑进行重构。这包括修改订阅代码，使其能够调用取消订阅接口，并在适当的时机取消用户的订阅。
- 停止发送信息或执行操作：在取消订阅时，需要确保系统停止向用户发送相关信息或执行相关操作。这可以通过在取消订阅接口中添加相应的逻辑来实现。
- 测试和验证：对重构后的订阅取消功能进行测试和验证，确保其在各种情况下都能正常工作。这包括测试取消订阅的边界条件、异常情况和并发订阅的情况。
行为主题取消订阅重构可以应用于各种场景，例如电子邮件订阅、消息推送、事件通知等。它可以提高系统的灵活性和用户体验，使用户能够更加方便地管理自己的订阅行为。
腾讯云提供了一系列与行为主题取消订阅相关的产品和服务，例如消息队列 CMQ（Cloud Message Queue），它提供了可靠的消息传递服务，支持订阅者取消订阅并停止接收消息。您可以通过以下链接了解更多关于腾讯云 CMQ 的信息：https://cloud.tencent.com/product/cmq
请注意，以上答案仅供参考，具体的实现方式和推荐产品可能因实际需求和环境而异。
相关·内容
我能否请求用户允许接收Firebase推送通知，并允许用户在第一次运行应用程序时选择退出接收推送通知？
我知道推送通知权限包含在正常而非危险的类别权限中，我们不需要请求推送通知权限，但是有什么解决办法吗？
浏览 4提问于2021-09-15得票数 0
回答已采纳
我有一个服务，作为方法调用的结果，我想给出一个主题(尽管它可以作为一个可观察的)。这很简单，但我真正想要的是能够“检测”它的取消订阅方法何时被调用(或者因为从技术上讲，它可以被多次分发给多个订阅者，当它的订阅计数降到零时)。这个是可能的吗？
浏览 5提问于2019-10-25得票数 0
回答已采纳
我面临一个问题，而没有订阅从卡夫卡消费者，请注意，我们正在使用反应堆卡夫卡API。它在开始时确实成功地取消订阅，但随后它立即加入到组中，并被分配给该主题的分区，因此本质上它始终保持订阅状态，并且一直在使用来自主题的消息，即使它不应该这样做！
下面是我做这个生意的代码，
import reactor.core.Disposable;
import reactor.core.publisher.Flux;
import reactor.core.scheduler.Schedulers;
import reactor.kafka.receiver.KafkaReceiver;
import rea
浏览 1提问于2021-08-04得票数 0
回答已采纳
2回答
我正在尝试排除我的代码。我希望订阅在.next()和初始化时触发。
但是它第一次触发一次，然后我导航离开，返回到组件并触发下一次，它会触发两次。我航行离开，然后返回，它就会发出颤音。
我检查了调用.next()的所有函数，它们只触发一次，但订阅仍在增加。
我的行为主体在服务中，当我单击组件时，它会调用服务中的下一个函数。
关于我还能在哪里检查这个问题或者如何检查的想法
浏览 0提问于2019-02-15得票数 1
1回答
我必须从两个订阅者那里获得数据，但我总是得到第一个订阅者的数据。
我有一个数据共享服务：
import { Injectable } from '@angular/core';
import { BehaviorSubject } from 'rxjs/BehaviorSubject';
@Injectable()
export class DataService {
private source = new BehaviorSubject<any>('');
data = this.source.asObser
浏览 1提问于2018-01-29得票数 3
回答已采纳
我在片段中使用了一个。
我试图以一种方式使用ReplaySubject，我希望主题在完成之前执行一个进程(可能超过片段的生命周期)。
在这个过程完成后，我想释放我理解的-as的资源--在注册观察者时取消订阅(在我的例子中，这就是主题本身)。
@benjchristensen说：
如果它是一个可观测的，那么它应该发出一个onCompleted并完成。
如果它是一个观察者，那么当它调用Observable.subscribe时，它应该从它收到的订阅中取消订阅，它将给观察到的用户一个关闭和清理的机会。
如果它是一个主题，-which既是观察者又是可观察的--行为是什么？如果我在这个主题上调
浏览 0提问于2014-09-02得票数 46
回答已采纳
2回答
我正试着在行为问题上锻炼。请找到以下片段。
dashboard.component.js
export class DashboardComponent implements OnInit {
inputObjResponse = [];
constructor(private http: Http, private GetjsondataService: GetjsondataService) { }
ngOnInit() {
var that = this;
this.GetjsondataService.getValuesFromJson()
this.Getjs
浏览 1提问于2018-07-09得票数 0
回答已采纳
2回答
我试图在我的角度应用程序上实现自动登录功能。我在用户登录时创建cookie。在重新加载页面时，我能够检索cookie和正确的存储内容。
我要做的是在重新加载页面时自动登录用户。
下面是app.component.ts的方式：
export class AppComponent {
constructor(
private cookieService: CookiesService,
) {
}
ngOnInit() {
this.profileService.getCachedProfile();
this.profileService.newTo
浏览 0提问于2018-12-07得票数 0
我们使用AWS SNS (简单通知服务)作为向用户发送通知的机制之一。这意味着，有通过SMS发送的通知(使用AWS SNS) /电子邮件/自动呼叫。
但是，任何时候，如果用户从这三种方法中的任何一种取消订阅，我们都应该停止在这三种模式下向用户发送进一步的警报。
目前，我无法在API中检查订阅请求是否已被选择退出(通过发送停止消息)，因此我们也可以阻止其他两种通信模式。
有可能吗，在SNS里？我试着查看API、console和Amazon论坛的列表。
浏览 4提问于2015-12-20得票数 1
回答已采纳
1回答
我可以发布和订阅一个主题，但是当取消订阅功能不起作用时呢？
var mqtt = require('mqtt');
var client = mqtt.connect('mqtt://localhost:1883');
var topic = 'home/machine1/lightSensor';
client .on('connect', ()=>{
client.unsubscribe(topic,console.log);
});
它返回null
浏览 10提问于2021-11-10得票数 0
我对“观察”很陌生，我很担心内存泄露。如果我创建以下内容：
private client = new BehaviorSubject("");
clientStream$ = this.client.asObservable();
在这样的景致下，他们可以看到：
this.clientService.clientStream$.subscribe(
client => {
this.client = client;
}
}
，我需要取消订阅吗?如果我打电话给client.getValue()，怎么办？
浏览 4提问于2017-09-13得票数 15
回答已采纳
我使用库paho来连接mqtt broker、发送消息以及几乎所有工作正常，但我使用setTimeToWait()方法有问题。我在setTimeToWait(2000)或setTimeToWait(10)方法中花费了多少毫秒，这并不重要。我总是收到来自publiusher的消息。
为什么我可以在小时内收到消息？如果我设置等待时间为2000毫秒。，我想在2秒内没有来自发布者的消息后，我的订阅者就不能从发布者那里获得消息，并且控制权将被返回。
我做错了什么？
发布者代码：
public class MqttPublishSample {
public static void main(S
浏览 215提问于2018-06-09得票数 -1
回答已采纳
我正在编写一个应用程序，该应用程序以编程方式创建一个新的SQS队列，该队列订阅现有的SNS主题，然后删除SQS队列。
我知道有一种方法可以使用Java删除SNS主题及其订阅。我知道我可以从web控制台手动删除已确认的订阅。我知道挂起的订阅将自行过期。
但是我想以编程的方式删除已确认的订阅，但保留SNS主题。或者，在SQS队列消失之后，确认的订阅会在一段时间后过期吗？
浏览 4提问于2020-05-13得票数 1
回答已采纳
我订阅了一个以电子邮件地址为端点的SNS主题。
我昨晚收到了取消订阅的通知，我问了所有有权访问收件箱的人，没有人点击取消订阅链接。
我重新创建了订阅，今天早上它又自动潜逃了。
怎么可能呢？我怎样才能防止这种情况再次发生？我在CloudTrail中查找，但取消订阅操作不会被记录下来，除非它们是在控制台中或通过API进行的。
任何指标都会有帮助，谢谢。
浏览 6提问于2018-04-20得票数 12
我正在实现一个angular4客户端应用程序。
我添加了一些服务，这些服务可以从后端发出一些http请求。
然后，它开始抛出以下ObjectUnsubscribedError.
这是一个截图：
经过一些研究，我发现了来自的以下警告
我猜由ReactJs rxjs/Subject属性引起的问题。我想，我可能会取消一些错误，但我的取消订阅代码是在ngOnDestroy()方法，这是退出的代码。
因此，我找不到适当的解决办法，也找不到问题的确切原因。
有什么建议或帮助吗？
谢谢
我的代码之一是：
import {Component, Inject, OnDestroy, OnInit} fro
浏览 5提问于2017-08-21得票数 4
1回答
我正在使用mqtt.js从mqtt服务器接收websocket，订阅工作正常，但我需要通过更改websocket的配置来动态地将订阅更改为主题，问题是更改配置后，我开始接收来自新主题和旧主题的消息，即使我执行client.unsubscribe()，旧的侦听器仍保持活动状态。 有没有办法删除旧的lister或停止旧的websocket，只保留新的websocket，下面是代码的一个片段： import React, { Component } from 'react'
import mqtt from 'mqtt';
var options = {
浏览 41提问于2020-11-11得票数 0
有个棘手的问题。我有防火墙消息传递，在数据库中记录令牌(按规定)。然后我运行触发器发送到主题(使用函数)。当我从主题中取消订阅时，我注意到了一个bug (在名称中有一个空格--因为是固定的)，所以用户不能正确地取消订阅。自从他们开始谈论这个话题。只是想知道是否有一种删除旧令牌/过期的方法--然后从所有主题中取消订阅。基本上，我希望创建一个“重置”按钮的类型，以防这种情况再次发生。
我的个人资料上也有同样的问题。但是，我的解决方案(和测试)是删除和重新创建我的配置文件。不是一个理想的解决方案！从那以后一切又恢复得很好。
浏览 0提问于2018-02-23得票数 0
回答已采纳
我使用一个ROS节点(C++代码)来执行一些图像处理，读取来自模拟器中不同视觉传感器的图像。我有个大问题，到目前为止，还没有解决办法.
假设我的节点处于活动状态，并且正在对从主题“A”获取的图像执行一些操作；在某个点(因此在运行时，)，我需要从这个主题“A”中取消订阅，并从另一个主题“B”(，该主题的名称“B”由另一个订阅者传递给节点)中删除，以读取来自另一个视觉传感器的图像:我想这样做，只需更改主题名称(例如，使用字符串变量)，并使用用于主题“A”的相同回调。
困难如下：
我无法读取所有的图像并选择我需要的图像:传感器太多，无法处理这样的数据流，而且，这个系统根本无法扩展。
我需要在
浏览 3提问于2013-06-12得票数 0
2回答
我正在尝试从主题中取消订阅持久订阅者。
我的应用是一种社交网络:每个用户都是其他用户的话题。因此，每次用户在做某件事时，都会通知他的朋友。当然，订阅者可能取消订阅某个主题，希望不再接收有关用户的通知。
每次我试图从主题中取消订阅用户时，我都会遇到一个错误，告诉我："javax.jms.JMSException:持久性消费者在使用“
这是我的两个类，发送者和接收者。有人能告诉我我做错了什么吗？
发件人班：
package com.citizenweb.classes;
import java.util.Date;
import javax.jms.Connection;
import
浏览 9提问于2016-09-16得票数 0
我在使用npm mqtt和react时遇到了问题。订阅主题“alert”以接收从服务器发布的数据，然后客户端取消订阅此主题。在每个订阅和取消订阅消息被复制之后。服务端发送1条消息，客户端接收更多条消息。基于subscribe和unsubscribe增加消息。
const List = () => {
const listener = (topic, message) => {
const data = JSON.parse(message.toString());
if (topic.includes('alert')) {
c
浏览 0提问于2020-11-15得票数 0
按照在angular中使用stompjs的指南，我试图弄清楚使用它作为web套接字的架构，以便通过我拥有的web套接字订阅实时通知。
在我的根组件中，我有2个页面/组件，它们将使用相同的主题进行订阅。在根目录(app.component.ts)中启动监视主题是正确的，还是应该在两个相应的组件中启动监视主题，并在销毁时取消订阅？
浏览 21提问于2021-03-02得票数 0
当最后一个主题观察者从主题中取消订阅时，AsyncSubject变得可观察。这是
当它完成了，它就完成了。主题在未订阅、完成或错误后不能重用。
下面是演示：
const ofObservable = Rx.Observable.of(1, 2, 3);
const subject = new Rx.AsyncSubject();
ofObservable.subscribe(subject);
subject.subscribe((v) => {
console.log(v);
});
subject.unsubscribe((v) => {
cons
浏览 2提问于2017-07-14得票数 4
回答已采纳
我有两个组件和一个服务。
在组件1中，我有一个在初始化时立即调用的函数。
组件1:
ngOnInit() {
this.getItems();
}
getItems(){
this.mainService.getItems().subscribe(items => { //WATCH SERVICE
this.items = items;
});
}
现在，在服务中，我有一个函数getItems()，它正确地完成了任务：
主服务：
public itemCategoryId = new BehaviorSubject<any&g
浏览 6提问于2019-12-03得票数 0
如果SNS主题订阅已经确认，然后放弃，但没有显式取消订阅，会发生什么？是否有可以设置的过期时间？我在文档中没有看到任何关于这方面的内容。如果我有很多被遗弃的客户端，我可能会收集很多垃圾订阅的主题。
你可能想知道我为什么会问这样的问题。
我想知道这一点，因为我正在做一些需要发布-订阅行为的工作，并且我可能会有我想要管理的悬空订阅。这可能是大量的悬而未决的订阅--比如数千。我不能控制客户端代码，所以我不能保证他们会表现良好，他们可能会从网络中“消失”，即使他们表现良好，也永远没有机会取消订阅。
有没有一些最好的卫生方法？
我可以定期修改所有现有的订阅(作为主题所有者)，监听主题流量的客户端将不得不
浏览 1提问于2015-07-30得票数 0
当我使用take(1)时，它将console.log两次1，如下所示：
const a$ = new BehaviorSubject(1).pipe(publishReplay(1), refCount());
a$.pipe(take(1)).subscribe();
a$.subscribe((v) => console.log(v)); // emit twice (1 1)
但是，当我删除take(1)或删除publishReplay(1), refCount()时，它会遵循我的预期(只有一个1 console.log)。
const a$ = new Behav
浏览 3提问于2020-06-30得票数 1
回答已采纳
场景:-带有选中和未选中项计数的json需要发送到一个公共函数，该函数反过来执行一些基本的验证或显示错误。有不同的函数，每个函数由不同的css/js团队处理，它们调用这个函数&根据公共函数的结果(true/false)，为json提供check/uncheck状态的每个团队/模块都会执行相关的操作。因此，公共函数(比如getcount)和调用该函数的每个独立团队都依赖于公共函数的结果独立地操作dom/css &公共函数也独立地操作dom。
而不是传统的调用函数的方法(比如getCount({"chk“：2，"unchk”：4}))，我正在寻找pusblish/s
浏览 3提问于2013-03-27得票数 0
回答已采纳
1回答
如何在rxjs中重构订阅内的订阅
、、、、
例如：
this.saveSubscription$ = this.ds.onSave$.subscribe(x =>
this.sb.updateMachineTool(this.viewEditModel.viewEditModel).subscribe(x = {
console.log('alert results', x)
})
)
this.ds.onSave$是在单击其他组件上的“保存”按钮时触发的主题。
this.sb.updateMachineTool是一个更新特定工具的httpClient帖子。
我应该使用某种类型的地图，这样我就不会
浏览 0提问于2018-10-01得票数 1
回答已采纳
2回答
可以使用注册Id直接订阅主题，而不是在应用程序中创建端点并使用该端点在主题中创建订阅。我也只想知道是否有可能用PHP来做。
请帮帮我。
浏览 0提问于2016-03-12得票数 0
2回答
是否有方法为Firebase主题订阅添加过期时间。
我希望在每周或每个月结束时，对一个主题的订阅都能被清除。
除了手动调用取消订阅之外，是否有任何方法在进行订阅时指定主题订阅的到期时间？
提前谢谢。
浏览 4提问于2017-03-06得票数 0
回答已采纳
1回答
取消订阅FCM中的主题
、、、
我成功地设置了FCM在我的网站，它是完美的工作。我使用JavaScript通过订阅“电影”主题发送通知。
fetch('https://iid.googleapis.com/iid/v1/'+tokenz+'/rel/topics/movies', {
method: 'POST',
headers: new Headers({
'Authorization': 'key=****'
})
我没有发现任何使用JS取消订阅web主题的
浏览 3提问于2017-03-22得票数 10
回答已采纳
我有一个角服务，它定义了一个公共Subject。稍后，在某些条件下，该服务将调用.next()有关此主题。
另外，我在.subscribe()的ngOnInit()方法中有一个角度分量，在它的ngOnDestroy()方法中调用.unsubscribe()。
当服务和组件都处于活动状态时，我的代码可以正常工作。但是，用户可以在我的应用程序中单击另一个选项卡。这会导致我的组件卸载并调用其ngOnDestroy()方法，这意味着可观察到的内容被取消订阅。
从这一点开始，组件就不再存在了，但是服务仍然存在--其他组件仍然在使用它。当服务在组件调用.unsubscribe()之后调用.unsubscr
浏览 10提问于2022-02-06得票数 1
回答已采纳
在flutter firestore代码库中，您可以找到，这是您在查询上运行snapshots()时它创建的流。
// It's fine to let the StreamController be garbage collected once all the
// subscribers have cancelled; this analyzer warning is safe to ignore.
StreamController<QuerySnapshotPlatform> controller; // ignore: close_sinks
我想用Behavior
浏览 1提问于2020-08-12得票数 0
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
为什么在启动Kafka流应用程序时，我会断断续续地点击下面的警告消息？
这不仅仅是一个警告，因为它淹没了应用程序日志& Kafka应用程序没有启动。
通常情况下，当我重新部署时，它就能工作了。
[my-app-0 my-app] 2020-03-25 14:00:12.931 WARN 1 --- [-StreamThread-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=my-app-b8f0b2a0-271b-4499-85bd-9e22d4a8b4b1-StreamThread-1-consu
浏览 1提问于2020-03-25得票数 7
回答已采纳
1回答
我正在考虑使用Firebase云消息实现移动应用程序和浏览器应用程序之间的消息传递，我有几个问题，文档似乎没有回答。
为了能够接收消息，您需要注册令牌(RT)。还可以将消息发送到RT、主题或设备组notification_key.The RT：
直接
订阅某个主题
添加到设备组中
RT也可以过期/更改。
在我的应用程序中，我为每个用户维护一个RT列表。现在，当RT更改时：
是否必须取消订阅旧令牌并订阅主题的新令牌？
是否必须删除旧令牌并将新令牌添加到设备组中？
是否可能获得有关令牌的设备组/主题的信息？
我可以不止一次地向设备组添加令牌吗？
我能不止一次
浏览 3提问于2017-02-15得票数 31
回答已采纳
1回答
你好，我有一个购物车，可以添加产品，也可以使用api删除产品。当从购物车中删除项目时，必须使用一个按钮逐个按id单击每个项目。这是好的，但我试图从一个函数中空出购物车url中的所有项目，而不是一个按钮，因为id将是未定义的。
我的问题是，这是否可能？我尝试过清除项目数组，如cartItems.length =0或cartItems = [] --这只会从我的理解中清空数组的一个副本，因此从我尝试过的内容来看，购物车中的项目仍然存在。
我伸出手来看看是否有人能回答这个问题，并指出正确的方向，这将是非常感谢的。我已经包含了html的片段和删除项的cart服务。
购物车服务
RemoveProdu
浏览 4提问于2022-08-10得票数 -1
1回答
用于跳转和投诉通知的Amazon
、、、、
我正在建立一个项目，在ASP.NET C#，以管理反弹和投诉通知，当我发送大量电子邮件与亚马逊SES。
我已经了解到，对于大量消息来说，最好的方法是SQS，而不是HTTP端点上的更简单的SNS。
我找到了亚马逊团队的一些现成代码：
我知道SQS服务必须由我调用，不是像SNS那样推动，但我不知道如何调用它，哪个URL以及如何构建请求。
浏览 2提问于2016-04-14得票数 3
回答已采纳
下面是我如何在两个不相关的组件之间进行通信。组件B试图从组件A访问myObj。奇怪的是，this.myObj并不总是指向最新的数据。有什么原因吗？
component A {
myService.pubSub.subscribe((data)=>{
if(data.type == "getMyObj"){
myService.pubSub.next(this.myObj);
}
});
}
component B {
myService.pubSub.next({type:
浏览 0提问于2021-11-30得票数 0
1回答
我正在为我的公司构建一个聊天应用程序，并决定使用带有websocket (ws)的node js。在我的应用程序中，有多个部门和每个部门的用户，当浏览器(提问题的人)选择一个特定的部门时，希望聊天被重定向到同一个部门。
我决定使用WAMP路由器，但没有示例脚本显示如何将每个聊天重定向到浏览器选择的特定部门。
有没有人能帮我一把
干杯
Sunil
浏览 1提问于2015-10-25得票数 1
我有一个管道，它根据图像名称通过api加载图像blob url。
export class LoadingImageNamePipe implements PipeTransform {
imageSub: Subscription;
constructor(private getimage: GetFileService) {}
transform(name: any) {
return this.getimageurl(name);
}
result: BehaviorSubject < string > = new Behav
浏览 0提问于2018-06-06得票数 0
回答已采纳
1回答
我们开发了一个iOS应用程序，并将该应用程序配置为侦听在亚马逊网络服务IoT上发布的特定MQTT主题上的所有消息。
我想知道的是，有没有办法可以获取正在收听该主题的已连接设备的列表？(我检查了cloudWatch日志，但我找不到详细信息，如连接的设备的MAC地址等)。
另外，我想知道对no是否有限制。可以订阅主题的设备的数量。
浏览 44提问于2016-08-16得票数 5
1回答
我有一个有多个订阅的主题。当其中一个订阅失败时，消息将被移动到DLQ。有没有办法找出哪个订阅失败了？如果再次处理相同的消息，那么如何确保已经处理该消息的订阅不再处理它？
浏览 6提问于2022-10-17得票数 0
1回答
如果我在这门课上有一个主题，在它的生命中释放出一个单一的价值：
export class MyClass {
myEmitter$: Subject<void> = new Subject();
someMethod(){
this.myEmitter$.next();
this.myEmitter$.complete();
}
}
然后在另一个班级：
this.instanceOfMyClass.myEmitter.subscribe();
如果主题在发射后完成，我应该取消订阅instanceOfMyClass.myEmitter$吗？
浏览 1提问于2017-08-18得票数 3
回答已采纳
我正在尝试确定如何处理以下代码 let sub = myObservable.subscribe(
v => doThing(v),
e => handle(e),
() => sub.unsubscribe(),
) 问题是% 1。此代码不正确，因为myObservable已同步完成，将在完成时引发NPE。2.即使我怀疑这里的取消订阅调用是一个很好的做法。我情不自禁地觉得这可能没有必要，因为我还没有在其他地方看到过。 我读过这篇文章https://blog.angularindepth.com/why-you-have-to-unsubscribe
浏览 15提问于2019-04-04得票数 0
回答已采纳
我有一个HTTP服务，它在将给定的项ID传递给它时返回一些信息。这是通过一个Subject完成的，它接收到了ngOnInit方法中的第一个数据。
然后，我使用async管道在HTML中显示服务返回的数据。
我的问题是，在使用第一个项目ID调用async时，selections.next管道还没有订阅可观察到的内容，因此初始化时不会显示这个条目。
如何等到async管道订阅了Observable之后，才向主题发送第一段数据以开始第一个HTTP请求？
我试过不同的，但似乎都没有用。
import { Component, OnInit } from "@angular/core";
浏览 2提问于2017-10-27得票数 1
回答已采纳
我有一个可以观察到的父值，一旦它有了订阅服务器，它就会执行一个查找并发出一个值，然后完成。
我想把它转换成一个可观察的(或行为主体或其他有用的东西)，这样做如下:一旦它至少有一个订阅者，它就会从可观察的父用户那里得到结果(一次)。然后，当所有订阅者订阅时，它会向所有订阅者发出该值，并向所有未来订阅者发出该值。它应该继续这种行为，即使它的订户计数下降到零。
这看起来应该很容易。以下是不起作用的地方：
theValue$: Observable<boolean> = parent$
.take(1)
.share()
其他不起作用的事情：publishReplay()，publish(
浏览 4提问于2017-09-13得票数 21
回答已采纳
1回答
我必须更改已经安装好的JBoss4.0.2环境的配置。已经确定的主题，需要更改名称。因此，我在它需要的地方进行了修改，比如在/home/jBoss-4.0.2/server/myappinste.conf/下的属性文件，以及列出主题的主要jboss service.xml文件。
mytopic-Destination-service.xml
<server>
<!-- event publish destination -->
<mbean code="org.jboss.mq.server.jmx.Topic"
name=
浏览 5提问于2018-06-13得票数 0
回答已采纳
我正在尝试测试订阅到事件网格的函数。
我发现了以下创建自定义事件的代码：
string topicEndpoint = "https://<topic-name>.<region>-1.eventgrid.azure.net/api/events";
string topicKey = "<topic-key>";
string topicHostname = new Uri(topicEndpoint).Host;
TopicCredentials topicCredentials = new TopicCredentia
浏览 0提问于2018-10-15得票数 0
1回答
我试图从离子角度使用Publish和Subscribe .
subscribe.js
this.events.subscribe('done:eventA', (userEventData) => {
//Perform some operations
this.startEventB();
this.events.unsubscribe('done:eventA'); <---
}
this.events.subscribe('done:eventB', (userEventData) => {
//P
浏览 1提问于2016-10-25得票数 1
在我的应用程序中，一些活动从服务器获取信息，在尝试检索数据之前，我需要确保已经建立了连接。在建立连接时，我使用BehaviorSubject通知订阅者，这样活动就可以加载数据。
问题是，同一流程中的多个活动具有相同的行为。在我们的API中，我们必须在connect()中调用onStart()，在onStop中调用disconnect()，但是如果用户使用另一个也使用连接的活动，则不需要重新创建连接，我们可以使用相同的连接。
目前，我正在以以下方式实现：
调用connect()时，它返回将从调用类订阅的BehaviorSubject
在方法disconnect()上，只有当Behavio
浏览 1提问于2017-06-19得票数 3
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
