WIP: async start

Cargo.toml

@@ -34,3 +34,6 @@ winapi = { version = "0.3", features = ["consoleapi", "handleapi", "minwindef",
 [dev-dependencies]
 tempdir = "0.3"
 assert_matches = "1.2"
+futures = "0.1"
+tokio = "0.1"
+

examples/async.rs

@@ -0,0 +1,40 @@
+use std::thread;
+
+use rustyline::error::ReadlineError;
+use rustyline::Editor;
+
+use futures::future::Future;
+use futures::stream::Stream;
+
+use tokio::sync::mpsc;
+
+fn main() {
+    let (mut stdin_tx, stdin_rx) = mpsc::unbounded_channel();
+    let (mut stdout_tx, stdout_rx) = mpsc::unbounded_channel();
+
+    let mut editor = Editor::<()>::new();
+
+    let thread = thread::spawn(move || loop {
+        let line = editor.readline(">");
+        match &line {
+            Err(ReadlineError::Interrupted) => break,
+            Err(ReadlineError::Eof) => break,
+            _ => (),
+        }
+        stdin_tx.try_send(line);
+    });
+
+    let read_all = stdin_rx.for_each(move |line| {
+        let message = match line {
+            Ok(line) => format!("Line: {}", line),
+            Err(ReadlineError::Interrupted) => format!("CTRL-C"),
+            Err(ReadlineError::Eof) => format!("CTRL-D"),
+            Err(err) => format!("Error: {:?}", err),
+        };
+        stdout_tx.try_send(message);
+
+        Ok(())
+    });
+
+    tokio::run(read_all.map_err(|_| ()));
+}