Skip to content

Commit

Permalink
flapper
Browse files Browse the repository at this point in the history
  • Loading branch information
aricart committed Oct 16, 2024
1 parent ed005f1 commit e97c43e
Show file tree
Hide file tree
Showing 2 changed files with 8 additions and 8 deletions.
3 changes: 2 additions & 1 deletion kv/tests/kv_test.ts
Original file line number Diff line number Diff line change
Expand Up @@ -399,8 +399,9 @@ Deno.test("kv - history and watch cleanup", async () => {
}
}

await delay(500);

// need to give some time for promises to be resolved
await delay(100);
const nci = nc as NatsConnectionImpl;
const min = nci.protocol.subscriptions.getMux() ? 1 : 0;
assertEquals(nci.protocol.subscriptions.size(), min);
Expand Down
13 changes: 6 additions & 7 deletions migration.md
Original file line number Diff line number Diff line change
Expand Up @@ -171,10 +171,9 @@ const service = await svc.add({
### Watch

Object.watch() now returns an `ObjectWatchInfo` which is an `ObjectInfo` but adding the property
`isUpdate` this property is now true when the watch is notifying of a new entry. Note that previously
the iterator would yield `ObjectInfo | null`, the `null` signal has been removed. This means that
when doing a watch on an empty ObjectStore you won't get an update notification until an actual value
arrives.


Object.watch() now returns an `ObjectWatchInfo` which is an `ObjectInfo` but
adding the property `isUpdate` this property is now true when the watch is
notifying of a new entry. Note that previously the iterator would yield
`ObjectInfo | null`, the `null` signal has been removed. This means that when
doing a watch on an empty ObjectStore you won't get an update notification until
an actual value arrives.

0 comments on commit e97c43e

Please sign in to comment.