Line data    Source code

       1              : import 'dart:async';
       2              : 
       3              : class CachedStreamController<T> {
       4              :   T? _value;
       5              :   Object? _lastError;
       6              :   final StreamController<T> _streamController = StreamController.broadcast();
       7              : 
       8           39 :   CachedStreamController([T? value]) : _value = value;
       9              : 
      10           66 :   T? get value => _value;
      11            0 :   Object? get lastError => _lastError;
      12           84 :   Stream<T> get stream => _streamController.stream;
      13              : 
      14           34 :   void add(T value) {
      15           34 :     _value = value;
      16           68 :     _streamController.add(value);
      17              :   }
      18              : 
      19            1 :   void addError(Object error, [StackTrace? stackTrace]) {
      20            2 :     _lastError = value;
      21            2 :     _streamController.addError(error, stackTrace);
      22              :   }
      23              : 
      24            3 :   Future close() => _streamController.close();
      25            0 :   bool get isClosed => _streamController.isClosed;
      26              : }