|
@@ -37,7 +37,7 @@ let dataSet: LogSetting & { incomingObservable: Observable<BaseMessage> } = {
|
|
|
incomingObservable: payload
|
|
|
}
|
|
|
|
|
|
-incoming.init(dataSet)
|
|
|
-// acknowledge.init(storage).then(() => {
|
|
|
-// acknowledge.subscribe(dataSet.incomingObservable)
|
|
|
-// })
|
|
|
+// incoming.init(dataSet)
|
|
|
+acknowledge.init(storage).then(() => {
|
|
|
+ acknowledge.subscribe(dataSet.incomingObservable)
|
|
|
+})
|