Skip to content

Commit b1dbad1

Browse files
committed
Fix start invocation
1 parent d104fd2 commit b1dbad1

File tree

1 file changed

+7
-1
lines changed

1 file changed

+7
-1
lines changed

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

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -588,7 +588,13 @@ final class _ActiveRustStreamingIteration {
588588

589589
Future<void> syncIteration() async {
590590
try {
591-
await _control('start', convert.json.encode(sync.options.params));
591+
await _control(
592+
'start',
593+
convert.json.encode({
594+
'parameters': sync.options.params,
595+
'schema': 'TODO: Pass-through schema (probably in serialized form)',
596+
}),
597+
);
592598
assert(_completedStream.isCompleted, 'Should have started streaming');
593599
await _completedStream.future;
594600
} finally {

0 commit comments

Comments
 (0)