Add tets

Author: simolus3

packages/sqlite_async/test/native/watch_test.dart

@@ -5,6 +5,7 @@ import 'dart:async';
 import 'dart:isolate';
 import 'dart:math';
 
+import 'package:async/async.dart';
 import 'package:sqlite3/common.dart';
 import 'package:sqlite_async/native.dart';
 import 'package:sqlite_async/sqlite_async.dart';
@@ -25,6 +26,16 @@ void main() {
       await testUtils.cleanDb(path: path);
     });
 
+    test('emits updates if stream is listened to before pool is opened',
+        () async {
+      final db = await testUtils.setupDatabase();
+      final updates = StreamQueue(db.updates);
+
+      await db.execute('CREATE TABLE a (bar INTEGER);');
+      await db.execute('INSERT INTO a DEFAULT VALUES');
+      await expectLater(updates, emits(UpdateNotification({'a'})));
+    });
+
     test('raw update notifications', () async {
       final factory =
           (await testUtils.testFactory(path: path)) as NativeSqliteOpenFactory;

packages/sqlite_async/test/watch_test.dart

@@ -31,6 +31,19 @@ void main() {
       await testUtils.cleanDb(path: path);
     });
 
+    test('is broadcast stream', () async {
+      final db = await testUtils.setupDatabase(path: path);
+      await createTables(db);
+
+      expect(db.updates.isBroadcast, isTrue);
+      var events = 0;
+
+      db.updates.listen((_) => events++);
+      db.updates.listen((_) => events++);
+      await db.execute('INSERT INTO assets DEFAULT VALUES');
+      expect(events, 2);
+    });
+
     test('watch', () async {
       final db = await testUtils.setupDatabase(path: path);
       await createTables(db);