updated

Author: hoc081098

README.md

@@ -51,7 +51,6 @@ class MyBloc implements BaseBloc {
 ```dart
 import 'dart:async';
 
-import 'package:distinct_value_connectable_stream/distinct_value_connectable_stream.dart';
 import 'package:flutter_bloc_pattern/flutter_bloc_pattern.dart';
 import 'package:rxdart_ext/rxdart_ext.dart';
 
@@ -60,7 +59,7 @@ class CounterBloc extends DisposeCallbackBaseBloc {
   final VoidAction increment;
 
   /// Outputs
-  final DistinctValueStream<int> state;
+  final StateStream<int> state;
 
   CounterBloc._({
     required void Function() dispose,
@@ -74,7 +73,7 @@ class CounterBloc extends DisposeCallbackBaseBloc {
 
     final state = incrementController.stream
         .scan<int>((acc, _, __) => acc + 1, 0)
-        .publishValueDistinct(0);
+        .publishState(0);
     final connection = state.connect();
 
     return CounterBloc._(
@@ -88,7 +87,6 @@ class CounterBloc extends DisposeCallbackBaseBloc {
     );
   }
 }
-
 ```
 
 ### 2. File `main.dart`:

lib/src/rx_stream_builder.dart

@@ -1,5 +1,6 @@
 import 'dart:async';
 
+import 'package:flutter/foundation.dart';
 import 'package:flutter/widgets.dart';
 import 'package:rxdart/rxdart.dart';
 import 'package:rxdart_ext/rxdart_ext.dart';
@@ -46,7 +47,7 @@ class RxStreamBuilder<T> extends StatefulWidget {
   @override
   _RxStreamBuilderState<T> createState() => _RxStreamBuilderState();
 
-  /// Get latest value from stream or return `null`.
+  /// Get latest value from stream or throw an [ArgumentError].
   @visibleForTesting
   static T getInitialData<T>(ValueStream<T> stream) {
     if (stream is StateStream<T>) {
@@ -55,7 +56,7 @@ class RxStreamBuilder<T> extends StatefulWidget {
     if (stream.hasValue) {
       return stream.value;
     }
-    throw ArgumentError.value(stream, 'stream', 'does not have value');
+    throw ArgumentError.value(stream, 'stream', 'has no value');
   }
 }
 
@@ -123,4 +124,12 @@ class _RxStreamBuilderState<T> extends State<RxStreamBuilder<T>> {
     subscription?.cancel();
     subscription = null;
   }
+
+  @override
+  void debugFillProperties(DiagnosticPropertiesBuilder properties) {
+    super.debugFillProperties(properties);
+    properties.add(DiagnosticsProperty.lazy('value', () => value));
+    properties.add(DiagnosticsProperty('subscription', subscription));
+    properties.add(DiagnosticsProperty('stream', widget._stream));
+  }
 }