fix(hydrated_bloc): Clearing existing storage when build storage called

packages/hydrated_bloc/lib/src/hydrated_storage.dart

@@ -85,7 +85,6 @@ class HydratedStorage implements Storage {
     HydratedCipher? encryptionCipher,
   }) {
     return _lock.synchronized(() async {
-      if (_instance != null) return _instance!;
       // Use HiveImpl directly to avoid conflicts with existing Hive.init
       // https://github.com/hivedb/hive/issues/336
       hive = HiveImpl();
@@ -105,7 +104,7 @@ class HydratedStorage implements Storage {
         await _migrate(storageDirectory, box);
       }
 
-      return _instance = HydratedStorage(box);
+      return HydratedStorage(box);
     });
   }
 
@@ -133,7 +132,6 @@ class HydratedStorage implements Storage {
   static late HiveInterface hive;
 
   static final _lock = Lock();
-  static HydratedStorage? _instance;
 
   final Box<dynamic> _box;
 
@@ -157,15 +155,13 @@ class HydratedStorage implements Storage {
   @override
   Future<void> clear() async {
     if (_box.isOpen) {
-      _instance = null;
       return _lock.synchronized(_box.clear);
     }
   }
 
   @override
   Future<void> close() async {
     if (_box.isOpen) {
-      _instance = null;
       return _lock.synchronized(_box.close);
     }
   }

packages/hydrated_bloc/test/hydrated_storage_test.dart

@@ -50,14 +50,19 @@ void main() {
         await storage.close();
       });
 
-      test('reuses existing instance when called multiple times', () async {
+      test('override existing instance when called multiple times', () async {
         final instanceA = storage = await HydratedStorage.build(
-          storageDirectory: storageDirectory,
+          storageDirectory:
+              await Directory(storageDirectory.path + "/new").create(),
         );
+
         final instanceB = await HydratedStorage.build(
           storageDirectory: storageDirectory,
         );
-        expect(instanceA, instanceB);
+
+        await instanceA.close();
+        await instanceB.close();
+        expect(instanceA, isNot(instanceB));
       });
 
       test('creates new instance if storage was closed', () async {
@@ -191,12 +196,13 @@ void main() {
 
           // ignore: unawaited_futures
           storage.write(token, record);
-
+          await storage.close();
+          await storage.clear();
           storage = await HydratedStorage.build(
             storageDirectory: Directory(cwd),
           );
 
-          final written = storage.read(token) as List<List<String>>;
+          final written = storage.read(token) as List;
           expect(written, isNotNull);
           expect(written, record);
         }).drain<dynamic>();