mirror of
https://github.com/venera-app/venera.git
synced 2025-09-27 15:57:25 +00:00
Improve image loading
This commit is contained in:
@@ -234,6 +234,7 @@ class _StreamWrapper<T> {
|
|||||||
}
|
}
|
||||||
|
|
||||||
void _listen() async {
|
void _listen() async {
|
||||||
|
try {
|
||||||
await for (var data in _stream) {
|
await for (var data in _stream) {
|
||||||
if (isClosed) {
|
if (isClosed) {
|
||||||
break;
|
break;
|
||||||
@@ -244,11 +245,21 @@ class _StreamWrapper<T> {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
catch (e) {
|
||||||
|
for (var controller in controllers) {
|
||||||
|
if (!controller.isClosed) {
|
||||||
|
controller.addError(e);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
finally {
|
||||||
for (var controller in controllers) {
|
for (var controller in controllers) {
|
||||||
if (!controller.isClosed) {
|
if (!controller.isClosed) {
|
||||||
controller.close();
|
controller.close();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
}
|
||||||
controllers.clear();
|
controllers.clear();
|
||||||
isClosed = true;
|
isClosed = true;
|
||||||
onClosed(this);
|
onClosed(this);
|
||||||
|
Reference in New Issue
Block a user