feat: move in memory store to core package

example/lib/shared/modules/profile/data/profile_repository.dart

@@ -1,4 +1,4 @@
-import 'package:buzz_ui/in_memory_events_store.dart';
+import 'package:core/core.dart';
 
 import '../model/profile.dart';
 import '../model/profile_user_info.dart';

example/packages/buzz_ui/lib/in_memory_events_store.dart

@@ -1,4 +1,4 @@
-import 'package:rxdart/rxdart.dart';
+import 'package:core/core.dart';
 
 abstract class EventRecord {
   String get name;
@@ -32,26 +32,3 @@ class EventRecordsInMemoryStore {
     _state.value.add(event);
   }
 }
-
-/// An in-memory store backed by BehaviorSubject that can be used to
-/// store the data for all the fake repositories in the app.
-class InMemoryStore<T> {
-  InMemoryStore(T initial) : _subject = BehaviorSubject<T>.seeded(initial);
-
-  /// The BehaviorSubject that holds the data
-  final BehaviorSubject<T> _subject;
-
-  bool get isWaiting => !_subject.hasValue && !_subject.hasError;
-
-  /// The output stream that can be used to listen to the data
-  Stream<T> get stream => _subject.stream;
-
-  /// A synchronous getter for the current value
-  T get value => _subject.value;
-
-  /// A setter for updating the value
-  set value(T value) => _subject.add(value);
-
-  /// Don't forget to call this when done
-  void close() => _subject.close();
-}

example/packages/core/lib/core.dart

@@ -1,5 +1,6 @@
 library core;
 
-export 'json_reader.dart';
-export 'managed_stream_builder.dart';
-export 'named_page.dart';
+export 'src/in_memory_store.dart';
+export 'src/json_reader.dart';
+export 'src/managed_stream_builder.dart';
+export 'src/named_page.dart';

example/packages/core/lib/src/in_memory_store.dart

@@ -0,0 +1,24 @@
+import 'package:rxdart/rxdart.dart';
+
+/// An in-memory store backed by BehaviorSubject that can be used to
+/// store the data for all the fake repositories in the app.
+class InMemoryStore<T> {
+  InMemoryStore(T initial) : _subject = BehaviorSubject<T>.seeded(initial);
+
+  /// The BehaviorSubject that holds the data
+  final BehaviorSubject<T> _subject;
+
+  bool get isWaiting => !_subject.hasValue && !_subject.hasError;
+
+  /// The output stream that can be used to listen to the data
+  Stream<T> get stream => _subject.stream;
+
+  /// A synchronous getter for the current value
+  T get value => _subject.value;
+
+  /// A setter for updating the value
+  set value(T value) => _subject.add(value);
+
+  /// Don't forget to call this when done
+  void close() => _subject.close();
+}