We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 6551ed1 commit 39d7543Copy full SHA for 39d7543
README.md
@@ -1372,7 +1372,7 @@ const subscriptionEndpoint = new EventStreamFactory({
1372
time: z.int().positive(),
1373
}).buildVoid({
1374
input: z.object({}), // optional input schema
1375
- handler: async ({ options: { emit, isClosed } }) => {
+ handler: async ({ options: { emit, isClosed, signal } }) => {
1376
while (!isClosed()) {
1377
emit("time", Date.now());
1378
await setTimeout(1000);
0 commit comments