import { StreamingService } from "./test-streamOBS"; import { IncomingMessageService } from "../services/incomingMessage.service"; import { Observable, take } from "rxjs"; import { LogSetting } from "../dependencies/log/type/datatype"; import { BaseMessage } from "../dependencies/log/dependencies/msgutil/interface/export"; const incoming = new IncomingMessageService() const streamService = new StreamingService() /* -------------- TEST -------------------- */ // change payload into Observable const payload: Observable = streamService.stream().pipe(take(3)); // Configure Log Setting let storage: LogSetting = { storage: "MongoDB", cacheMessageLimit: 0, setting: { appName: 'Default from client', appLocName: 'To be generated in client', logLocName: 'To be generated in client', }, customSetting: { srv: true, user: "testDB", password: "h1nt1OyXw6QeUnzS", server: "cluster0.29sklte.mongodb.net", database: "log", } } let dataSet: LogSetting & { incomingObservable: Observable } = { storage: storage.storage, setting: storage.setting, customSetting: storage.customSetting, incomingObservable: payload } incoming.init(dataSet)