fix(offline_first): await closable streams #552 (#565)

Author: tshedor

packages/brick_offline_first/CHANGELOG.md

@@ -1,3 +1,7 @@
+## 4.0.1
+
+- Fix never-completing Future on `#reset` (#552)
+
 ## 4.0.0
 
 - **BREAKING CHANGE** Require `brick_core: >= 2.0.0` and remove support for `Query(providerArgs:)`; see [migration steps](https://github.com/GetDutchie/brick/issues/510)

packages/brick_offline_first/lib/src/offline_first_repository.dart

@@ -342,7 +342,12 @@ abstract class OfflineFirstRepository<TRepositoryModel extends OfflineFirstModel
     memoryCacheProvider.reset();
     for (final subscription in subscriptions.values) {
       for (final controller in subscription.values) {
-        await controller.close();
+        // https://github.com/GetDutchie/brick/issues/552
+        if (!controller.isClosed && controller.hasListener && !controller.isPaused) {
+          await controller.close();
+        } else {
+          unawaited(controller.close());
+        }
       }
     }
     subscriptions.clear();

packages/brick_offline_first/pubspec.yaml

@@ -5,7 +5,7 @@ homepage: https://github.com/GetDutchie/brick/tree/main/packages/brick_offline_f
 issue_tracker: https://github.com/GetDutchie/brick/issues
 repository: https://github.com/GetDutchie/brick
 
-version: 4.0.0
+version: 4.0.1
 
 environment:
   sdk: ">=3.4.0 <4.0.0"