flo_scene 0.2.0

Entity-messaging system for composing large programs from small programs
Documentation 
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
55
56
57
58
59
60
61
62
63
64
65
66
67

use flo_scene::*;
use flo_scene::programs::*;

use std::io::*;

#[test]
fn read_input() {
    let input_source = "first line\n\
        chars\n\
        final line".as_bytes();

    let scene = Scene::default();

    // Create a test input program
    let test_input_stream = SubProgramId::new();
    scene.add_subprogram(test_input_stream, |input, context| text_input_subprogram(BufReader::new(input_source), input, context), 20);    

    // Connect it as the default IO program
    scene.connect_programs((), test_input_stream, StreamId::with_message_type::<TextInput>()).unwrap();

    // Try reading from the stream
    let test_subprogram = SubProgramId::new();
    TestBuilder::new()
        .send_message(TextInput::RequestLine(test_subprogram))
        .expect_message(|input: TextInputResult| if input == TextInputResult::Characters("first line".to_string()) { Ok(()) } else { Err(format!("first line != {:?}", input)) })
        .send_message(TextInput::RequestCharacter(test_subprogram))
        .send_message(TextInput::RequestCharacter(test_subprogram))
        .send_message(TextInput::RequestCharacter(test_subprogram))
        .send_message(TextInput::RequestCharacter(test_subprogram))
        .send_message(TextInput::RequestCharacter(test_subprogram))
        .send_message(TextInput::RequestCharacter(test_subprogram))
        .expect_message(|input: TextInputResult| if input == TextInputResult::Characters("c".to_string()) { Ok(()) } else { Err(format!("c != {:?}", input)) })
        .expect_message(|input: TextInputResult| if input == TextInputResult::Characters("h".to_string()) { Ok(()) } else { Err(format!("h != {:?}", input)) })
        .expect_message(|input: TextInputResult| if input == TextInputResult::Characters("a".to_string()) { Ok(()) } else { Err(format!("a != {:?}", input)) })
        .expect_message(|input: TextInputResult| if input == TextInputResult::Characters("r".to_string()) { Ok(()) } else { Err(format!("r != {:?}", input)) })
        .expect_message(|input: TextInputResult| if input == TextInputResult::Characters("s".to_string()) { Ok(()) } else { Err(format!("s != {:?}", input)) })
        .expect_message(|input: TextInputResult| if input == TextInputResult::Characters("\n".to_string()) { Ok(()) } else { Err(format!("\\n != {:?}", input)) })
        .send_message(TextInput::RequestLine(test_subprogram))
        .expect_message(|input: TextInputResult| if input == TextInputResult::Characters("final line".to_string()) { Ok(()) } else { Err(format!("final line != {:?}", input)) })
        .send_message(TextInput::RequestLine(test_subprogram))
        .expect_message(|input: TextInputResult| if input == TextInputResult::Eof { Ok(()) } else { Err(format!("EOF != {:?}", input)) })
        .send_message(TextInput::RequestCharacter(test_subprogram))
        .expect_message(|input: TextInputResult| if input == TextInputResult::Eof { Ok(()) } else { Err(format!("EOF != {:?}", input)) })
        .run_in_scene_with_threads(&scene, test_subprogram, 5);
}

#[test]
fn prompt_for_input() {
    let input_source = "42".as_bytes();

    let scene = Scene::default();

    // Create a test input program
    let test_input_stream = SubProgramId::called("test_input_stream");
    scene.add_subprogram(test_input_stream, |input, context| text_input_subprogram(BufReader::new(input_source), input, context), 20);    

    // Connect it as the default IO program
    scene.connect_programs((), test_input_stream, StreamId::with_message_type::<TextInput>()).unwrap();

    // Read from the stream with a prompt
    let test_subprogram = SubProgramId::called("test_subprogram");
    TestBuilder::new()
        .send_message(TextInput::PromptRequestLine(vec![TextOutput::Line(format!("PROMPT> "))], test_subprogram))
        .expect_message(|output: TextOutput| if output == TextOutput::Line(format!("PROMPT> ")) { Ok(()) } else { Err(format!("'PROMPT> ' != {:?}", output))})
        .expect_message(|input: TextInputResult| if input == TextInputResult::Characters(format!("42")) { Ok(()) } else { Err(format!("42 != {:?}", input)) })
        .run_in_scene(&scene, test_subprogram);
}