日本免费高清视频-国产福利视频导航-黄色在线播放国产-天天操天天操天天操天天操|www.shdianci.com

學無先后，達者為師

網站首頁 編程語言 正文

Flutter?Recovering?Stream?Errors小技巧_Android

作者：程序員界的小學生 ? 更新時間： 2023-01-06 編程語言

正文

你是否遇到過，出現異常的時候也需要給一個默認值，讓程序可以繼續運行下去？

一般的做法就是 一個達到try catch，然后在finally里面做一個處理。

今天我嘗試換一個思路，簡單的封裝一下

簡單封裝

首先定義一個stream轉換器，為了處理error handler。

如果onError不為空，就將出現錯誤添加到stream中

class StreamErrorHandle<T> extends StreamTransformerBase<T, T> {
    final _controller = StreamController<T>.broadcast();
    final T? Function(Object error) onError;
    StreamErrorHandler({
        required this.onError,
    });
    @override
    Stream<T> bind(Stream<T> stream) {
        ...
    }
}

override bind()

用Stream里面的handleError來捕獲錯誤。如果出現錯誤，我們調用handler，如果我們得到一個返回值，就將他發送到stream

@override
Stream<T> bind(Stream<T> stream) {
    final sub = stream.handleError((error) {
        final value = onError(error);
        if (value != null) {
            _controller.sink.add(value);
        }
    }).listen(_controller.sink.add);
    _controller.onCancel = (){
        sub.cancel();
    };
    return _controller.stream;
}

最后我們在Stream上面創建一個拓展，它允許我們輕松的使用我們的流轉換器

extension Recover<T> on Stream<T> {
    Stream<T> onErrorRecoverWith(T? Functioon(Object error) onError) => transform(StreamErrorHandle<T>(onError: onError));
}

測試一下

Stream<String> getNames() async* {
    yield 'Foo'.
    yield 'Bar';
    throw Exception('Something went wrong');
}
Future<void> testIt() async {
    final names = getNames().onErrorRecoverWith(
        (error) {
            error.log();
            return 'Baz';
        },
    );
    await for(final name in names){
        name.log(); // Foo, Bar, Baz
    }
}

最后來看一下結果：

這里面有一個小注意的地方，log()是我自己封裝的一個拓展

import 'dart:developer' as devtools show log;
extension Log on Object {
    void log() => devtools.log(toString());
}

原文鏈接：https://juejin.cn/post/7173543847287324680

欄目分類
最近更新