Merge pull request #127 from powersync-ja/chore/merge-master-alpha-release-2

Merge master to alpha release

Author: mugikhan

packages/powersync/lib/src/stream_utils.dart

@@ -68,6 +68,13 @@ Stream<Object?> ndjson(ByteStream input) {
   return jsonInput;
 }
 
+/// Given a raw ByteStream, parse each line as JSON.
+Stream<String> newlines(ByteStream input) {
+  final textInput = input.transform(convert.utf8.decoder);
+  final lineInput = textInput.transform(const convert.LineSplitter());
+  return lineInput;
+}
+
 void pauseAll(List<StreamSubscription> subscriptions) {
   for (var sub in subscriptions) {
     sub.pause();