rxdart BehaviorSubject不在iOS上发出最后一个值
rxdart是一个在Dart语言中实现响应式编程的库，它提供了一系列的类和方法来简化异步编程和数据流处理。其中，BehaviorSubject是rxdart库中的一个类，它是一个特殊的StreamController，可以同时充当数据源和数据流的订阅者。
BehaviorSubject在iOS上不发出最后一个值可能是由于以下原因之一：
- 数据流未完成：BehaviorSubject需要在数据流完成之前才能发出最后一个值。如果数据流还没有完成，那么BehaviorSubject将不会发出最后一个值。
- 数据流为空：如果数据流中没有任何值，那么BehaviorSubject将不会发出最后一个值。
- 订阅时机：如果在BehaviorSubject发出最后一个值之前订阅了数据流，那么订阅者将无法接收到最后一个值。
为了解决这个问题，可以采取以下措施：
- 确保数据流完成：在数据流完成之前，确保调用
close()方法关闭数据流。这样可以确保BehaviorSubject发出最后一个值。 - 检查数据流是否为空：在订阅数据流之前，可以先检查数据流中是否有值。如果数据流为空，可以采取相应的处理措施，例如提供默认值或者给出提示信息。
- 合理安排订阅时机：确保在BehaviorSubject发出最后一个值之后再订阅数据流，这样可以确保订阅者接收到最后一个值。
需要注意的是，以上解决方案是基于rxdart库的特性和使用方法，具体实现可能会因具体的业务场景和代码逻辑而有所不同。
关于腾讯云相关产品和产品介绍链接地址，由于要求不能提及具体的云计算品牌商，无法给出相关链接。但是腾讯云作为一家知名的云计算服务提供商，提供了丰富的云计算产品和解决方案，可以通过访问腾讯云官方网站获取更多信息。
相关·内容
在我更新代码以适应颤振空安全后，下面的代码会使我产生错误
未为类型'BehaviorSubject‘定义getter 'value’。
final _brightness = BehaviorSubject<Brightness>();
...
if (_brightness.value == Brightness.light) { ... } // error is here
那么如何从value获得BehaviorSubject呢？
使用rxdart：^0.26.0
浏览 6提问于2021-04-29得票数 0
我正在用FLUTTER/DART和RXDART做小项目。
下面是代码的一部分：
class RegisterBloc with UserValidator {
final _username = BehaviorSubject<String>();
final _email = BehaviorSubject<String>();
final _password = BehaviorSubject<String>();
Function(String) get setUsername => _username.sink.add;
Stream<
浏览 4提问于2019-04-06得票数 3
对于rxdart ，我有一个奇怪的问题。通常，BehaviorSubject应该只向流发出最后一个值：
一种特殊的StreamController，它捕获添加到控制器中的最新项，并将其作为第一项发送到任何新侦听器。
但是在我的例子中，它也在流中释放所有以前的值，我不知道为什么。
我有以下测试组：
class TestBloc {
final _controller = BehaviorSubject.seeded([]);
Stream get stream$ => _controller.stream;
TestBloc(BehaviorSubject subjec
浏览 11提问于2022-06-10得票数 2
1回答
我已经开发了一个应用程序，它使用行为主体为所有组件进行数据传输，这真的是一个使用可观察概念的良好实践吗？
import { BehaviorSubject } from 'rxjs';
const subject = new BehaviorSubject(123);
// two new subscribers will get initial value => output: 123, 123
subject.subscribe(console.log);
subject.subscribe(console.log);
// two subscribers wi
浏览 0提问于2020-03-02得票数 0
回答已采纳
我正尝试在我的无状态小部件上使用Rxdart： class SimplePrioritySelectWidget extends StatelessWidget {
BehaviorSubject<List<String>> _valueNotifier =
BehaviorSubject<List<String>>.seeded([]); 我用StreamBuilder包装我的小部件： @override
Widget build(BuildContext context) {
return StreamBui
浏览 66提问于2021-07-29得票数 0
回答已采纳
我用的是角8和SignalR。我把一个可观察到的从我的NotificationService推到一个DashboardComponent。为了进行测试，我每10秒发送一次测试消息。
如果我在订阅处理程序中省略了一些防御性编码，订阅就会失败--即使实际的通知消息是以正确的格式传递的，所以技术上不应该需要它。此外，我还从订阅处理程序获得了一条一次性错误消息，该消息似乎在注册订阅时被执行(带有一个空对象{})。可能最好的解释是代码：
可观测性： (NotificationListenerService)
private doorMessageSource: BehaviorSubject<a
浏览 0提问于2019-07-22得票数 0
回答已采纳
1回答
订阅后立即响应
、、
这是我的理论服务：
@Injectable({
providedIn: 'root'
})
export class DataService {
@Output() data: EventEmitter<number> = new EventEmitter();
constructor() {
setInterval(() => {
this.data.emit(Math.random());
}, 1e3);
}
}
和我的组件：
ngOnInit() {
this.sub = this.dataSe
浏览 3提问于2019-05-24得票数 1
我像往常一样在服务文件中创建了一个主题
editLectures = new Subject<Lecture>();
getEditLectureListener() {
return this.editLectures.asObservable();
}
我正在从一个组件发送数据(当我console.log它时，我得到了正确的数据)
onUpdate(lec: any) {
this.attendanceService.emitLecture(lec);
}
在另一个组件上，我正在监听主题：
this.updateLecture = this.attendanceSer
浏览 12提问于2019-11-19得票数 0
这快把我逼疯了，有人能告诉我为什么我不能通过组件交流吗？我试图从HomeComponent向RecipesComponent发送一条消息，反之亦然。当我单击testInstruction按钮时，它只记录在同一个组件中。
import { Component, OnInit } from '@angular/core';
import { VoiceInstructionService } from './voice-instruction.service';
import { Subscription } from 'rxjs/Subscription
浏览 1提问于2018-02-01得票数 1
1回答
我已经创建了一个Angular服务，它基本上是用一些用户信息设置一个对象。当我更改用户时，该服务发出一个可观察对象，由一些兄弟组件捕获以更新信息。问题是，当我第一次设置数据时，还没有人订阅，所以我得到了一个未定义的值。我读过关于使用publish()或share()将可观察对象转换为“热”的文章，但我对RxJS非常陌生，我仍然不明白它是如何100%工作的，所以我有点迷惑了。
服务代码(相关部分)：
getFwcUser() : Observable<FwcUser> {
return this.subjectFwcUser.asObservable();
}
setFwcUs
浏览 0提问于2017-09-19得票数 9
回答已采纳
在从BehaviorSubject获得价值时，我遇到了问题。我创建了一个屏幕抖动，有两个TextField和一个按钮，我和我收到他们的数据与集团模式。
但是，当我更改TextFields值时，连接到TextFiled的BehaviorSubject值将为null，而当更改TextField值时，连接到TextFields的两个TextFiled的值将获得null。
使用颤振和飞镖的
import 'dart:async';
import 'package:bloc_provider/bloc_provider.dart';
import
浏览 0提问于2019-07-27得票数 2
回答已采纳
我想知道这两个函数之间是否有什么区别：
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
回答已采纳
我有一个重播主题如下：
@Injectable()
export class ViewByService implements OnDestroy {
private _selectedViewBy$ = new ReplaySubject<ViewByContext>(1);
public selectedViewBy$ = this._selectedViewBy$.asObservable();
constructor() {}
setViewBy(viewBy: ViewByContext): void {
this._selectedViewBy$
浏览 1提问于2020-04-22得票数 0
我想根据用户输入启用/禁用按钮。如果所有文本输入都符合某个条件，则只需启用“插入”按钮。 通常情况下，如果所有输入字段都正确，按钮才会被启用。但是，如果一个或多个输入错误，并且用户移动到另一个输入域，并将其更改为正确/不正确，则按钮将被启用，即使某些域具有错误的输入。检查图像： ? 登录区块代码： import 'package:rxdart/rxdart.dart';
class LoginScreenBloc {
final _firstCtrl = BehaviorSubject<String>();
final _lastCtrl = B
浏览 47提问于2019-05-24得票数 0
我想在一个固定的时间间隔内重新发出可观察到的最后一个值，我尝试了。
obs.pipe(repeat({delay:1000})).subscribe(x => console.log('Emitted', x));
但这不起作用。在研究过这个之后，我的可观察到的实际上是一个BehaviorSubject。
所以我的问题是为什么第一颗卫星每秒钟发射一次
of('Observable').pipe(repeat({ delay: 1000 })).subscribe(x => console.log(x));
但不是这个？
var bs = new Be
浏览 12提问于2022-12-02得票数 0
我正在创建一个角9应用程序。我有一个共享服务，用于在组件之间共享用户数据。在我重新加载应用程序之前，它是正确的。
我的sharedService叫UserService。服务设置BehaviorSubject的值。登录时，它调用方法setLoggedInUser()从JWT获取userID，该JWT存储在AuthenticationService中的另一个BehaviorSubject中。然后通过HTTP调用请求用户的数据。值设置为loggedInUser
export class UserService {
public loggedInUser: BehaviorSubject<
浏览 3提问于2020-07-31得票数 1
回答已采纳
我一直想找到一种很好的方法来做这件事，但我运气不好。
以下是问题的简化版本：
import 'package:rxdart/rxdart.dart';
/// Input a list of integers [0,1,2,3,4]
/// map each of those integers to the corresponding index in the map
/// if the map updates, the output should update too.
///
/// The output should be a list of Strings:
//
浏览 0提问于2018-11-26得票数 2
回答已采纳
1回答
RxJS采取()运算符
、、、
我有点搞不懂take()操作符。在它的定义中，它应该返回由可观测对象发出的第一个值，但在我看来，它似乎是返回最后一个值。
为了更好地理解它，我尝试了以下测试：
UsersService.ts
import {User} from '../models/user.model';
import {BehaviorSubject} from 'rxjs';
@Injectable({providedIn: 'root'})
export class UsersService {
userObs = new BehaviorSubject<
浏览 2提问于2020-07-26得票数 0
回答已采纳
我有一个使用NGRX的角形9应用程序，它大部分使用可观测/主题和assync管道。
我有一个导航栏组件，它具有以下HTML：
<ul class="navbar-nav">
<li class="nav-item" *ngFor="let menuItem of navbarMenuItems | async">
<a id="{{ menuItem.id }}" [routerLink]="menuItem.routerLink" class="nav-l
浏览 2提问于2020-03-06得票数 1
回答已采纳
2回答
post组件订阅了behaviour并获得了帖子的订阅。First time运行良好，但当我转到另一个页面并返回时，我只得到帖子的最后一个值，但我需要所有的帖子列表，就像第一次一样。
发布服务：
public getPosts(): BehaviorSubject<Post> {
let postSubject: BehaviorSubject<Post> = new BehaviorSubject<Post>(Post.EMPTY_POST);
this.db.list(this.getModelPath()).subscribe((pos
浏览 12提问于2017-07-26得票数 0
我正在使用可观测数据从后端获取数据。在我的函数中，我订阅了可观察到的数据，当我将被传回的数据console.log()时，它似乎会返回两次。首先是空对象，然后是我期望的数据。
这给我带来了一个问题，因为我试图使用for...in循环来比较数据的键和另一个对象的键，以便匹配值。我得到一个TypeError:无法读取未定义的属性'0‘，因为数据首先返回一个空对象。这让我感到困惑，因为我正在订阅的回调方法中执行console.log()。
回调方法的全部目的不是等待数据到达吗？
我尝试了一个回调函数，并将for...in直接放置在订阅中，因为对象首先返回为空，所以两者都不起作用。我做错了什么
浏览 1提问于2019-08-27得票数 0
回答已采纳
我使用共享服务在两个独立的组件之间传递数据。当我在我的共享服务中使用主题时，我看不到订阅组件的html中的订阅数据，但可以在订阅后在控制台中看到它。然而，如果我使用Behaviorsubject，它工作得很好。谁能给我解释一下为什么会这样。
sharedservice.ts：
//code with subject (not working)
private msgStatistics = new Subject<any>();
msgStatistics$ = this.msgStatistics.asObservable();
msgStats(
浏览 4提问于2021-08-05得票数 0
我需要在两个组件之间传递数据，同时页面也在更改。为此，我实现了一个数据服务：
@Injectable()
export class DatashareService {
public dataSubject = new Subject<any>();
public addData(data){
this.dataSubject.next(data);
}
}
并使用addData方法将数据传递给它：
export class DashboardDialog {
dashboardName;
dashboardDescripti
浏览 2提问于2018-01-02得票数 0
回答已采纳
3回答
我正在使用流来监视我的后端的变化。对于更新来说，这是可行的，但是我没有得到初始值。
class A {
final Stream<DocumentSnapshot> _visitorCount =
Firestore.instance.document('ServerData/serverStatus').snapshots();
Stream<int> get visitorCount {
return Observable(_visitorCount)
.map((DocumentSnapshot doc
浏览 0提问于2018-06-20得票数 2
回答已采纳
我有一个可观察的从我的BackEnd中获取所有数据的方法。当我对某一项执行删除操作时，我希望刷新此可观察到的内容。
我尝试过两种有效的解决方案，但它们看起来真的很难看。一种是强制角重新加载当前路由，另一种是如下面代码所示，在给定的间隔内重新订阅可观察到的内容。
component.ts：
data: Observable<Setting[]>;
ngOnInit() {
this.data = interval(1000).pipe(
startWith(0),
mergeMap(res => this.dataService.fetchData())
浏览 0提问于2018-10-17得票数 2
回答已采纳
我组装了一个示例应用程序，它使用流实现用户名和密码字段，并使用验证转换进行验证。为此，我使用了RxDart，并连接了"Login“按钮，以便根据2流结果为true启用/禁用。
bloc.dart
Stream<bool> get submitValidWithCombineLatestStream =>
CombineLatestStream([email, password], (list) => true);
login_page.dart
Widget submitButton(Bloc bloc) {
return StreamBuilder
浏览 7提问于2020-12-15得票数 0
我有一个主题，我在两个不同的routes.In上听，这是一条路，我在设定主题值，同时也在听它。从该路由中，在设置了它的subject值之后，导航到在ngOnInit()上侦听相同主题的其他路由。该路由上一次从前一个路由url发出值，有什么方法可以处理在加载组件时无法侦听最后发送的value.Only侦听的方法吗？
浏览 1提问于2022-08-09得票数 0
1回答
我正在创建一个简单的应用程序，目前只有两页：
(1)一份完整的库存清单。(2)一只股票的详细情况。
当您单击股票列表中的特定股票时，应将其路由到另一页以读取其信息。
下面是我使用的服务：
export class StockService {
stock$ = new Subject();
public setStock(stock: Stock){
this.stock$.next(stock);
}
public getStock():Observable<any>{
return this.stock$.asObservable();
浏览 6提问于2022-02-14得票数 0
回答已采纳
我有一个简单的服务。
import { Injectable } from '@angular/core';
@Injectable({ providedIn: 'root' })
export class XmlService {
items$: Subject<Item[]> = new Subject<Item[]>();
constructor() {
setTimeout(() => this.items.next([{age: '20'}]), 4000);
}
浏览 0提问于2019-04-05得票数 1
我正试图使自己的头在现代的角度，而几个小时的谷歌搜索，无论什么原因，并没有导致清晰(这可能是我错过了午餐)。我正在尝试建立一个文件上传小部件的原型，以便开始。
到目前为止，我的情况如下：
"File-一个包含一些属性的简单类，其中一些属性是有状态的(例如上传状态)
"FileComponent“--呈现文件的组件
"FileListComponent“--一个包含文件数组的属性的组件
我需要能够做到以下几点：
当用户在FileListComponent上执行拖放操作时实例化新文件对象
在文件对象上传时更新它的状态
在相应文件的状态更改时刷
浏览 0提问于2018-07-19得票数 0
回答已采纳
我正在尝试使用视频BLoC中描述的模式来构建一个颤振应用程序
BLoC基本上是一个具有Sink输入和Stream输出的视图模型。在我的示例中，它看起来有点像这样：
class BLoC {
// inputs
Sink<String> inputTextChanges;
Sink<Null> submitButtonClicks;
// outputs
Stream<bool> showLoading;
Stream<bool> submitEnabled;
}
我在层次结构根附近的小部件中定
浏览 1提问于2018-04-10得票数 12
我试图使用Subject和共享服务将数据从一个组件传输到另一个组件。但它不起作用。
请注意，我在模块级别列出了服务，而不是组件装饰器。同样值得注意的是，这两个组成部分并不具有父子关系。
我的服务(SearchService)：
import { Subject } from 'rxjs/Subject';
@Injectable()
export class SearchService {
public messageSource = new Subject<any>();
constructor() { }
topAlbums(album){
浏览 1提问于2017-09-09得票数 0
回答已采纳
1回答
我有一个服务，组件和模块。
在服务中，我希望发送标志$变量的更改。
export class ListUserService {
public flag$ = new Subject< boolean >();
}
此组件对变量进行更改
export class ListUserComponent implements OnInit {
private flagPerfil = false;
getFlag() {
return this.flagPerfil;
}
constructor(private listUserS
浏览 39提问于2019-05-30得票数 0
回答已采纳
我有一个名为nav-bar.component.ts的组件，它使用以下方法将搜索查询传递给另一个组件。
nav-bar.component.ts
publishSearchQuery(query) {
if (query !== '') {
this.searchService.publicSearchQuery(query);
this.router.navigate(['search']);
}
另一个组件OnInit()方法包含对searchLectures()方法的调用
searchLectures(url) {
console.log('
浏览 3提问于2017-09-02得票数 1
回答已采纳
我正在与RxDart做斗争(可能只是直接进行Rx编程)。我现在有一个有状态的小部件，在它的didChangeDependencies()中调用我的集团。该调用发出并通过http请求获取数据，并将其添加到流中。我使用的是BehaviorSubject，这个很好。我有使用StreamBuilders的子部件，它们可以获得数据，没有问题。我的问题是处理错误。如果我的http请求失败，我使用addError('whatever error')补充流，但是我的子部件的StreamBuilder没有接收到该错误。什么都没得到。
所以我有几个问题。
这是意料之中吗？
在StreamB
浏览 1提问于2019-03-31得票数 1
4回答
我有一些数据，我想与我的整个应用程序共享，所以我创建了这样一个服务。
user.service
userDataSource = BehaviorSubject<Array<any>>([]);
userData = this.userDataSource.asObservable();
updateUserData(data) {
this.userDataSource.next(data);
}
然后，在我的组件中，我从api中获取一些数据，然后像这样将数据发送到userDataSource。
constructor(
private: userServ
浏览 0提问于2018-03-28得票数 17
回答已采纳
我有两个部件。一种是形式，另一种是形式的输出。一旦用户点击submit按钮，我希望将数据从form组件发送到output组件。
这就是我尝试过的：
form.service.ts
private listOfFoundedMatches;
// Set list of founded matches
setListOfFoundedMatches(value) {
this.listOfFoundedMatches = value;
}
// Get list of founded matches
getListOfFoundedMatches() {
浏览 0提问于2019-11-07得票数 0
回答已采纳
此ngOnInit不执行console.log行 ngOnInit() {
this.loadBlogPosts();
this.authStatusService.getAuthUsername().subscribe(
status => {
// got username status
console.log("This is the username status from home", status);
this.authUsername = status;
}
);
} 将执行此行 this.l
浏览 26提问于2020-05-03得票数 1
回答已采纳
2回答
请检查一下这个GitHub回购
userService在根级注册。
我希望将getUserLogin可观测值输入到SharedModule的UserComponent中，当用户单击按钮时，从在HomeModule中声明的HomeComponent中将值发送给用户组件。
根级的UserService：
userLogin = new Subject<string>();
constructor() { }
sendUserLogin(user: string) {
console.log("value received at user service
浏览 1提问于2019-12-05得票数 0
我很难从主题中得到最后发出的值。
这是我的班，负责发射和观察电池的变化：
class BatteryLevelProvider @Inject constructor(
app: App
) {
private val context: Context = app
private val receiver: PowerConnectionReceiver = PowerConnectionReceiver()
init {
initializeReceiver()
}
private fun initializeReceiver() {
IntentFilter(Intent.ACTIO
浏览 0提问于2018-09-14得票数 1
回答已采纳
1回答
从活着的对象中创建可观察的对象
、、、、
我是RxJS的新手。我想要创建一个可以观察到的AppState对象，该对象可能在任何时候发生变化，并订阅它以获得这些更改。这是一个被剥离的实现：
export class AppState {
public get observable(): Observable<any> {
return Observable.of(this._state);
}
}
// appState is injected into my component via angular DI
this.appState.observable
.subscribe((app
浏览 5提问于2017-09-22得票数 0
回答已采纳
2回答
我从json得到了一个我想要显示的列表，并且能够使用输入框进行过滤。到目前为止，它是有效的，但列表只在我向搜索框中输入内容时显示，而不是在那之前。我希望在开始时显示列表。我尝试在开始时使用空字符串设置搜索框的值，但它不起作用。在网上查了也没找到实现的方法。任何帮助都将不胜感激。 我的组件html： <h4><label for="search-box">Hero Search</label></h4>
<input #searchBox id="search-box" (input)=search(sea
浏览 18提问于2020-11-11得票数 0
回答已采纳
4回答
我想从一个角服务中提供一个rxjs Subject，以便能够通过调用服务上的方法来发出值(通过next)。我希望它发出的值之一是角HttpClient get调用的结果。我只是看上去搞错了。我想知道为什么以下结果导致订阅处理程序没有被调用：
-View
export default abstract class TileView implements OnInit {
constructor (private configService : ConfigService) {}
ngOnInit () {
this.configService.fetch(this.type())
浏览 0提问于2018-09-19得票数 4
回答已采纳
我知道BehaviorRelay正在取代Variable，BehaviorSubject和BehaviorRelay都以初始值开始，并向订阅者重放该初始值或最新值。
那有什么不同呢？在哪种情况下，您会使用其中一个而不是另一个？
浏览 9提问于2020-07-17得票数 8
我试图使用forkJoin操作符组合两个可观测值并输出一个新值。其中一个调用返回一个对象数组，其中包含与保险单上的多个人相关的数据(该部分不能更改)。另一个可以观察到的告诉我们是谁登录了。我正在考虑使用forkJoin获取两个值，并只返回登录用户的信息。以下是我如何尝试建立一个新的可观察到的：
this.incentiveStepsHistory$ = forkJoin({
incentiveStepsHistory: this._steps.getIncentiveStepsHistory(year),
loggedInPerson: this._member.loggedI
浏览 7提问于2019-10-31得票数 2
回答已采纳
1回答
我想要实现的是:我想通过每5分钟轮询一次，但只有当有一个观察者订阅的时候，我想从网络上投票一些资源。我使用BehaviorSubject和interval作为池。我成功地实现了它，但我对Rx并不熟悉，我认为它可以做得更好。
我就是这样做的：
private BehaviorSubject<String> observable;
private Subscription> subscription;
public Subscription subscribe(final Action1<String> action) {
if (observable ==
浏览 4提问于2016-02-16得票数 2
回答已采纳
1回答
我不确定我是否理解为什么我的订阅没有正确完成。
以下是该服务：
import { Injectable } from '@angular/core';
import { FormBuilder, FormGroup, Validators } from '@angular/forms';
import { Subject, Observable } from 'rxjs';
@Injectable({
providedIn: 'root'
})
export class FormService {
private
浏览 11提问于2020-05-11得票数 1
回答已采纳
1回答
我需要来自带有http调用的服务的一些值，所以我将它们保存在一个主题中。
这在我的组件中工作得很好
ngOnInit() {
this.service.values.subscribe(values) {
console.log(values);
}
}
但当我再次触发ngOnInit时，我得不到任何值，因为该服务仅在整个网站重新加载时触发(而不是当我切换到另一个页面时)。
那么，如何才能在元素更改时订阅元素，并在元素已经在主题中时获取元素呢？
浏览 1提问于2017-03-07得票数 1
回答已采纳
我尝试使用服务通过主题传递数据，但第一次单击编辑按钮时，在控制台中看不到任何内容，然后第二次单击按钮时，我在管理products.component.ts中发送值时看到了结果 this.prservice.editproduct.next(this.editedproduct) 它在这里工作得很好，问题是在订阅的时候，我想，这也是我第一次点击 admin-products.component.html <button type="button" [routerLink]="['new']" mdbBtn color="primar
浏览 14提问于2019-02-13得票数 2
1回答
在我基于ASP.NET MVC的Range8应用程序中，有一个仪表板组件，其中我显示某种统计数据(例如求和、平均值)，并在每次创建更新-删除事件后借助SignalR更新这些数据，向所有客户端广播新的数据。另一方面，我想构建一种通用的方法，应该在整个应用程序中使用，我认为使用EventEmitter、BehaviorSubject、Subject、ReplaySubject等似乎是个好主意，以便将新检索的统计数据传递给客户。但是，正如在上所指出的，这些组件之间有一些不同，我想澄清一下，哪个组件最适合于给定的示例？为什么？
请注意，我需要通过没有父-子关系(通常是在同级组件之间)的不同组件向客户端
浏览 1提问于2019-07-16得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
