|
|
|
|
|
|
|
|
setTimeout(() => { |
|
|
setTimeout(() => { |
|
|
this.mqtt$.sendPublish({ id: '0', type: 'get', arlamtime: ''}); |
|
|
this.mqtt$.sendPublish({ id: '0', type: 'get', arlamtime: ''}); |
|
|
}, 1000); |
|
|
}, 1000); |
|
|
this.mqtt$.messages$.pipe(takeUntil(this.unsubscribeAll)).subscribe((message: any) => { |
|
|
|
|
|
|
|
|
this.mqtt$.messages$.pipe(takeUntil(this.unsubscribeAll), filter((item) => item !== null)).subscribe((message: any) => { |
|
|
if (message.id == '0' && message.whistletime) { |
|
|
if (message.id == '0' && message.whistletime) { |
|
|
this.whistle.time = Number(message.whistletime); |
|
|
this.whistle.time = Number(message.whistletime); |
|
|
} |
|
|
} |