temp uncomment for testing workflow
This commit is contained in:
parent
fe8465fcaa
commit
9292e175da
1 changed files with 9 additions and 10 deletions
|
|
@ -30,17 +30,16 @@ export class WebsocketService {
|
|||
})
|
||||
}
|
||||
|
||||
// public listenTo<T>(topic: string): Observable<T> {
|
||||
// return this.subject.pipe(
|
||||
// value => value.topic == topic,
|
||||
public listenTo<T>(topic: string): Observable<T> {
|
||||
return this.subject.pipe(
|
||||
filter((msg: any) => msg.topic === topic),
|
||||
share()
|
||||
);
|
||||
}
|
||||
|
||||
// );
|
||||
|
||||
// }
|
||||
|
||||
// public data = this.subject.pipe(
|
||||
// share()
|
||||
// );
|
||||
public data = this.subject.pipe(
|
||||
share()
|
||||
);
|
||||
|
||||
public send(url: any){
|
||||
this.subject.next(url);
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue