blob: 9560e1e4393e8eae1e53e76a79ee63518ec34f26 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
|
use std::cmp::Ordering;
use bevy::prelude::*;
use crossterm::event::{read, Event, KeyEvent, KeyEventKind};
use super::{events::TerminalInputEvent, resources::{EventQueue, TerminalInput}};
/// Initializes event queue and thread
pub fn setup_input(event_queue: Res<EventQueue>) {
let event_queue = event_queue.0.clone();
std::thread::spawn(move || {
loop {
// `read()` blocks until an `Event` is available
match read() {
Ok(event) => {
event_queue.lock().unwrap().push(event);
}
Err(err) => {
panic!("Error reading input events: {:?}", err);
}
}
}
});
}
/// Reads events from queue and broadcasts corresponding `TerminalInputEvent`s
pub fn input_handling(
event_queue: Res<EventQueue>,
mut input: ResMut<TerminalInput>,
mut event_writer: EventWriter<TerminalInputEvent>,
) {
input.clear_released();
let mut event_queue = event_queue.0.lock().unwrap();
let mut key_events = Vec::<KeyEvent>::new();
while let Some(event) = event_queue.pop() {
if let Event::Key(event) = event {
key_events.push(event);
}
event_writer.send(TerminalInputEvent(event));
}
key_events.sort_by(|&a, &b| a.kind.partial_cmp(&b.kind).unwrap_or(Ordering::Equal));
for event in key_events {
match event.kind {
KeyEventKind::Press => {
input.press(event.code);
}
KeyEventKind::Release => {
input.release(event.code);
}
_ => (),
}
}
}
|
