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

use super::events::*;
use super::glutin_thread::*;
use super::window_properties::*;
use super::glutin_thread_event::*;

use flo_stream::*;
use flo_render::*;

use futures::prelude::*;

///
/// Creates a window that can be rendered to by sending groups of render actions
///
pub fn create_render_window<'a, TProperties: 'a+FloWindowProperties>(properties: TProperties) -> (Publisher<Vec<RenderAction>>, impl Clone+Send+Stream<Item=DrawEvent>) {
    // Create the publisher to send the render actions to the stream
    let mut render_publisher    = Publisher::new(1);
    let event_subscriber        = create_render_window_from_stream(render_publisher.subscribe(), properties);

    // Publisher can now be used to render to the window
    (render_publisher, event_subscriber)
}

///
/// Creates a window that renders a stream of actions
///
pub fn create_render_window_from_stream<'a, RenderStream: 'static+Send+Stream<Item=Vec<RenderAction>>, TProperties: 'a+FloWindowProperties>(render_stream: RenderStream, properties: TProperties) -> impl Clone+Send+Stream<Item=DrawEvent> {
    // Create the publisher to send the render actions to the stream
    let window_properties       = WindowProperties::from(&properties);
    let mut event_publisher     = Publisher::new(1000);

    let event_subscriber        = event_publisher.subscribe();

    // Create a window that subscribes to the publisher
    let glutin_thread           = glutin_thread();
    glutin_thread.send_event(GlutinThreadEvent::CreateRenderWindow(render_stream.boxed(), event_publisher, window_properties));

    // Result is the events for the new window
    event_subscriber
}