fix(offline_first): await closable streams #552

[tshedor]

Ref #555 and #552

[jit-ci]

✅ Great news! Jit hasn't found any security issues in your PR. Good Job! 🏆

[TillJohanndeiter]

To get rid of my problem i had to do the same with the real time stream controllers

In OfflineFirstWithSupabaseRepository i changed:

final controller = StreamController<List<TModel>>(
      onCancel: () async {
        await channel.unsubscribe();

        final controller =
            supabaseRealtimeSubscriptions[TModel]?[eventType]?[query];
        // https://github.com/GetDutchie/brick/issues/552

        if (controller != null) {
          if (!controller.isClosed &&
              controller.hasListener &&
              !controller.isPaused) {
            await controller.close();
          } else {
            unawaited(controller.close());
          }
        }

After this i had to change the reset method to get rid of concurrency

@override
 Future<void> reset() async {
   await super.reset();

   // Collect controllers to avoid concurrent modification
   final controllers = <StreamController>[];
   for (final subscription in supabaseRealtimeSubscriptions.values) {
     for (final eventType in subscription.values) {
       controllers.addAll(eventType.values);
     }
   }

   for (final controller in controllers) {
     await controller.close();
   }

   supabaseRealtimeSubscriptions.clear();
 }