mirror of
https://github.com/uqbar-dao/nectar.git
synced 2024-12-23 00:21:38 +03:00
Format Rust code using rustfmt
This commit is contained in:
parent
028acd66ef
commit
a8f2921340
@ -354,7 +354,8 @@ impl UqProcessImports for ProcessWasi {
|
||||
},
|
||||
None,
|
||||
)
|
||||
.await else {
|
||||
.await
|
||||
else {
|
||||
return Ok(Err(wit::SpawnError::NoFileAtPath));
|
||||
};
|
||||
let wit::Message::Response((wit::Response { ipc: Some(ipc), .. }, _)) = hash_response
|
||||
@ -383,7 +384,8 @@ impl UqProcessImports for ProcessWasi {
|
||||
},
|
||||
None,
|
||||
)
|
||||
.await else {
|
||||
.await
|
||||
else {
|
||||
return Ok(Err(wit::SpawnError::NoFileAtPath));
|
||||
};
|
||||
|
||||
@ -462,7 +464,9 @@ impl UqProcessImports for ProcessWasi {
|
||||
mime: None,
|
||||
bytes: bytes.to_vec(),
|
||||
}),
|
||||
).await else {
|
||||
)
|
||||
.await
|
||||
else {
|
||||
return Ok(Err(wit::SpawnError::NameTaken));
|
||||
};
|
||||
|
||||
|
@ -1,3 +1,4 @@
|
||||
use crate::types::*;
|
||||
use anyhow::Result;
|
||||
use crossterm::{
|
||||
cursor,
|
||||
@ -13,7 +14,6 @@ use futures::{future::FutureExt, StreamExt};
|
||||
use std::collections::VecDeque;
|
||||
use std::fs::{read_to_string, File, OpenOptions};
|
||||
use std::io::{stdout, BufWriter, Write};
|
||||
use crate::types::*;
|
||||
|
||||
#[derive(Debug)]
|
||||
struct CommandHistory {
|
||||
|
@ -149,8 +149,7 @@ async fn persist_state(our_node: String, send_to_loop: &MessageSender, state: &I
|
||||
inherit: true,
|
||||
expects_response: Some(5), // TODO evaluate
|
||||
ipc: Some(
|
||||
serde_json::to_string(&FsAction::SetState(VFS_PROCESS_ID.clone()))
|
||||
.unwrap(),
|
||||
serde_json::to_string(&FsAction::SetState(VFS_PROCESS_ID.clone())).unwrap(),
|
||||
),
|
||||
metadata: None,
|
||||
}),
|
||||
@ -186,8 +185,7 @@ async fn load_state_from_reboot(
|
||||
inherit: true,
|
||||
expects_response: Some(5), // TODO evaluate
|
||||
ipc: Some(
|
||||
serde_json::to_string(&FsAction::GetState(VFS_PROCESS_ID.clone()))
|
||||
.unwrap(),
|
||||
serde_json::to_string(&FsAction::GetState(VFS_PROCESS_ID.clone())).unwrap(),
|
||||
),
|
||||
metadata: None,
|
||||
}),
|
||||
|
Loading…
Reference in New Issue
Block a user