update dependencies

2020-12-21 11:57:50 +01:00
parent 9ec5f102d1
commit cc41d5380f
2 changed files with 5 additions and 5 deletions
@@ -97,19 +97,19 @@ class ChannelsBlocState extends State<ChannelsBloc>
        paginationParams: paginationParams,
        onlyOffline: onlyOffline,
      )
-          .listen((channels) {
+          .then((channels) {
        if (clear) {
          _channelsController.add(channels);
        } else {
          final l = oldChannels + channels;
          _channelsController.add(l);
        }
-      }, onDone: () {
-        _queryChannelsLoadingController.sink.add(false);
-      }, onError: (err, stackTrace) {
+      }).catchError((err, stackTrace) {
        print(err);
        print(stackTrace);
        _queryChannelsLoadingController.addError(err, stackTrace);
+      }).whenComplete(() {
+        _queryChannelsLoadingController.sink.add(false);
      });
    } catch (err, stackTrace) {
      _queryChannelsLoadingController.addError(err, stackTrace);