We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 1d86c92 commit b00eaa7Copy full SHA for b00eaa7
src/packages/frontend/client/query.ts
@@ -54,7 +54,10 @@ export class QueryClient {
54
});
55
// id for canceling this changefeed
56
const id = uuid();
57
- const query = await changefeed.connect();
+ const initval = await changefeed.connect();
58
+ const query = {
59
+ [Object.keys(opts.query)[0]]: initval,
60
+ };
61
this.changefeeds[id] = changefeed;
62
cb(undefined, { query, id });
63
changefeed.on("update", (change) => {
src/packages/sync/table/changefeed-nats.ts
@@ -3,6 +3,8 @@
3
* License: MS-RSL – see LICENSE.md for details
4
*/
5
6
+// DEPRECATED!!! DELETE THIS!!!
7
+
8
import { EventEmitter } from "events";
9
import type { State } from "./changefeed";
10
import { delay } from "awaiting";
0 commit comments