@schemeless/event-store
Advanced tools
Comparing version 2.4.0-rc1 to 2.4.0-rc2
@@ -9,3 +9,3 @@ "use strict"; | ||
it('should run', (cb) => { | ||
const mainQueue = makeMainQueue_1.makeMainQueue([Standard_event_1.StandardEvent, NestedOnce_event_1.NestedOnceEvent, NestedTwice_event_1.NestedTwiceEvent], { target: 'node' }); | ||
const mainQueue = makeMainQueue_1.makeMainQueue([Standard_event_1.StandardEvent, NestedOnce_event_1.NestedOnceEvent, NestedTwice_event_1.NestedTwiceEvent], { target: 'browser' }); | ||
mainQueue.processed$.subscribe(); | ||
@@ -12,0 +12,0 @@ mainQueue.push({ |
@@ -15,3 +15,3 @@ "use strict"; | ||
push: mainQueuePush, | ||
}, { target: 'node' }); | ||
}, { target: 'browser' }); | ||
sideEffectQueue.processed$.subscribe((r) => { | ||
@@ -40,3 +40,3 @@ if (r.state === event_store_types_1.SideEffectsState.fail) { | ||
push: mainQueuePush, | ||
}, { target: 'node' }); | ||
}, { target: 'browser' }); | ||
sideEffectQueue.processed$.subscribe((r) => { | ||
@@ -43,0 +43,0 @@ if (r.state === event_store_types_1.SideEffectsState.done) { |
@@ -5,4 +5,3 @@ "use strict"; | ||
const MemoryStore = require("better-queue-memory"); | ||
let store = new MemoryStore(); | ||
const getBetterQueueStoreOption = (useMemory) => (useMemory ? { store } : {}); | ||
const getBetterQueueStoreOption = (useMemory) => (useMemory ? { store: new MemoryStore() } : {}); | ||
exports.getBetterQueueStoreOption = getBetterQueueStoreOption; |
{ | ||
"name": "@schemeless/event-store", | ||
"version": "2.4.0-rc1", | ||
"version": "2.4.0-rc2", | ||
"typescript:main": "src/index.ts", | ||
@@ -53,3 +53,3 @@ "main": "dist/index.js", | ||
}, | ||
"gitHead": "018dc3c8fe80e1c369a888432bacf6ce1c079b7f" | ||
"gitHead": "c3c8cd90e4405a2f989904aef5619633a86f3e19" | ||
} |
79184
1592