Fixes event-bus tests
This commit is contained in:
@@ -86,7 +86,9 @@ describe("EventBusService", () => {
|
|||||||
jest.resetAllMocks()
|
jest.resetAllMocks()
|
||||||
eventBus = new EventBusService({ logger: loggerMock })
|
eventBus = new EventBusService({ logger: loggerMock })
|
||||||
eventBus.subscribe("eventName", () => Promise.resolve("hi"))
|
eventBus.subscribe("eventName", () => Promise.resolve("hi"))
|
||||||
result = await eventBus.worker_({ eventName: "eventName", data: {} })
|
result = await eventBus.worker_({
|
||||||
|
data: { eventName: "eventName", data: {} },
|
||||||
|
})
|
||||||
})
|
})
|
||||||
|
|
||||||
it("calls logger", () => {
|
it("calls logger", () => {
|
||||||
@@ -112,7 +114,9 @@ describe("EventBusService", () => {
|
|||||||
eventBus.subscribe("eventName", () => Promise.reject("fail2"))
|
eventBus.subscribe("eventName", () => Promise.reject("fail2"))
|
||||||
eventBus.subscribe("eventName", () => Promise.reject("fail3"))
|
eventBus.subscribe("eventName", () => Promise.reject("fail3"))
|
||||||
|
|
||||||
result = await eventBus.worker_({ eventName: "eventName", data: {} })
|
result = await eventBus.worker_({
|
||||||
|
data: { eventName: "eventName", data: {} },
|
||||||
|
})
|
||||||
})
|
})
|
||||||
|
|
||||||
it("calls logger warn on rejections", () => {
|
it("calls logger warn on rejections", () => {
|
||||||
|
|||||||
Reference in New Issue
Block a user