fix(concatEager): activeSubscription should be changed to next subs…

…cription (#682) * Fix ConcatEagerStream bug * Update concat_eager.dart Co-authored-by: Petrus Nguyễn Thái Học <[email protected]>
ReactiveX · Jun 15, 2022 · 6a8eef5 · 6a8eef5
1 parent dfae6fa
commit 6a8eef5
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/lib/src/streams/concat_eager.dart b/lib/src/streams/concat_eager.dart
@@ -46,10 +46,9 @@ class ConcatEagerStream<T> extends StreamView<T> {
         return () {
           if (index < subscriptions.length - 1) {
             completeEvents[index].complete();
+            activeSubscription = subscriptions[index + 1];
           } else if (index == subscriptions.length - 1) {
             controller.close();
-          } else {
-            activeSubscription = subscriptions[index + 1];
           }
         };
       }