better cursor search (#473)

* improve cursor code

* proper unicode support

* refactor and test

* fmt

* clippy

* move methods to state

* refactor search modules

1 files changed, 0 insertions, 70 deletions

diff --git a/src/command/client/event.rs b/src/command/client/event.rs
deleted file mode 100644
index 8044e278..00000000
--- a/src/command/client/event.rs
+++ /dev/null
@@ -1,70 +0,0 @@
-use std::{thread, time::Duration};
-
-use crossbeam_channel::unbounded;
-use termion::{event::Event as TermEvent, event::Key, input::TermRead};
-
-pub enum Event<I> {
-    Input(I),
-    Tick,
-}
-
-/// A small event handler that wrap termion input and tick events. Each event
-/// type is handled in its own thread and returned to a common `Receiver`
-pub struct Events {
-    rx: crossbeam_channel::Receiver<Event<TermEvent>>,
-}
-
-#[derive(Debug, Clone, Copy)]
-pub struct Config {
-    pub exit_key: Key,
-    pub tick_rate: Duration,
-}
-
-impl Default for Config {
-    fn default() -> Config {
-        Config {
-            exit_key: Key::Char('q'),
-            tick_rate: Duration::from_millis(250),
-        }
-    }
-}
-
-impl Events {
-    pub fn new() -> Events {
-        Events::with_config(Config::default())
-    }
-
-    pub fn with_config(config: Config) -> Events {
-        let (tx, rx) = unbounded();
-
-        {
-            let tx = tx.clone();
-            thread::spawn(move || {
-                let tty = termion::get_tty().expect("Could not find tty");
-                for event in tty.events().flatten() {
-                    if let Err(err) = tx.send(Event::Input(event)) {
-                        eprintln!("{}", err);
-                        return;
-                    }
-                }
-            })
-        };
-
-        thread::spawn(move || loop {
-            if tx.send(Event::Tick).is_err() {
-                break;
-            }
-            thread::sleep(config.tick_rate);
-        });
-
-        Events { rx }
-    }
-
-    pub fn next(&self) -> Result<Event<TermEvent>, crossbeam_channel::RecvError> {
-        self.rx.recv()
-    }
-
-    pub fn try_next(&self) -> Result<Event<TermEvent>, crossbeam_channel::TryRecvError> {
-        self.rx.try_recv()
-    }
-}