Skip to content

Commit 0919586

Browse files
committed
Merge branch 'master' into chore/merge-master-alpha-release-2
2 parents d2b8eeb + de5b7dd commit 0919586

File tree

2 files changed

+9
-2
lines changed

2 files changed

+9
-2
lines changed

packages/powersync/lib/src/stream_utils.dart

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -68,6 +68,13 @@ Stream<Object?> ndjson(ByteStream input) {
6868
return jsonInput;
6969
}
7070

71+
/// Given a raw ByteStream, parse each line as JSON.
72+
Stream<String> newlines(ByteStream input) {
73+
final textInput = input.transform(convert.utf8.decoder);
74+
final lineInput = textInput.transform(const convert.LineSplitter());
75+
return lineInput;
76+
}
77+
7178
void pauseAll(List<StreamSubscription> subscriptions) {
7279
for (var sub in subscriptions) {
7380
sub.pause();

packages/powersync/test/crud_test.dart

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -155,7 +155,7 @@ void main() {
155155
equals([
156156
{
157157
'data':
158-
'{"op":"PUT","type":"logs","id":"$testId","data":{"level":"INFO","content":"test log"}}'
158+
'{"op":"PUT","type":"logs","id":"$testId","data":{"content":"test log","level":"INFO"}}'
159159
}
160160
]));
161161

@@ -231,7 +231,7 @@ void main() {
231231
equals([
232232
{
233233
'data':
234-
'{"op":"PATCH","type":"assets","id":"$testId","data":{"quantity":${bigNumber + 1},"description":"updated"}}'
234+
'{"op":"PATCH","type":"assets","id":"$testId","data":{"description":"updated","quantity":${bigNumber + 1}}}'
235235
}
236236
]));
237237
});

0 commit comments

Comments
 (0)