Angular：我在服务中有两个函数，想要进行同步
我们可以使用RxJS中的Subject实现两个函数的同步。Subject是一个可被观察者也可以作为一个观察者的对象，因此可以将其放在服务中共享。每当其中一个函数执行时，我们可以通过Subject来发出一个值，另一个函数可以通过订阅这个Subject来获取这个值，并执行相应的操作。
示例代码如下：
在服务中定义一个Subject：
import { Injectable } from '@angular/core'; import { Subject } from 'rxjs';
@Injectable({
providedIn: 'root'
})
export class DataService {
private mySubject = new Subject
constructor() { }
// 发布一个值 publishValue(data: any) { this.mySubject.next(data); }
// 订阅一个值 subscribeValue() { return this.mySubject.asObservable(); } }
在需要同步的两个函数中分别调用publishValue方法和subscribeValue方法：
import { Component } from '@angular/core'; import { DataService } from './data.service';
@Component({
selector: 'app-root',
template:
})
export class AppComponent {
constructor(private dataService: DataService) {}
function1() { // do something this.dataService.publishValue('Hello from function 1'); }
function2() { this.dataService.subscribeValue().subscribe((data) => { // do something with the data received console.log(data); }); } }
当我们点击button1时，会发送一个值到Subject中，然后Subject会将这个值传递到所有订阅它的观察者中。当我们点击button2时，我们会订阅这个Subject并获取数据。在这个例子中，我们只是在控制台中打印出这个值，实际应用中我们可以根据需求执行相应的操作。
这样我们就实现了两个函数的同步。