angular 发布订阅

平常一段歌 發表於 2019-5-5 18:15:00

创建service
<div class="cnblogs_code">
<pre>import { Subject } from 'rxjs/Subject';
import { Observable } from 'rxjs/observable';

export class MessageService {
private subject = new Subject<any>();

send(message: any) {
 this.subject.next(message);
}

get(): Observable<any> {
 return this.subject.asObservable();
}
}</pre>
</div>
组件1 发布
<div class="cnblogs_code">
<pre>import { Component, OnInit } from '@angular/core';
import { Subject } from 'rxjs/Subject';
import { MessageService } from '../../service/message.service';

@Component({
selector: 'app-video-demo-home',
templateUrl: './video-demo-home.component.html',
styleUrls: ['./video-demo-home.component.sass']
})
export class VideoDemoHomeComponent implements OnInit {

private _clickPoint: Subject<any> = new Subject<any>();
public name = 'www';
constructor(public srv: MessageService) { }

ngOnInit() {
}

clickBtn() {
this.srv.send(this.name);
}

}</pre>
</div>
组件2 订阅
<div class="cnblogs_code">
<pre>import { Component, OnInit } from '@angular/core';
import { MessageService } from '../../service/message.service';

@Component({
selector: 'app-subscribe-home',
templateUrl: './subscribe-home.component.html',
styleUrls: ['./subscribe-home.component.sass']
})
export class SubscribeHomeComponent implements OnInit {

constructor(public srv: MessageService) { }
public message = '';
ngOnInit() {

this.srv.get().subscribe((result) => {
 console.log('111111111111111111');
 this.message = result;
 console.log(this.message);
});
}

}</pre>
</div>
  
来源：https://www.cnblogs.com/stacey-zy/p/10815380.html

頁: [1]

琼殿技术论坛's Archiver

angular 发布订阅