Skip to content

Commit 745ef22

Browse files
committed
Fix start invocation
1 parent e659b38 commit 745ef22

File tree

1 file changed

+6
-1
lines changed

1 file changed

+6
-1
lines changed

packages/powersync_core/lib/src/sync/streaming_sync.dart

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -596,7 +596,12 @@ final class _ActiveRustStreamingIteration {
596596
Future<void> syncIteration() async {
597597
try {
598598
await _control(
599-
'start', convert.json.encode({'parameters': sync.options.params}));
599+
'start',
600+
convert.json.encode({
601+
'parameters': sync.options.params,
602+
'schema': 'TODO: Pass-through schema (probably in serialized form)',
603+
}),
604+
);
600605
assert(_completedStream.isCompleted, 'Should have started streaming');
601606
await _completedStream.future;
602607
} finally {

0 commit comments

Comments
 (0)