use std::sync::mpsc;
pub use super::native::*;
use glutin::event_loop::{ControlFlow, EventLoop};
use crate::prelude::*;
pub use self::window::*;
pub use self::window_builder::*;
mod states;
mod window;
mod window_builder;
pub fn initialize() {}
pub struct Shell<A: 'static>
where
A: WindowAdapter,
{
window_shells: Vec<Window<A>>,
requests: mpsc::Receiver<ShellRequest<A>>,
event_loop: Vec<EventLoop<()>>,
}
impl<A> Shell<A>
where
A: WindowAdapter,
{
pub fn new(requests: mpsc::Receiver<ShellRequest<A>>) -> Self {
Shell {
window_shells: vec![],
requests,
event_loop: vec![EventLoop::new()],
}
}
pub fn create_window(&mut self, adapter: A) -> WindowBuilder<A> {
WindowBuilder::new(self, adapter)
}
pub fn create_window_from_settings(
&mut self,
settings: WindowSettings,
adapter: A,
) -> WindowBuilder<A> {
WindowBuilder::from_settings(settings, self, adapter)
}
pub fn receive_requests(&mut self) {
let mut requests = vec![];
for request in self.requests.try_iter() {
requests.push(request);
}
for request in requests {
match request {
ShellRequest::CreateWindow(adapter, settings, window_requests) => {
self.create_window_from_settings(settings, adapter)
.request_receiver(window_requests)
.build();
}
_ => {}
}
}
}
pub fn event_loop(&self) -> &EventLoop<()> {
self.event_loop.get(0).unwrap()
}
pub fn run(mut self) {
self.event_loop
.pop()
.unwrap()
.run(move |event, _, control_flow| {
if self.window_shells.is_empty() {
*control_flow = ControlFlow::Exit;
}
for i in 0..self.window_shells.len() {
let mut remove = false;
if let Some(window_shell) = self.window_shells.get_mut(i) {
window_shell.render();
window_shell.update();
window_shell.drain_events(control_flow, &event);
window_shell.receive_requests();
if !window_shell.is_open() {
remove = true;
}
}
if remove {
self.window_shells.remove(i);
break;
}
}
});
}
}