chore: test fixes

flutterwtf · Aug 1, 2023 · ee9295e · ee9295e
1 parent 4fd011e
commit ee9295e
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 15 deletions.
diff --git a/example/pubspec.lock b/example/pubspec.lock
@@ -208,14 +208,6 @@ packages:
       url: "https://pub.dev"
     source: hosted
     version: "6.0.5"
-  rxdart:
-    dependency: transitive
-    description:
-      name: rxdart
-      sha256: "0c7c0cedd93788d996e33041ffecda924cc54389199cde4e6a34b440f50044cb"
-      url: "https://pub.dev"
-    source: hosted
-    version: "0.27.7"
   sky_engine:
     dependency: transitive
     description: flutter

diff --git a/lib/src/data/repositories/suggestion_repository.dart b/lib/src/data/repositories/suggestion_repository.dart
@@ -19,7 +19,8 @@ class SuggestionRepositoryImpl implements SuggestionRepository {
       SimpleBehaviorSubject<List<Suggestion>>([]);
 
   @override
-  Stream<List<Suggestion>> get suggestionsStream => _suggestionsSubject.stream();
+  Stream<List<Suggestion>> get suggestionsStream =>
+      _suggestionsSubject.stream();
 
   @override
   List<Suggestion> get suggestions => _suggestionsSubject.value;

diff --git a/test/presentation/cubits/suggestions_cubit_test.dart b/test/presentation/cubits/suggestions_cubit_test.dart
@@ -1,8 +1,8 @@
 import 'package:bloc_test/bloc_test.dart';
 import 'package:flutter_test/flutter_test.dart';
 import 'package:mockito/mockito.dart';
-import 'package:rxdart/rxdart.dart';
 import 'package:suggest_a_feature/src/domain/entities/suggestion.dart';
+import 'package:suggest_a_feature/src/domain/utils/simple_behavior_subject.dart';
 import 'package:suggest_a_feature/src/presentation/di/injector.dart';
 import 'package:suggest_a_feature/src/presentation/pages/suggestions/suggestions_cubit.dart';
 import 'package:suggest_a_feature/src/presentation/pages/suggestions/suggestions_state.dart';
@@ -119,19 +119,18 @@ void main() {
       blocTest<SuggestionsCubit, SuggestionsState>(
         'vote requested suggestion',
         build: () {
-          final dataStream = BehaviorSubject.seeded([
+          final dataStream = SimpleBehaviorSubject([
             mockedRequestSuggestion,
             mockedRequestSuggestion2,
           ]);
 
           when(mockSuggestionRepository.suggestionsStream).thenAnswer(
-            (_) => dataStream,
+            (_) => dataStream.stream(),
           );
 
           when(mockSuggestionRepository.upvote(any)).thenAnswer(
-            (_) async => dataStream.add(
-              [mockedRequestSuggestion, upvotedSuggestion],
-            ),
+            (_) async =>
+                dataStream.value = [mockedRequestSuggestion, upvotedSuggestion],
           );
 
           return SuggestionsCubit(