File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -551,8 +551,8 @@ class HyperStorage extends _HyperStorageImpl {
551551 /// * [serializableItemHolder] - Direct access to the underlying SerializableItemHolder
552552 /// * [jsonStream] - For JSON serialization
553553 Stream <E ?> serializableStream <E extends Object >(
554- String key, {
555- required SerializeCallback <E > serialize,
556- required DeserializeCallback <E > deserialize,
557- }) => serializableItemHolder <E >(key, serialize: serialize, deserialize: deserialize);
554+ String key, {
555+ required SerializeCallback <E > serialize,
556+ required DeserializeCallback <E > deserialize,
557+ }) => serializableItemHolder <E >(key, serialize: serialize, deserialize: deserialize);
558558}
Original file line number Diff line number Diff line change @@ -88,13 +88,16 @@ class ItemHolder<E extends Object> extends ManagedStream<E?> implements BaseList
8888 if (isClosed || _isFetching) return ;
8989 _isFetching = true ;
9090
91- get ().then (emit).catchError ((error, stackTrace) {
92- // If no value has been cached yet, emit null so listeners receive something.
93- // If a value exists, retain it rather than overwriting with null.
94- if (! streamController.hasValue) {
95- emit (null );
96- }
97- }).whenComplete (() => _isFetching = false );
91+ get ()
92+ .then (emit)
93+ .catchError ((error, stackTrace) {
94+ // If no value has been cached yet, emit null so listeners receive something.
95+ // If a value exists, retain it rather than overwriting with null.
96+ if (! streamController.hasValue) {
97+ emit (null );
98+ }
99+ })
100+ .whenComplete (() => _isFetching = false );
98101 }
99102
100103 @override
Original file line number Diff line number Diff line change @@ -245,11 +245,13 @@ void main() {
245245
246246 expect (
247247 () => stream.listen ((_) {}),
248- throwsA (isA <StateError >().having (
249- (e) => e.message,
250- 'message' ,
251- contains ('Cannot listen to a disposed' ),
252- )),
248+ throwsA (
249+ isA <StateError >().having (
250+ (e) => e.message,
251+ 'message' ,
252+ contains ('Cannot listen to a disposed' ),
253+ ),
254+ ),
253255 );
254256 });
255257
You can’t perform that action at this time.
0 commit comments