Merge pull request #592 from dkunzler/265-lazyBox-notify

Fix #265
isar · Mar 7, 2021 · 266fb5e · 266fb5e
2 parents 2279300 + 1004ab8
commit 266fb5e
Show file tree

Hide file tree

Showing 4 changed files with 7 additions and 7 deletions.
diff --git a/hive/lib/src/box/keystore.dart b/hive/lib/src/box/keystore.dart
@@ -146,7 +146,7 @@ class Keystore<E> {
   }
 
   /// Not part of public API
-  Frame? insert(Frame frame, {bool notify = true}) {
+  Frame? insert(Frame frame, {bool notify = true, bool lazy = false}) {
     var value = frame.value;
     Frame? deletedFrame;
 
@@ -160,7 +160,7 @@ class Keystore<E> {
         value.init(key, _box);
       }
 
-      deletedFrame = _store.insert(key, frame);
+      deletedFrame = _store.insert(key, lazy ? frame.toLazy() : frame);
     } else {
       deletedFrame = _store.delete(frame.key);
     }

diff --git a/hive/lib/src/box/lazy_box_impl.dart b/hive/lib/src/box/lazy_box_impl.dart
@@ -66,7 +66,7 @@ class LazyBoxImpl<E> extends BoxBaseImpl<E> implements LazyBox<E> {
       if (frame.value is HiveObject) {
         (frame.value as HiveObject).init(frame.key, this);
       }
-      keystore.insert(frame.toLazy());
+      keystore.insert(frame, lazy: true);
     }
 
     await performCompactionIfNeeded();

diff --git a/hive/test/tests/box/lazy_box_impl_test.dart b/hive/test/tests/box/lazy_box_impl_test.dart
@@ -88,8 +88,8 @@ void main() {
             Frame('key1', 'value1'),
             Frame('key2', 'value2'),
           ]),
-          keystore.insert(Frame.lazy('key1')),
-          keystore.insert(Frame.lazy('key2')),
+          keystore.insert(Frame('key1', 'value1'), lazy: true),
+          keystore.insert(Frame('key2', 'value2'), lazy: true),
         ]);
       });
 

diff --git a/hive/test/tests/mocks.mocks.dart b/hive/test/tests/mocks.mocks.dart
@@ -162,8 +162,8 @@ class MockKeystore<E> extends _i1.Mock implements _i11.Keystore<E> {
   _i7.Stream<_i3.BoxEvent> watch({dynamic key}) => (super.noSuchMethod(
       Invocation.method(#watch, [], {#key: key}),
       Stream<_i3.BoxEvent>.empty()) as _i7.Stream<_i3.BoxEvent>);
-  _i9.Frame? insert(_i9.Frame? frame, {bool? notify = true}) => (super
-          .noSuchMethod(Invocation.method(#insert, [frame], {#notify: notify}))
+  _i9.Frame? insert(_i9.Frame? frame, {bool? notify = true, bool lazy = false}) =>
+      (super.noSuchMethod(Invocation.method(#insert, [frame], {#notify: notify}))
       as _i9.Frame?);
   bool beginTransaction(List<_i9.Frame>? newFrames) => (super.noSuchMethod(
       Invocation.method(#beginTransaction, [newFrames]), false) as bool);