目录正文简单封装override bind()测试一下正文 你是否遇到过,出现异常的时候也需要给一个默认值,让程序可以继续运行下去? 一般的做法就是 一个达到try catch,然
你是否遇到过,出现异常的时候也需要给一个默认值,让程序可以继续运行下去?
一般的做法就是 一个达到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) {
...
}
}
用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());
}
以上就是Flutter Recovering Stream Errors小技巧的详细内容,更多关于Flutter Recovering Stream Errors的资料请关注编程网其它相关文章!
--结束END--
本文标题: FlutterRecoveringStreamErrors小技巧
本文链接: https://www.lsjlt.com/news/174583.html(转载时请注明来源链接)
有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341
下载Word文档到电脑,方便收藏和打印~
2024-01-21
2023-10-28
2023-10-28
2023-10-27
2023-10-27
2023-10-27
2023-10-27
回答
回答
回答
回答
回答
回答
回答
回答
回答
回答
0