bug
This commit is contained in:
parent
3cba56c809
commit
c03c49d482
@ -521,10 +521,11 @@ pub fn set_option(key: &str, value: &str) {
|
|||||||
|
|
||||||
#[tokio::main(flavor = "current_thread")]
|
#[tokio::main(flavor = "current_thread")]
|
||||||
pub async fn set_options(value: HashMap<String, String>) -> ResultType<()> {
|
pub async fn set_options(value: HashMap<String, String>) -> ResultType<()> {
|
||||||
let mut c = connect(1000, "").await?;
|
if let Ok(mut c) = connect(1000, "").await {
|
||||||
c.send(&Data::Options(Some(value.clone()))).await?;
|
c.send(&Data::Options(Some(value.clone()))).await?;
|
||||||
// do not put below before connect, because we need to check should_exit
|
// do not put below before connect, because we need to check should_exit
|
||||||
c.next_timeout(1000).await.ok();
|
c.next_timeout(1000).await.ok();
|
||||||
|
}
|
||||||
Config::set_options(value);
|
Config::set_options(value);
|
||||||
Ok(())
|
Ok(())
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user