File tree Expand file tree Collapse file tree 1 file changed +3
-4
lines changed
packages/service-core/src/routes/endpoints Expand file tree Collapse file tree 1 file changed +3
-4
lines changed Original file line number Diff line number Diff line change @@ -3,8 +3,7 @@ import { RequestParameters } from '@powersync/service-sync-rules';
33import { serialize } from 'bson' ;
44
55import { Metrics } from '../../metrics/Metrics.js' ;
6- import { RequestTracker } from '../../sync/RequestTracker.js' ;
7- import { streamResponse } from '../../sync/sync.js' ;
6+ import * as sync from '../../sync/sync-index.js' ;
87import * as util from '../../util/util-index.js' ;
98import { SocketRouteGenerator } from '../router-socket.js' ;
109import { SyncRoutes } from './sync-stream.js' ;
@@ -61,9 +60,9 @@ export const syncStreamReactive: SocketRouteGenerator = (router) =>
6160 } ) ;
6261
6362 Metrics . getInstance ( ) . concurrent_connections . add ( 1 ) ;
64- const tracker = new RequestTracker ( ) ;
63+ const tracker = new sync . RequestTracker ( ) ;
6564 try {
66- for await ( const data of streamResponse ( {
65+ for await ( const data of sync . streamResponse ( {
6766 storage,
6867 params : {
6968 ...params ,
You can’t perform that action at this time.
0 commit comments