Skip to content

Commit

Permalink
refactor: fetch batch messages on batch subscribe
Browse files Browse the repository at this point in the history
  • Loading branch information
ganchoradkov committed Nov 29, 2024
1 parent b3ca5f4 commit a674347
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion packages/core/src/controllers/relayer.ts
Original file line number Diff line number Diff line change
Expand Up @@ -207,7 +207,7 @@ export class Relayer extends IRelayer {
},
"relayer.request - publishing...",
);
const tag = `${id}:${(request.params as any)?.tag}`;
const tag = `${id}:${(request.params as any)?.tag || ""}`;
this.requestsInFlight.push(tag);
const result = await this.provider.request(request);
this.requestsInFlight = this.requestsInFlight.filter((i) => i !== tag);
Expand Down
2 changes: 1 addition & 1 deletion packages/core/src/controllers/subscriber.ts
Original file line number Diff line number Diff line change
Expand Up @@ -535,7 +535,7 @@ export class Subscriber extends ISubscriber {
this.pending.forEach((params) => {
pendingSubscriptions.push(params);
});

await this.batchFetchMessages(pendingSubscriptions);
await this.batchSubscribe(pendingSubscriptions);
};

Expand Down

0 comments on commit a674347

Please sign in to comment.