[feat]: Made io reading methods async

anoma · Jul 26, 2023 · cfb57ab · cfb57ab
1 parent c5a2ce2
commit cfb57ab
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 3 deletions.
diff --git a/apps/src/lib/cli/api.rs b/apps/src/lib/cli/api.rs
@@ -28,6 +28,8 @@ impl CliClient for HttpClient {
 }
 
 pub struct CliIo;
+
+#[async_trait::async_trait(?Send)]
 impl Io for CliIo {}
 
 pub struct CliApi<IO: Io = CliIo>(PhantomData<IO>);
diff --git a/shared/src/ledger/eth_bridge/bridge_pool.rs b/shared/src/ledger/eth_bridge/bridge_pool.rs
@@ -221,7 +221,7 @@ where
         display!(IO, "\nDo you wish to proceed? (y/n): ");
         IO::flush();
         loop {
-            let resp = IO::read().try_halt(|e| {
+            let resp = IO::read().await.try_halt(|e| {
                 display_line!(
                     IO,
                     "Encountered error reading from STDIN: {e:?}"

diff --git a/shared/src/types/io.rs b/shared/src/types/io.rs
@@ -5,8 +5,10 @@
 /// Rust native I/O handling.
 pub struct DefaultIo;
 
+#[async_trait::async_trait(?Send)]
 impl Io for DefaultIo {}
 
+#[async_trait::async_trait(?Send)]
 #[allow(missing_docs)]
 pub trait Io {
     fn print(output: impl AsRef<str>) {
@@ -40,11 +42,11 @@ pub trait Io {
         eprintln!("{}", output.as_ref());
     }
 
-    fn read() -> std::io::Result<String> {
+    async fn read() -> std::io::Result<String> {
         read_aux(std::io::stdin().lock())
     }
 
-    fn prompt(question: impl AsRef<str>) -> String {
+    async fn prompt(question: impl AsRef<str>) -> String {
         prompt_aux(
             std::io::stdin().lock(),
             std::io::stdout(),