|
|
@@ -33,16 +33,12 @@ export class MessageSyncrhonizationService implements MessageSynchronisationServ
|
|
|
let msg : Subject<BaseMessage> = new Subject()
|
|
|
obsTrigger.subscribe({
|
|
|
next: obs => {
|
|
|
- console.log(`${obsTrigger} has trigged synchronization`)
|
|
|
- this.dataConversion().subscribe({
|
|
|
- next: e => console.log(e)
|
|
|
+ let missingMsg = this.dataConversion()
|
|
|
+ missingMsg.subscribe({
|
|
|
+ next: element => {
|
|
|
+ msg.next(element)
|
|
|
+ }
|
|
|
})
|
|
|
- // let missingMsg = this.dataConversion()
|
|
|
- // missingMsg.subscribe({
|
|
|
- // next: element => {
|
|
|
- // msg.next(element)
|
|
|
- // }
|
|
|
- // })
|
|
|
}
|
|
|
})
|
|
|
// trigger by timer
|
