mirror of
https://github.com/aljazceru/ditto.git
synced 2026-01-09 00:24:20 +01:00
streaming: actually hydrate with optimizer
This commit is contained in:
@@ -68,8 +68,8 @@ const streamingController: AppController = (c) => {
|
||||
if (!filter) return;
|
||||
|
||||
try {
|
||||
const db = await Storages.db();
|
||||
const pubsub = await Storages.pubsub();
|
||||
const optimizer = await Storages.optimizer();
|
||||
|
||||
for await (const msg of pubsub.req([filter], { signal: controller.signal })) {
|
||||
if (msg[0] === 'EVENT') {
|
||||
@@ -77,7 +77,7 @@ const streamingController: AppController = (c) => {
|
||||
|
||||
await hydrateEvents({
|
||||
events: [event],
|
||||
store: db,
|
||||
store: optimizer,
|
||||
signal: AbortSignal.timeout(1000),
|
||||
});
|
||||
|
||||
|
||||
Reference in New Issue
Block a user