Add one missing error handling
This commit is contained in:
parent
3cce3e43d9
commit
508e7d8ccf
|
@ -583,7 +583,7 @@ fn stream_worker(rx: TriggerReceiver,
|
|||
continue;
|
||||
},
|
||||
Err(err) => {
|
||||
// TODO: signal errors
|
||||
error_callback(err.into());
|
||||
continue;
|
||||
}
|
||||
};
|
||||
|
|
Loading…
Reference in New Issue